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%)