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
