You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by ib...@apache.org on 2021/04/01 16:16:38 UTC
[ignite-3] branch main updated (4d82a7e -> e9ef6d4)
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%)