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 c4871ce IGNITE-14149 wip. add db91bfb IGNITE-14181 Support arrays of primitives in the configuration schema (#54) add ca0d35e IGNITE-14194 Multiple storages support for configuration framework. (#55) add 552d887 IGNITE-14110 Networking module basic API and implementation - #53 add c548a82 IGNITE-14110 Code style and maven configuration fixes new b22ccf8 Merge branch 'main' of https://gitbox.apache.org/repos/asf/ignite-3 into ignite-14149 new 399f640 IGNITE-14149 Migrate to ignite network. The 2 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: .../processor/internal/ITProcessorTest.java | 12 +- .../configuration/processor/internal/Types.java | 3 + .../internal/TestConfigurationSchema.java | 3 + .../processor/internal/Processor.java | 138 +++++++--- .../internal/util/ConfigurationUtilTest.java | 32 ++- .../sample/ConfigurationArrayTest.java | 105 ++++++++ .../sample/storage/ConfigurationChangerTest.java | 69 ++--- .../sample/storage/TestConfigurationStorage.java | 6 +- .../ignite/configuration/ConfigurationChanger.java | 277 ++++++++++++--------- .../configuration/ConfigurationRegistry.java | 20 ++ .../org/apache/ignite/configuration/RootKey.java | 13 +- .../apache/ignite/configuration/RootKeyImpl.java | 56 +++++ .../internal/util/ConfigurationUtil.java | 130 +++++++++- .../storage/ConfigurationStorage.java | 2 +- .../apache/ignite/configuration/storage/Data.java | 6 +- .../ignite/configuration/tree/InnerNode.java | 2 +- modules/{raft-client => network}/pom.xml | 42 +++- .../ITScaleCubeNetworkClusterMessagingTest.java | 97 ++++++++ .../ignite/network/scalecube/TestMessage.java} | 52 ++-- .../scalecube/TestNetworkHandlersProvider.java | 63 +++++ .../ignite/network/MessageHandlerHolder.java | 59 +++++ .../org/apache/ignite/network/NetworkCluster.java | 83 ++++++ .../network/NetworkClusterEventHandler.java} | 31 +-- .../ignite/network/NetworkClusterFactory.java | 75 ++++++ .../ignite/network/NetworkHandlersProvider.java} | 26 +- .../org/apache/ignite/network/NetworkMember.java} | 48 ++-- .../org/apache/ignite/network/NetworkMessage.java | 59 +++++ .../ignite/network/NetworkMessageHandler.java} | 12 +- .../network/scalecube/ScaleCubeMemberResolver.java | 64 +++++ .../network/scalecube/ScaleCubeMessageHandler.java | 100 ++++++++ .../network/scalecube/ScaleCubeNetworkCluster.java | 113 +++++++++ modules/raft-client/pom.xml | 5 + .../org/apache/ignite/raft/ElectionPriority.java | 2 +- .../main/java/org/apache/ignite/raft/PeerId.java | 18 +- .../java/org/apache/ignite/raft/RaftException.java | 16 -- .../ignite/raft/client/RaftClientMessages.java | 66 ++--- .../client/message/AddLearnersRequestImpl.java | 2 +- .../raft/client/message/AddPeerRequestImpl.java | 2 +- .../raft/client/message/ChangePeerRequestImpl.java | 2 +- .../raft/client/message/GetLeaderRequestImpl.java | 2 +- .../raft/client/message/GetPeersRequestImpl.java | 2 +- .../raft/client/message/PingRequestImpl.java | 21 -- ...rFactory.java => RaftClientMessageFactory.java} | 6 +- ...tory.java => RaftClientMessageFactoryImpl.java} | 14 +- .../client/message/RemoveLearnersRequestImpl.java | 2 +- .../raft/client/message/RemovePeerRequestImpl.java | 2 +- .../client/message/ResetLearnersRequestImpl.java | 2 +- .../raft/client/message/ResetPeerRequestImpl.java | 2 +- .../raft/client/message/SnapshotRequestImpl.java | 2 +- .../raft/client/message/StatusResponseImpl.java | 32 --- .../client/message/TransferLeaderRequestImpl.java | 2 +- .../raft/client/message/UserRequestImpl.java | 10 +- .../ignite/raft/client/rpc/RaftGroupRpcClient.java | 30 ++- .../client/rpc/impl/RaftGroupRpcClientImpl.java | 135 ++-------- .../service/RaftGroupClientRequestService.java | 2 +- .../client/service/RaftGroupManagmentService.java | 8 +- .../impl/RaftGroupClientRequestServiceImpl.java | 12 +- .../impl/RaftGroupManagementServiceImpl.java | 2 +- .../org/apache/ignite/raft/rpc/InvokeCallback.java | 24 -- .../java/org/apache/ignite/raft/rpc/Message.java | 4 - .../main/java/org/apache/ignite/raft/rpc/Node.java | 10 - .../apache/ignite/raft/rpc/RaftGroupMessage.java | 8 - .../java/org/apache/ignite/raft/rpc/RpcClient.java | 59 ----- .../org/apache/ignite/raft/client/MockUtils.java | 71 ++++++ .../raft/client/rpc/RaftGroupRpcClientTest.java | 118 +++------ .../service/RaftGroupClientRequestServiceTest.java | 104 ++------ parent/pom.xml | 7 + pom.xml | 1 + 68 files changed, 1742 insertions(+), 863 deletions(-) create mode 100644 modules/configuration-annotation-processor/src/test/java/org/apache/ignite/configuration/sample/ConfigurationArrayTest.java create mode 100644 modules/configuration/src/main/java/org/apache/ignite/configuration/RootKeyImpl.java copy modules/{raft-client => network}/pom.xml (69%) create mode 100644 modules/network/src/integrationTest/java/org/apache/ignite/network/scalecube/ITScaleCubeNetworkClusterMessagingTest.java rename modules/{raft-client/src/main/java/org/apache/ignite/raft/rpc/NodeImpl.java => network/src/integrationTest/java/org/apache/ignite/network/scalecube/TestMessage.java} (53%) create mode 100644 modules/network/src/integrationTest/java/org/apache/ignite/network/scalecube/TestNetworkHandlersProvider.java create mode 100644 modules/network/src/main/java/org/apache/ignite/network/MessageHandlerHolder.java create mode 100644 modules/network/src/main/java/org/apache/ignite/network/NetworkCluster.java copy modules/{cli/src/main/java/org/apache/ignite/cli/builtins/module/ResolveResult.java => network/src/main/java/org/apache/ignite/network/NetworkClusterEventHandler.java} (57%) create mode 100644 modules/network/src/main/java/org/apache/ignite/network/NetworkClusterFactory.java copy modules/{configuration/src/main/java/org/apache/ignite/configuration/tree/NamedListView.java => network/src/main/java/org/apache/ignite/network/NetworkHandlersProvider.java} (64%) copy modules/{configuration/src/main/java/org/apache/ignite/configuration/internal/validation/MemberKey.java => network/src/main/java/org/apache/ignite/network/NetworkMember.java} (53%) create mode 100644 modules/network/src/main/java/org/apache/ignite/network/NetworkMessage.java copy modules/{configuration/src/main/java/org/apache/ignite/configuration/ConfigurationValue.java => network/src/main/java/org/apache/ignite/network/NetworkMessageHandler.java} (77%) create mode 100644 modules/network/src/main/java/org/apache/ignite/network/scalecube/ScaleCubeMemberResolver.java create mode 100644 modules/network/src/main/java/org/apache/ignite/network/scalecube/ScaleCubeMessageHandler.java create mode 100644 modules/network/src/main/java/org/apache/ignite/network/scalecube/ScaleCubeNetworkCluster.java delete mode 100644 modules/raft-client/src/main/java/org/apache/ignite/raft/RaftException.java delete mode 100644 modules/raft-client/src/main/java/org/apache/ignite/raft/client/message/PingRequestImpl.java rename modules/raft-client/src/main/java/org/apache/ignite/raft/client/message/{ClientMessageBuilderFactory.java => RaftClientMessageFactory.java} (89%) rename modules/raft-client/src/main/java/org/apache/ignite/raft/client/message/{RaftClientMessageBuilderFactory.java => RaftClientMessageFactoryImpl.java} (85%) delete mode 100644 modules/raft-client/src/main/java/org/apache/ignite/raft/client/message/StatusResponseImpl.java delete mode 100644 modules/raft-client/src/main/java/org/apache/ignite/raft/rpc/InvokeCallback.java delete mode 100644 modules/raft-client/src/main/java/org/apache/ignite/raft/rpc/Message.java delete mode 100644 modules/raft-client/src/main/java/org/apache/ignite/raft/rpc/Node.java delete mode 100644 modules/raft-client/src/main/java/org/apache/ignite/raft/rpc/RaftGroupMessage.java delete mode 100644 modules/raft-client/src/main/java/org/apache/ignite/raft/rpc/RpcClient.java create mode 100644 modules/raft-client/src/test/java/org/apache/ignite/raft/client/MockUtils.java