This is an automated email from the ASF dual-hosted git repository.
ibessonov pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/ignite-3.git.
from 4d82a7e IGNITE-14438 Added README.md for cli and cli-common modules.
Fixes #75
add e9ef6d4 IGNITE-14295 Network messages refactored to have a common
interface and proper serializers/deserializers. (#70)
No new revisions were added by this update.
Summary of changes:
.../ITScaleCubeNetworkClusterMessagingTest.java | 107 ++++++++++++++--
.../ignite/network/scalecube/TestMessage.java | 16 ++-
.../scalecube/TestMessageMapperProvider.java | 54 ++++++++
.../scalecube/TestNetworkHandlersProvider.java | 2 +-
.../ignite/network/scalecube/TestRequest.java} | 33 +++--
.../scalecube/TestRequestMapperProvider.java | 54 ++++++++
.../ignite/network/scalecube/TestResponse.java} | 34 +++--
.../scalecube/TestResponseMapperProvider.java | 54 ++++++++
.../java/org/apache/ignite/network/Network.java | 66 ++++++++++
.../org/apache/ignite/network/NetworkCluster.java | 14 +-
.../ignite/network/NetworkClusterContext.java | 57 +++++++++
.../ignite/network/NetworkClusterFactory.java | 56 +-------
.../network/NetworkConfigurationException.java} | 17 +--
...rkMessageHandler.java => NetworkException.java} | 22 ++--
.../org/apache/ignite/network/NetworkMessage.java | 59 ---------
.../ignite/network/NetworkMessageHandler.java | 2 +
.../ignite/network/internal/MessageReader.java} | 16 +--
.../ignite/network/internal/MessageWriter.java} | 16 +--
.../ignite/network/message/AckResponse.java} | 10 +-
.../network/message/MessageDeserializer.java} | 19 +--
.../network/message/MessageMapperProvider.java} | 30 ++---
.../network/message/MessageMappingException.java} | 17 +--
.../ignite/network/message/MessageSerializer.java} | 28 ++--
.../ignite/network/message/NetworkMessage.java} | 11 +-
.../network/scalecube/ScaleCubeMessageCodec.java | 133 +++++++++++++++++++
.../network/scalecube/ScaleCubeMessageHandler.java | 7 +-
.../network/scalecube/ScaleCubeMessageReader.java} | 26 ++--
.../network/scalecube/ScaleCubeMessageWriter.java} | 26 ++--
.../network/scalecube/ScaleCubeNetworkCluster.java | 31 +++--
.../ScaleCubeNetworkClusterFactory.java} | 71 ++++++++---
.../ignite/raft/client/message/ActionRequest.java | 3 +-
.../ignite/raft/client/message/ActionResponse.java | 4 +-
.../raft/client/message/AddLearnersRequest.java | 3 +-
.../raft/client/message/AddPeersRequest.java | 3 +-
.../raft/client/message/ChangePeersResponse.java | 3 +-
.../raft/client/message/GetLeaderRequest.java | 4 +-
.../raft/client/message/GetLeaderResponse.java | 3 +-
.../raft/client/message/GetPeersRequest.java | 4 +-
.../raft/client/message/GetPeersResponse.java | 3 +-
.../raft/client/message/RaftErrorResponse.java | 3 +-
.../raft/client/message/RemoveLearnersRequest.java | 3 +-
.../raft/client/message/RemovePeersRequest.java | 3 +-
.../raft/client/message/SnapshotRequest.java | 4 +-
.../client/message/TransferLeadershipRequest.java | 3 +-
.../client/message/impl/ActionRequestImpl.java | 5 +
.../client/message/impl/ActionResponseImpl.java | 5 +
.../message/impl/AddLearnersRequestImpl.java | 5 +
.../client/message/impl/AddPeersRequestImpl.java | 5 +
.../message/impl/ChangePeersResponseImpl.java | 5 +
.../client/message/impl/GetLeaderRequestImpl.java | 5 +
.../client/message/impl/GetLeaderResponseImpl.java | 5 +
.../client/message/impl/GetPeersRequestImpl.java | 5 +
.../client/message/impl/GetPeersResponseImpl.java | 5 +
.../client/message/impl/RaftErrorResponseImpl.java | 5 +
.../message/impl/RemoveLearnersRequestImpl.java | 5 +
.../message/impl/RemovePeersRequestImpl.java | 5 +
.../client/message/impl/SnapshotRequestImpl.java | 5 +
.../impl/TransferLeadershipRequestImpl.java | 5 +
.../client/service/impl/RaftGroupServiceImpl.java | 141 ++++++++-------------
.../raft/client/service/RaftGroupServiceTest.java | 20 +--
60 files changed, 942 insertions(+), 423 deletions(-)
create mode 100644
modules/network/src/integrationTest/java/org/apache/ignite/network/scalecube/TestMessageMapperProvider.java
copy
modules/{schema/src/main/java/org/apache/ignite/internal/schema/IndexColumnImpl.java
=>
network/src/integrationTest/java/org/apache/ignite/network/scalecube/TestRequest.java}
(59%)
create mode 100644
modules/network/src/integrationTest/java/org/apache/ignite/network/scalecube/TestRequestMapperProvider.java
copy
modules/{api/src/main/java/org/apache/ignite/schema/builder/HashIndexBuilder.java
=>
network/src/integrationTest/java/org/apache/ignite/network/scalecube/TestResponse.java}
(58%)
create mode 100644
modules/network/src/integrationTest/java/org/apache/ignite/network/scalecube/TestResponseMapperProvider.java
create mode 100644
modules/network/src/main/java/org/apache/ignite/network/Network.java
create mode 100644
modules/network/src/main/java/org/apache/ignite/network/NetworkClusterContext.java
copy
modules/{configuration/src/main/java/org/apache/ignite/configuration/ConfigurationChangeException.java
=>
network/src/main/java/org/apache/ignite/network/NetworkConfigurationException.java}
(68%)
copy
modules/network/src/main/java/org/apache/ignite/network/{NetworkMessageHandler.java
=> NetworkException.java} (70%)
delete mode 100644
modules/network/src/main/java/org/apache/ignite/network/NetworkMessage.java
copy modules/{api/src/main/java/org/apache/ignite/binary/BinaryObject.java =>
network/src/main/java/org/apache/ignite/network/internal/MessageReader.java}
(74%)
copy modules/{api/src/main/java/org/apache/ignite/binary/BinaryObject.java =>
network/src/main/java/org/apache/ignite/network/internal/MessageWriter.java}
(74%)
copy modules/{api/src/main/java/org/apache/ignite/schema/HashIndex.java =>
network/src/main/java/org/apache/ignite/network/message/AckResponse.java} (76%)
copy modules/{api/src/main/java/org/apache/ignite/schema/PrimaryIndex.java =>
network/src/main/java/org/apache/ignite/network/message/MessageDeserializer.java}
(65%)
copy modules/{api/src/main/java/org/apache/ignite/schema/Column.java =>
network/src/main/java/org/apache/ignite/network/message/MessageMapperProvider.java}
(62%)
copy
modules/{configuration/src/main/java/org/apache/ignite/configuration/ConfigurationChangeException.java
=>
network/src/main/java/org/apache/ignite/network/message/MessageMappingException.java}
(67%)
copy
modules/{schema/src/main/java/org/apache/ignite/internal/schema/marshaller/SerializationException.java
=>
network/src/main/java/org/apache/ignite/network/message/MessageSerializer.java}
(65%)
copy modules/{api/src/main/java/org/apache/ignite/schema/SchemaObject.java =>
network/src/main/java/org/apache/ignite/network/message/NetworkMessage.java}
(81%)
create mode 100644
modules/network/src/main/java/org/apache/ignite/network/scalecube/ScaleCubeMessageCodec.java
copy
modules/{configuration/src/main/java/org/apache/ignite/configuration/validation/ValidationIssue.java
=>
network/src/main/java/org/apache/ignite/network/scalecube/ScaleCubeMessageReader.java}
(65%)
copy
modules/{configuration/src/main/java/org/apache/ignite/configuration/validation/ValidationIssue.java
=>
network/src/main/java/org/apache/ignite/network/scalecube/ScaleCubeMessageWriter.java}
(65%)
copy
modules/network/src/main/java/org/apache/ignite/network/{NetworkClusterFactory.java
=> scalecube/ScaleCubeNetworkClusterFactory.java} (50%)
