This is an automated email from the ASF dual-hosted git repository.
ascherbakov pushed a change to branch ignite-14149
in repository https://gitbox.apache.org/repos/asf/ignite-3.git.
from d70fe7d IGNITE-14149 Services.
new 092bc39 IGNITE-14149 Cleanup.
new df9226b IGNITE-14149 wip.
new ac96cae IGNITE-14149 wip.
new c4871ce IGNITE-14149 wip.
The 4 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../main/java/org/apache/ignite/raft/PeerId.java | 4 +
.../main/java/org/apache/ignite/raft/State.java | 265 +--------------------
...CommonMessages.java => RaftClientMessages.java} | 8 +-
.../client/message/AddLearnersRequestImpl.java | 7 +-
.../raft/client/message/AddPeerRequestImpl.java | 6 +-
.../raft/client/message/AddPeerResponseImpl.java | 6 +-
.../raft/client/message/ChangePeerRequestImpl.java | 6 +-
.../client/message/ChangePeersResponseImpl.java | 6 +-
.../message/ClientMessageBuilderFactory.java | 44 ++--
.../raft/client/message/GetLeaderRequestImpl.java | 6 +-
.../raft/client/message/GetLeaderResponseImpl.java | 6 +-
.../raft/client/message/GetPeersRequestImpl.java | 6 +-
.../raft/client/message/GetPeersResponseImpl.java | 6 +-
.../client/message/LearnersOpResponseImpl.java | 6 +-
.../raft/client/message/PingRequestImpl.java | 6 +-
.../RaftClientCommonMessageBuilderFactory.java | 86 -------
.../message/RaftClientMessageBuilderFactory.java | 94 ++++++++
.../client/message/RemoveLearnersRequestImpl.java | 6 +-
.../raft/client/message/RemovePeerRequestImpl.java | 6 +-
.../client/message/RemovePeerResponseImpl.java | 6 +-
.../client/message/ResetLearnersRequestImpl.java | 6 +-
.../raft/client/message/ResetPeerRequestImpl.java | 6 +-
.../raft/client/message/SnapshotRequestImpl.java | 7 +-
.../raft/client/message/StatusResponseImpl.java | 6 +-
.../client/message/TransferLeaderRequestImpl.java | 6 +-
.../raft/client/message/UserRequestImpl.java | 32 +++
.../raft/client/message/UserResponseImpl.java | 21 ++
.../ignite/raft/client/rpc/RaftGroupRpcClient.java | 50 ++--
.../client/rpc/impl/RaftGroupRpcClientImpl.java | 144 +++++++----
.../service/RaftGroupClientRequestListener.java | 2 +-
.../service/RaftGroupClientRequestService.java | 7 +
.../client/service/RaftGroupManagmentService.java | 8 +-
.../impl/RaftGroupClientRequestServiceImpl.java | 20 +-
.../impl/RaftGroupManagementServiceImpl.java | 8 +-
.../java/org/apache/ignite/raft/rpc/NodeImpl.java | 2 +-
.../apache/ignite/raft/rpc/RaftGroupMessage.java | 3 +
.../java/org/apache/ignite/raft/rpc/RpcClient.java | 8 +-
.../ignite/raft/client/RaftGroupRpcClientTest.java | 98 --------
.../raft/client/rpc/RaftGroupRpcClientTest.java | 183 ++++++++++++++
.../service/RaftGroupClientRequestServiceTest.java | 132 ++++++++++
40 files changed, 721 insertions(+), 614 deletions(-)
rename
modules/raft-client/src/main/java/org/apache/ignite/raft/client/{RaftClientCommonMessages.java
=> RaftClientMessages.java} (97%)
delete mode 100644
modules/raft-client/src/main/java/org/apache/ignite/raft/client/message/RaftClientCommonMessageBuilderFactory.java
create mode 100644
modules/raft-client/src/main/java/org/apache/ignite/raft/client/message/RaftClientMessageBuilderFactory.java
create mode 100644
modules/raft-client/src/main/java/org/apache/ignite/raft/client/message/UserRequestImpl.java
create mode 100644
modules/raft-client/src/main/java/org/apache/ignite/raft/client/message/UserResponseImpl.java
delete mode 100644
modules/raft-client/src/test/java/org/apache/ignite/raft/client/RaftGroupRpcClientTest.java
create mode 100644
modules/raft-client/src/test/java/org/apache/ignite/raft/client/rpc/RaftGroupRpcClientTest.java
create mode 100644
modules/raft-client/src/test/java/org/apache/ignite/raft/client/service/RaftGroupClientRequestServiceTest.java
