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
