You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by am...@apache.org on 2021/04/07 12:55:45 UTC
[ignite-3] branch ignite-14330 updated (d6d8c79 -> d6d8ad8)
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