This is an automated email from the ASF dual-hosted git repository.
agura pushed a change to branch ignite-14389
in repository https://gitbox.apache.org/repos/asf/ignite-3.git.
discard fd1ae78 IGNITE-14389 Fixed WatchAggregatorTest
discard a858e14 WIP
discard ec45fe0 IGNITE-14389 Implemented cursor for ranges and watches.
discard d15ac8f IGNITE-14389 Added putAll and removeAll. Started cursor
management: ranges and watches (WIP)
discard 1bd716b IGNITE-14389 putAll initial (WIP)
discard 4dfcc43 IGNITE-14389 getAll and tests (WIP)
discard 72859a8 IGNITE-14389 Added get and do smth semantic
discard a1b451d IGNITE-14398: Meta storage: added update counter
discard 71f810f IGNITE-14389 Meta storage: in-memory implementation WIP
add 22c060a IGNITE-14664 Implemented MetaStorageService and corresponding
raft commands. Fixes #116
add 66bb2ef Revert "IGNITE-14664 Implemented MetaStorageService and
corresponding raft commands. Fixes #116"
add ad1fa86 IGNITE-14664 Implemented MetaStorageService and corresponding
raft commands. Fixes #116
add 3279a9a IGNITE-14088 ScaleCube transport API over Netty (#102)
add c231e86 IGNITE-14712 Fix MetaStorageServiceTest (#124)
add d2c38f0 Revert "IGNITE-14088 ScaleCube transport API over Netty
(#102)"
add 33d0385 IGNITE-14666 Added proper listener handling in
DistributedConfigurationStorage and LocalConfigurationStorage. Fixes #114
new 4fbbaa9 IGNITE-14389 Meta storage: in-memory implementation WIP
new ead9ad5 IGNITE-14398: Meta storage: added update counter
new 9cd33ea IGNITE-14389 Added get and do smth semantic
new 02f3371 IGNITE-14389 getAll and tests (WIP)
new 904f266 IGNITE-14389 putAll initial (WIP)
new 36722c6 IGNITE-14389 Added putAll and removeAll. Started cursor
management: ranges and watches (WIP)
new 5fe099d IGNITE-14389 Implemented cursor for ranges and watches.
new 7eebebf WIP
new a831849 IGNITE-14389 Fixed WatchAggregatorTest
This update added new revisions after undoing existing revisions.
That is to say, some revisions that were in the old version of the
branch are not in the new version. This situation occurs
when a user --force pushes a change and generates a repository
containing something like this:
* -- * -- B -- O -- O -- O (fd1ae78)
\
N -- N -- N refs/heads/ignite-14389 (a831849)
You should already have received notification emails for all of the O
revisions, and so the following emails describe only the N revisions
from the common base, B.
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
The 9 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:
.../ignite/internal/affinity/AffinityManager.java | 26 +-
.../storage/TestConfigurationStorage.java | 4 +-
.../ignite/configuration/ConfigurationChanger.java | 6 +-
.../storage/ConfigurationStorage.java | 16 +-
.../apache/ignite/configuration/storage/Data.java | 24 +-
modules/metastorage-client/pom.xml | 29 +
.../metastorage/client/MetaStorageServiceTest.java | 1194 ++++++++++++++++++++
.../internal/metastorage/client/CursorImpl.java | 114 ++
.../metastorage/client/MetaStorageServiceImpl.java | 346 ++++++
.../apache/ignite/metastorage/client/Entry.java | 7 +
.../ignite/metastorage/client/EntryEvent.java | 42 +-
.../org/apache/ignite/metastorage/client/Key.java | 3 +-
.../metastorage/client/MetaStorageService.java | 4 +-
modules/metastorage-common/pom.xml | 5 +
.../internal/metastorage/common/DummyEntry.java | 107 ++
.../metastorage/common/command/GetAllCommand.java | 78 ++
.../common/command/GetAndPutAllCommand.java | 62 +
.../common/command/GetAndPutCommand.java | 57 +
.../common/command/GetAndRemoveAllCommand.java | 53 +
.../common/command/GetAndRemoveCommand.java} | 27 +-
.../metastorage/common/command/GetCommand.java | 67 ++
.../metastorage/common/command/PutAllCommand.java | 53 +
.../metastorage/common/command/PutCommand.java | 57 +
.../metastorage/common/command/RangeCommand.java | 82 ++
.../common/command/RemoveAllCommand.java} | 43 +-
.../metastorage/common/command/RemoveCommand.java} | 26 +-
.../common/command/WatchExactKeysCommand.java | 63 ++
.../common/command/WatchRangeKeysCommand.java | 81 ++
.../common/command/cursor/CursorCloseCommand.java} | 25 +-
.../command/cursor/CursorHasNextCommand.java} | 25 +-
.../common/command/cursor/CursorNextCommand.java} | 25 +-
.../server/raft/MetaStorageCommandListener.java | 295 +++++
.../internal/metastorage/MetaStorageManager.java | 240 +++-
.../internal/metastorage/WatchAggregatorTest.java | 30 +-
.../network/TestMessageSerializationFactory.java | 2 +-
.../scalecube/ITScaleCubeNetworkMessagingTest.java | 4 +-
.../scalecube/DelegatingTransportFactory.java | 2 +-
.../scalecube/ScaleCubeClusterServiceFactory.java | 4 +-
.../java/org/apache/ignite/internal/raft/Loza.java | 12 +
.../json/TestConfigurationStorage.java | 4 +-
.../ignite/internal/runner/app/IgnitionTest.java | 11 +-
.../apache/ignite/internal/app/IgnitionImpl.java | 117 +-
.../storage/DistributedConfigurationStorage.java | 207 +++-
.../storage/LocalConfigurationStorage.java | 79 +-
.../internal/table/distributed/TableManager.java | 24 +-
.../distributed/storage/InternalTableImpl.java | 14 +-
.../apache/ignite/internal/vault/VaultManager.java | 34 +-
.../internal/vault/impl/VaultServiceImpl.java | 16 +-
.../internal/vault/service/VaultService.java | 21 +-
49 files changed, 3448 insertions(+), 419 deletions(-)
create mode 100644
modules/metastorage-client/src/integrationTest/java/org/apache/ignite/internal/metastorage/client/MetaStorageServiceTest.java
create mode 100644
modules/metastorage-client/src/main/java/org/apache/ignite/internal/metastorage/client/CursorImpl.java
create mode 100644
modules/metastorage-client/src/main/java/org/apache/ignite/internal/metastorage/client/MetaStorageServiceImpl.java
create mode 100644
modules/metastorage-common/src/main/java/org/apache/ignite/internal/metastorage/common/DummyEntry.java
create mode 100644
modules/metastorage-common/src/main/java/org/apache/ignite/internal/metastorage/common/command/GetAllCommand.java
create mode 100644
modules/metastorage-common/src/main/java/org/apache/ignite/internal/metastorage/common/command/GetAndPutAllCommand.java
create mode 100644
modules/metastorage-common/src/main/java/org/apache/ignite/internal/metastorage/common/command/GetAndPutCommand.java
create mode 100644
modules/metastorage-common/src/main/java/org/apache/ignite/internal/metastorage/common/command/GetAndRemoveAllCommand.java
copy
modules/{metastorage-server/src/main/java/org/apache/ignite/internal/metastorage/server/AbstractCondition.java
=>
metastorage-common/src/main/java/org/apache/ignite/internal/metastorage/common/command/GetAndRemoveCommand.java}
(58%)
create mode 100644
modules/metastorage-common/src/main/java/org/apache/ignite/internal/metastorage/common/command/GetCommand.java
create mode 100644
modules/metastorage-common/src/main/java/org/apache/ignite/internal/metastorage/common/command/PutAllCommand.java
create mode 100644
modules/metastorage-common/src/main/java/org/apache/ignite/internal/metastorage/common/command/PutCommand.java
create mode 100644
modules/metastorage-common/src/main/java/org/apache/ignite/internal/metastorage/common/command/RangeCommand.java
copy
modules/{metastorage-client/src/main/java/org/apache/ignite/metastorage/client/Entry.java
=>
metastorage-common/src/main/java/org/apache/ignite/internal/metastorage/common/command/RemoveAllCommand.java}
(51%)
copy
modules/{metastorage-server/src/main/java/org/apache/ignite/internal/metastorage/server/AbstractCondition.java
=>
metastorage-common/src/main/java/org/apache/ignite/internal/metastorage/common/command/RemoveCommand.java}
(60%)
create mode 100644
modules/metastorage-common/src/main/java/org/apache/ignite/internal/metastorage/common/command/WatchExactKeysCommand.java
create mode 100644
modules/metastorage-common/src/main/java/org/apache/ignite/internal/metastorage/common/command/WatchRangeKeysCommand.java
copy
modules/{raft-client/src/main/java/org/apache/ignite/raft/client/service/RaftGroupCommandListener.java
=>
metastorage-common/src/main/java/org/apache/ignite/internal/metastorage/common/command/cursor/CursorCloseCommand.java}
(59%)
copy
modules/{raft-client/src/main/java/org/apache/ignite/raft/client/service/RaftGroupCommandListener.java
=>
metastorage-common/src/main/java/org/apache/ignite/internal/metastorage/common/command/cursor/CursorHasNextCommand.java}
(58%)
copy
modules/{raft-client/src/main/java/org/apache/ignite/raft/client/service/RaftGroupCommandListener.java
=>
metastorage-common/src/main/java/org/apache/ignite/internal/metastorage/common/command/cursor/CursorNextCommand.java}
(59%)
create mode 100644
modules/metastorage-server/src/main/java/org/apache/ignite/internal/metastorage/server/raft/MetaStorageCommandListener.java
