This is an automated email from the ASF dual-hosted git repository.
vpyatkov pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/ignite-3.git
from 397abf2d0c IGNITE-18132 Scale down scheduler added (#1631)
add 38833ffcf2 IGNITE-18639 Implement distributed onLeaderElected callback
within topology aware raft client (#1648)
No new revisions were added by this update.
Summary of changes:
modules/placement-driver/build.gradle | 13 +
.../client/TopologyAwareRaftGroupServiceTest.java | 384 ++++++++++++++++++
.../raft/client/TopologyAwareRaftGroupService.java | 446 +++++++++++++++++++++
.../internal/raft/server/impl/JraftServerImpl.java | 9 +-
.../impl/RaftGroupEventsListenerAdapter.java | 29 +-
.../raft/server/impl/RaftServiceEventListener.java | 136 +++++++
.../apache/ignite/raft/jraft/RaftMessageGroup.java | 13 +-
.../apache/ignite/raft/jraft/rpc/CliRequests.java | 26 +-
.../apache/ignite/raft/jraft/rpc/RpcContext.java | 21 +-
.../raft/jraft/rpc/impl/IgniteRpcServer.java | 104 +++--
.../raft/jraft/rpc/impl/NotifyElectProcessor.java | 66 +++
.../ignite/raft/jraft/test/MockAsyncContext.java | 20 +-
.../ignite/raft/jraft/rpc/TestIgniteRpcServer.java | 14 +-
13 files changed, 1234 insertions(+), 47 deletions(-)
create mode 100644
modules/placement-driver/src/integrationTest/java/org/apache/ignite/internal/raft/client/TopologyAwareRaftGroupServiceTest.java
create mode 100644
modules/placement-driver/src/main/java/org/apache/ignite/internal/raft/client/TopologyAwareRaftGroupService.java
create mode 100644
modules/raft/src/main/java/org/apache/ignite/internal/raft/server/impl/RaftServiceEventListener.java
create mode 100644
modules/raft/src/main/java/org/apache/ignite/raft/jraft/rpc/impl/NotifyElectProcessor.java
