IGNITE-14269 Added multi-invoke feature for meta storage. Fixes #619
authorKirill Gusakov <kgusakov@gmail.com>
Thu, 17 Feb 2022 14:51:24 +0000 (17:51 +0300)
committerSlava Koptilin <slava.koptilin@gmail.com>
Thu, 17 Feb 2022 14:51:24 +0000 (17:51 +0300)
commitfc01ecc158971b673790ed9ea81abee94d5da5ac
tree552f260918d72d251dafbd9a60ec9e9986885e5d
parent66108f5e594cfb82f2157a460f55207740d43b20
IGNITE-14269 Added multi-invoke feature for meta storage. Fixes #619

Signed-off-by: Slava Koptilin <slava.koptilin@gmail.com>
47 files changed:
modules/metastorage-client/pom.xml
modules/metastorage-client/src/integrationTest/java/org/apache/ignite/internal/metastorage/client/ItMetaStorageServiceTest.java
modules/metastorage-client/src/main/java/org/apache/ignite/internal/metastorage/client/CompoundCondition.java [new file with mode: 0644]
modules/metastorage-client/src/main/java/org/apache/ignite/internal/metastorage/client/Condition.java
modules/metastorage-client/src/main/java/org/apache/ignite/internal/metastorage/client/Conditions.java
modules/metastorage-client/src/main/java/org/apache/ignite/internal/metastorage/client/If.java [new file with mode: 0644]
modules/metastorage-client/src/main/java/org/apache/ignite/internal/metastorage/client/MetaStorageService.java
modules/metastorage-client/src/main/java/org/apache/ignite/internal/metastorage/client/MetaStorageServiceImpl.java
modules/metastorage-client/src/main/java/org/apache/ignite/internal/metastorage/client/Operations.java
modules/metastorage-client/src/main/java/org/apache/ignite/internal/metastorage/client/SimpleCondition.java [new file with mode: 0644]
modules/metastorage-client/src/main/java/org/apache/ignite/internal/metastorage/client/Statement.java [new file with mode: 0644]
modules/metastorage-client/src/main/java/org/apache/ignite/internal/metastorage/client/StatementResult.java [new file with mode: 0644]
modules/metastorage-client/src/main/java/org/apache/ignite/internal/metastorage/client/Update.java [new file with mode: 0644]
modules/metastorage-common/src/main/java/org/apache/ignite/internal/metastorage/common/StatementInfo.java [new file with mode: 0644]
modules/metastorage-common/src/main/java/org/apache/ignite/internal/metastorage/common/StatementResultInfo.java [new file with mode: 0644]
modules/metastorage-common/src/main/java/org/apache/ignite/internal/metastorage/common/UpdateInfo.java [new file with mode: 0644]
modules/metastorage-common/src/main/java/org/apache/ignite/internal/metastorage/common/command/CompoundConditionInfo.java [new file with mode: 0644]
modules/metastorage-common/src/main/java/org/apache/ignite/internal/metastorage/common/command/CompoundConditionType.java [new file with mode: 0644]
modules/metastorage-common/src/main/java/org/apache/ignite/internal/metastorage/common/command/ConditionInfo.java
modules/metastorage-common/src/main/java/org/apache/ignite/internal/metastorage/common/command/IfInfo.java [new file with mode: 0644]
modules/metastorage-common/src/main/java/org/apache/ignite/internal/metastorage/common/command/MultiInvokeCommand.java [new file with mode: 0644]
modules/metastorage-common/src/main/java/org/apache/ignite/internal/metastorage/common/command/SimpleConditionInfo.java [new file with mode: 0644]
modules/metastorage-server/pom.xml
modules/metastorage-server/src/main/java/org/apache/ignite/internal/metastorage/server/AbstractCompoundCondition.java [new file with mode: 0644]
modules/metastorage-server/src/main/java/org/apache/ignite/internal/metastorage/server/AbstractSimpleCondition.java [moved from modules/metastorage-server/src/main/java/org/apache/ignite/internal/metastorage/server/AbstractCondition.java with 62% similarity]
modules/metastorage-server/src/main/java/org/apache/ignite/internal/metastorage/server/AndCondition.java [new file with mode: 0644]
modules/metastorage-server/src/main/java/org/apache/ignite/internal/metastorage/server/Condition.java
modules/metastorage-server/src/main/java/org/apache/ignite/internal/metastorage/server/ExistenceCondition.java
modules/metastorage-server/src/main/java/org/apache/ignite/internal/metastorage/server/If.java [new file with mode: 0644]
modules/metastorage-server/src/main/java/org/apache/ignite/internal/metastorage/server/KeyValueStorage.java
modules/metastorage-server/src/main/java/org/apache/ignite/internal/metastorage/server/OrCondition.java [new file with mode: 0644]
modules/metastorage-server/src/main/java/org/apache/ignite/internal/metastorage/server/RevisionCondition.java
modules/metastorage-server/src/main/java/org/apache/ignite/internal/metastorage/server/Statement.java [new file with mode: 0644]
modules/metastorage-server/src/main/java/org/apache/ignite/internal/metastorage/server/StatementResult.java [new file with mode: 0644]
modules/metastorage-server/src/main/java/org/apache/ignite/internal/metastorage/server/TombstoneCondition.java
modules/metastorage-server/src/main/java/org/apache/ignite/internal/metastorage/server/Update.java [new file with mode: 0644]
modules/metastorage-server/src/main/java/org/apache/ignite/internal/metastorage/server/Value.java
modules/metastorage-server/src/main/java/org/apache/ignite/internal/metastorage/server/ValueCondition.java
modules/metastorage-server/src/main/java/org/apache/ignite/internal/metastorage/server/persistence/RocksDbKeyValueStorage.java
modules/metastorage-server/src/main/java/org/apache/ignite/internal/metastorage/server/raft/MetaStorageListener.java
modules/metastorage-server/src/test/java/org/apache/ignite/internal/metastorage/server/AbstractKeyValueStorageTest.java
modules/metastorage-server/src/test/java/org/apache/ignite/internal/metastorage/server/AndConditionTest.java [new file with mode: 0644]
modules/metastorage-server/src/test/java/org/apache/ignite/internal/metastorage/server/OrConditionTest.java [new file with mode: 0644]
modules/metastorage-server/src/test/java/org/apache/ignite/internal/metastorage/server/SimpleInMemoryKeyValueStorage.java
modules/metastorage/src/main/java/org/apache/ignite/internal/metastorage/MetaStorageManager.java
modules/runner/src/main/java/org/apache/ignite/internal/configuration/storage/DistributedConfigurationStorage.java
modules/runner/src/test/java/org/apache/ignite/internal/configuration/storage/DistributedConfigurationStorageTest.java