This is an automated email from the ASF dual-hosted git repository. amashenkov pushed a change to branch ignite-14330 in repository https://gitbox.apache.org/repos/asf/ignite-3.git.
from d6d8c79 Styles. add 53e870d IGNITE-14198 Meta storage client interface add 8cf0bb2 IGNITE-14442 Fixed NPE in IgniteRunner caused by broken REST module. (#77) add 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) add 297468b IGNITE-14180 Implemented the ability to subscribe to configuration updates. (#76) add ed2b820 IGNITE-14460 Single-node RAFT server (#80). add 15166f8 IGNITE-14457 Update Ignite 3 binary build structure (#79) add 7710e15 IGNITE-14495 Add common internal exceptions (#85). add 4018647 IGNITE-14393 Modules interaction description add 351ac70 Merge branch 'main' into ignite-14330 add d6d8ad8 Styles. No new revisions were added by this update. Summary of changes: assembly/NOTICE | 0 assembly/README | 0 assembly/assembly.xml | 50 +++ modules/cli-common/README.md | 5 + modules/cli/README.md | 32 ++ modules/configuration-annotation-processor/pom.xml | 12 - .../processor/internal/Processor.java | 31 +- .../configuration/processor/internal/Utils.java | 109 +------ .../storage => }/ConfigurationChangerTest.java | 28 +- .../internal/util/ConfigurationUtilTest.java | 82 ++++- .../internal/validation/ValidationUtilTest.java | 2 +- .../notifications/ConfigurationListenerTest.java | 245 ++++++++++++++ .../sample/LocalConfigurationSchema.java | 2 +- .../sample/NetworkConfigurationSchema.java | 2 +- .../ignite/configuration/sample/UsageTest.java | 16 +- .../storage/TestConfigurationStorage.java | 25 +- modules/configuration/pom.xml | 13 - .../ignite/configuration/ConfigurationChanger.java | 209 +++++++----- .../configuration/ConfigurationProperty.java | 14 +- .../configuration/ConfigurationRegistry.java | 59 +++- .../ignite/configuration/ConfigurationTree.java | 4 +- .../ignite/configuration/ConfigurationValue.java | 6 +- .../configuration/NamedConfigurationTree.java | 9 +- .../ignite/configuration/PropertyListener.java | 61 ---- .../configuration/internal/ConfigurationNode.java | 19 +- .../internal/DynamicConfiguration.java | 9 +- .../configuration/internal/DynamicProperty.java | 16 +- .../internal/NamedListConfiguration.java | 25 +- .../ConfigurationNotificationEventImpl.java} | 42 +-- .../util/ConfigurationNotificationsUtil.java | 184 +++++++++++ .../internal/util/ConfigurationUtil.java | 42 +++ .../notifications/ConfigurationListener.java} | 20 +- .../ConfigurationNamedListListener.java} | 33 +- .../ConfigurationNotificationEvent.java} | 29 +- .../storage/ConfigurationStorage.java | 16 +- .../storage/ConfigurationStorageListener.java | 1 + .../apache/ignite/configuration/storage/Data.java | 22 +- .../ignite/configuration/tree/NamedListNode.java | 5 + .../ignite/configuration/tree/NamedListView.java | 5 + modules/core/pom.xml | 5 +- .../lang/IgniteInternalCheckedException.java | 80 +++++ .../ignite/lang/IgniteInternalException.java | 69 ++++ .../apache/ignite/lang/IgniteRuntimeException.java | 34 -- modules/{cli-common => metastorage-client}/pom.xml | 7 +- .../metastorage/client/MetaStorageService.java | 345 ++++++++++++++++++++ .../ignite/metastorage/client/package-info.java} | 7 +- modules/{cli-common => metastorage-common}/pom.xml | 12 +- .../metastorage/common/CompactedException.java} | 37 ++- .../ignite/metastorage/common/Condition.java | 356 +++++++++++++++++++++ .../ignite/metastorage/common/Conditions.java} | 35 +- .../apache/ignite/metastorage/common/Cursor.java} | 7 +- .../apache/ignite/metastorage/common/Entry.java} | 33 +- .../org/apache/ignite/metastorage/common/Key.java | 80 +++++ .../ignite/metastorage/common/Operation.java | 84 +++++ .../common/OperationTimeoutException.java} | 37 ++- .../ignite/metastorage/common/Operations.java | 64 ++++ .../ignite/metastorage/common/WatchEvent.java} | 45 +-- .../ignite/metastorage/common/WatchListener.java} | 31 +- .../ignite/metastorage/common}/package-info.java | 4 +- modules/network/pom.xml | 12 - .../ITScaleCubeNetworkClusterMessagingTest.java | 107 ++++++- .../ignite/network/scalecube/TestMessage.java | 16 +- .../scalecube/TestMessageMapperProvider.java | 54 ++++ .../scalecube/TestNetworkHandlersProvider.java | 4 +- .../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 | 25 +- .../ignite/network/NetworkClusterContext.java | 57 ++++ .../ignite/network/NetworkClusterFactory.java | 56 +--- .../network/NetworkConfigurationException.java} | 17 +- ...rkMessageHandler.java => NetworkException.java} | 22 +- .../org/apache/ignite/network/NetworkMember.java | 3 +- .../org/apache/ignite/network/NetworkMessage.java | 59 ---- .../ignite/network/NetworkMessageHandler.java | 6 +- .../ignite/network/internal/MessageReader.java} | 16 +- .../ignite/network/internal/MessageWriter.java} | 16 +- .../ignite/network/message/AckResponse.java} | 10 +- .../message/DefaultMessageMapperProvider.java | 54 ++++ .../network/message/MessageDeserializer.java} | 24 +- .../network/message/MessageMapperProvider.java} | 23 +- .../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 | 8 +- .../network/scalecube/ScaleCubeMessageReader.java} | 26 +- .../network/scalecube/ScaleCubeMessageWriter.java} | 26 +- .../network/scalecube/ScaleCubeNetworkCluster.java | 37 ++- .../ScaleCubeNetworkClusterFactory.java} | 71 ++-- .../org/apache/ignite/raft/client/Command.java | 4 +- .../java/org/apache/ignite/raft/client/Peer.java | 3 +- .../apache/ignite/raft/client/RaftErrorCode.java | 10 +- .../ignite/raft/client/message/ActionRequest.java | 4 +- .../ignite/raft/client/message/ActionResponse.java | 5 +- .../raft/client/message/AddLearnersRequest.java | 4 +- .../raft/client/message/AddPeersRequest.java | 4 +- .../raft/client/message/ChangePeersResponse.java | 4 +- .../raft/client/message/GetLeaderRequest.java | 5 +- .../raft/client/message/GetLeaderResponse.java | 4 +- .../raft/client/message/GetPeersRequest.java | 5 +- .../raft/client/message/GetPeersResponse.java | 4 +- .../{impl => }/RaftClientMessageFactory.java | 17 +- .../raft/client/message/RaftErrorResponse.java | 4 +- .../raft/client/message/RemoveLearnersRequest.java | 4 +- .../raft/client/message/RemovePeersRequest.java | 4 +- .../raft/client/message/SnapshotRequest.java | 5 +- .../client/message/TransferLeadershipRequest.java | 4 +- .../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 + .../message/impl/RaftClientMessageFactoryImpl.java | 1 + .../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 + .../CommandClosure.java} | 23 +- .../client/service/RaftGroupCommandListener.java | 4 +- .../client/service/impl/RaftGroupServiceImpl.java | 149 ++++----- .../raft/client/service/RaftGroupServiceTest.java | 26 +- modules/{raft-client => raft}/pom.xml | 21 +- .../ignite/raft/server/CounterCommandListener.java | 53 +++ .../ignite/raft/server/GetValueCommand.java} | 10 +- .../raft/server/ITRaftCounterServerTest.java | 186 +++++++++++ .../raft/server/IncrementAndGetCommand.java} | 26 +- .../org/apache/ignite/raft/server/RaftServer.java | 56 ++++ .../ignite/raft/server/impl/RaftServerImpl.java | 264 +++++++++++++++ .../java/org/apache/ignite/rest/RestModule.java | 11 +- .../InMemoryConfigurationStorage.java} | 51 +-- .../configuration/RestConfigurationSchema.java | 2 +- .../rest/presentation/json/JsonConverter.java | 9 +- .../rest/presentation/json/JsonConverterTest.java | 7 + .../json/TestConfigurationStorage.java | 14 +- modules/runner/README.md | 166 ++++++++++ .../java/org/apache/ignite/app/IgniteRunner.java | 5 +- .../ignite/configuration/ConfigurationModule.java | 41 ++- .../extended/LocalConfigurationSchema.java | 3 +- .../ignite/internal/table/KVBinaryViewImpl.java | 6 +- .../apache/ignite/internal/table/KVViewImpl.java | 6 +- .../ignite/internal/table/RecordViewImpl.java | 6 +- .../apache/ignite/internal/table/TableImpl.java | 6 +- parent/pom.xml | 7 - pom.xml | 27 ++ 152 files changed, 4218 insertions(+), 1167 deletions(-) create mode 100644 assembly/NOTICE create mode 100644 assembly/README create mode 100644 assembly/assembly.xml create mode 100644 modules/cli-common/README.md create mode 100644 modules/cli/README.md rename modules/configuration-annotation-processor/src/test/java/org/apache/ignite/configuration/{sample/storage => }/ConfigurationChangerTest.java (87%) create mode 100644 modules/configuration-annotation-processor/src/test/java/org/apache/ignite/configuration/notifications/ConfigurationListenerTest.java copy modules/configuration-annotation-processor/src/test/java/org/apache/ignite/configuration/{sample => }/storage/TestConfigurationStorage.java (80%) delete mode 100644 modules/configuration/src/main/java/org/apache/ignite/configuration/PropertyListener.java copy modules/{raft-client/src/main/java/org/apache/ignite/raft/client/message/impl/GetPeersRequestImpl.java => configuration/src/main/java/org/apache/ignite/configuration/internal/notifications/ConfigurationNotificationEventImpl.java} (51%) create mode 100644 modules/configuration/src/main/java/org/apache/ignite/configuration/internal/util/ConfigurationNotificationsUtil.java copy modules/{schema/src/main/java/org/apache/ignite/internal/util/Factory.java => configuration/src/main/java/org/apache/ignite/configuration/notifications/ConfigurationListener.java} (61%) copy modules/{table/src/main/java/org/apache/ignite/internal/schema/marshaller/RecordSerializer.java => configuration/src/main/java/org/apache/ignite/configuration/notifications/ConfigurationNamedListListener.java} (52%) copy modules/{table/src/main/java/org/apache/ignite/internal/schema/marshaller/KVSerializer.java => configuration/src/main/java/org/apache/ignite/configuration/notifications/ConfigurationNotificationEvent.java} (53%) create mode 100644 modules/core/src/main/java/org/apache/ignite/lang/IgniteInternalCheckedException.java create mode 100644 modules/core/src/main/java/org/apache/ignite/lang/IgniteInternalException.java delete mode 100644 modules/core/src/main/java/org/apache/ignite/lang/IgniteRuntimeException.java copy modules/{cli-common => metastorage-client}/pom.xml (87%) create mode 100644 modules/metastorage-client/src/main/java/org/apache/ignite/metastorage/client/MetaStorageService.java copy modules/{api/src/main/java/org/apache/ignite/table/mapper/KeyMapper.java => metastorage-client/src/main/java/org/apache/ignite/metastorage/client/package-info.java} (88%) copy modules/{cli-common => metastorage-common}/pom.xml (80%) copy modules/{schema/src/main/java/org/apache/ignite/internal/schema/marshaller/SerializationException.java => metastorage-common/src/main/java/org/apache/ignite/metastorage/common/CompactedException.java} (52%) create mode 100644 modules/metastorage-common/src/main/java/org/apache/ignite/metastorage/common/Condition.java copy modules/{table/src/main/java/org/apache/ignite/binary/BinaryObjects.java => metastorage-common/src/main/java/org/apache/ignite/metastorage/common/Conditions.java} (54%) copy modules/{api/src/main/java/org/apache/ignite/table/mapper/KeyMapper.java => metastorage-common/src/main/java/org/apache/ignite/metastorage/common/Cursor.java} (77%) copy modules/{table/src/main/java/org/apache/ignite/internal/schema/marshaller/KVSerializer.java => metastorage-common/src/main/java/org/apache/ignite/metastorage/common/Entry.java} (55%) create mode 100644 modules/metastorage-common/src/main/java/org/apache/ignite/metastorage/common/Key.java create mode 100644 modules/metastorage-common/src/main/java/org/apache/ignite/metastorage/common/Operation.java copy modules/{schema/src/main/java/org/apache/ignite/internal/schema/marshaller/SerializationException.java => metastorage-common/src/main/java/org/apache/ignite/metastorage/common/OperationTimeoutException.java} (53%) create mode 100644 modules/metastorage-common/src/main/java/org/apache/ignite/metastorage/common/Operations.java copy modules/{schema/src/main/java/org/apache/ignite/internal/util/Pair.java => metastorage-common/src/main/java/org/apache/ignite/metastorage/common/WatchEvent.java} (54%) copy modules/{table/src/main/java/org/apache/ignite/internal/schema/marshaller/RecordSerializer.java => metastorage-common/src/main/java/org/apache/ignite/metastorage/common/WatchListener.java} (55%) copy modules/{cli/src/main/java/org/apache/ignite/cli/builtins/init => metastorage-common/src/main/java/org/apache/ignite/metastorage/common}/package-info.java (86%) 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%) create mode 100644 modules/network/src/main/java/org/apache/ignite/network/message/DefaultMessageMapperProvider.java copy modules/{api/src/main/java/org/apache/ignite/schema/builder/SchemaObjectBuilder.java => network/src/main/java/org/apache/ignite/network/message/MessageDeserializer.java} (65%) copy modules/{api/src/main/java/org/apache/ignite/schema/builder/SchemaObjectBuilder.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%) rename modules/raft-client/src/main/java/org/apache/ignite/raft/client/message/{impl => }/RaftClientMessageFactory.java (70%) copy modules/raft-client/src/main/java/org/apache/ignite/raft/client/{ElectionPriority.java => service/CommandClosure.java} (65%) copy modules/{raft-client => raft}/pom.xml (78%) create mode 100644 modules/raft/src/integrationTest/java/org/apache/ignite/raft/server/CounterCommandListener.java copy modules/{raft-client/src/main/java/org/apache/ignite/raft/client/WriteCommand.java => raft/src/integrationTest/java/org/apache/ignite/raft/server/GetValueCommand.java} (84%) create mode 100644 modules/raft/src/integrationTest/java/org/apache/ignite/raft/server/ITRaftCounterServerTest.java copy modules/{raft-client/src/main/java/org/apache/ignite/raft/client/WriteCommand.java => raft/src/integrationTest/java/org/apache/ignite/raft/server/IncrementAndGetCommand.java} (65%) create mode 100644 modules/raft/src/main/java/org/apache/ignite/raft/server/RaftServer.java create mode 100644 modules/raft/src/main/java/org/apache/ignite/raft/server/impl/RaftServerImpl.java rename modules/{configuration-annotation-processor/src/test/java/org/apache/ignite/configuration/sample/storage/TestConfigurationStorage.java => rest/src/main/java/org/apache/ignite/rest/configuration/InMemoryConfigurationStorage.java} (68%) create mode 100644 modules/runner/README.md