This is an automated email from the ASF dual-hosted git repository.
tkalkirill pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/ignite-3.git
from e891461401 IGNITE-18131 .NET: LINQ: Improve Distinct support (#1401)
add d1c051f909 IGNITE-18265 Update Raft packages structure (#1383)
No new revisions were added by this update.
Summary of changes:
check-rules/checkstyle-disabled-modules.xml | 1 -
modules/affinity/build.gradle | 8 -
modules/affinity/pom.xml | 30 +-
modules/client/build.gradle | 2 +-
.../ignite/client/fakes/FakeInternalTable.java | 2 +-
modules/cluster-management/build.gradle | 4 +-
.../management/raft/ItCmgRaftServiceTest.java | 9 +-
.../management/ClusterManagementGroupManager.java | 20 +-
.../management/raft/CmgRaftGroupListener.java | 8 +-
.../cluster/management/raft/CmgRaftService.java | 4 +-
.../raft/commands/InitCmgStateCommand.java | 2 +-
.../management/raft/commands/JoinReadyCommand.java | 2 +-
.../raft/commands/JoinRequestCommand.java | 2 +-
.../raft/commands/NodesLeaveCommand.java | 2 +-
.../raft/commands/ReadLogicalTopologyCommand.java | 2 +-
.../management/raft/commands/ReadStateCommand.java | 2 +-
.../management/raft/CmgRaftGroupListenerTest.java | 4 +-
.../ErrorPolymorphic5ConfigurationSchema.java | 1 -
modules/jacoco-report/build.gradle | 2 +-
modules/jacoco-report/pom.xml | 2 +-
.../apache/ignite/internal/util/ObjectFactory.java | 1 -
modules/metastorage-client/build.gradle | 4 +-
modules/metastorage-client/pom.xml | 20 +-
.../client/ItMetaStorageRaftGroupTest.java | 24 +-
.../ItMetaStorageServicePersistenceTest.java | 6 +-
.../client/ItMetaStorageServiceTest.java | 128 ++++----
.../internal/metastorage/client/CursorImpl.java | 2 +-
.../metastorage/client/MetaStorageServiceImpl.java | 2 +-
modules/metastorage-common/build.gradle | 2 +-
modules/metastorage-common/pom.xml | 2 +-
.../metastorage/common/command/GetAllCommand.java | 2 +-
.../common/command/GetAndPutAllCommand.java | 2 +-
.../common/command/GetAndPutCommand.java | 2 +-
.../common/command/GetAndRemoveAllCommand.java | 2 +-
.../common/command/GetAndRemoveCommand.java | 2 +-
.../metastorage/common/command/GetCommand.java | 2 +-
.../metastorage/common/command/InvokeCommand.java | 2 +-
.../common/command/MultiInvokeCommand.java | 2 +-
.../metastorage/common/command/PutAllCommand.java | 2 +-
.../metastorage/common/command/PutCommand.java | 2 +-
.../metastorage/common/command/RangeCommand.java | 2 +-
.../common/command/RemoveAllCommand.java | 2 +-
.../metastorage/common/command/RemoveCommand.java | 2 +-
.../common/command/WatchExactKeysCommand.java | 2 +-
.../common/command/WatchRangeKeysCommand.java | 2 +-
.../common/command/cursor/CursorCloseCommand.java | 2 +-
.../command/cursor/CursorHasNextCommand.java | 2 +-
.../common/command/cursor/CursorNextCommand.java | 2 +-
.../common/command/cursor/CursorsCloseCommand.java | 2 +-
modules/metastorage-server/build.gradle | 2 +-
.../server/raft/MetaStorageListener.java | 8 +-
modules/metastorage/build.gradle | 9 +-
modules/metastorage/pom.xml | 2 +-
.../internal/metastorage/MetaStorageManager.java | 12 +-
.../metastorage/MetaStorageRangeCursorTest.java | 10 +-
.../messages/SerializationOrderMessage.java | 1 +
.../ignite/utils/ClusterServiceTestUtils.java | 13 +
modules/{raft-client => raft-api}/README.md | 0
modules/{raft-client => raft-api}/build.gradle | 6 +-
modules/{raft-client => raft-api}/pom.xml | 17 +-
.../org/apache/ignite/internal/raft}/Command.java | 2 +-
.../ignite/internal/raft}/ElectionPriority.java | 2 +-
.../org/apache/ignite/internal/raft}/Peer.java | 3 +-
.../apache/ignite/internal/raft/RaftError.java} | 21 +-
.../internal/raft}/RaftGroupEventsListener.java | 13 +-
.../apache/ignite/internal/raft/RaftManager.java | 91 ++++++
.../apache/ignite/internal/raft}/ReadCommand.java | 2 +-
.../internal/raft}/ReplicationGroupOptions.java | 2 +-
.../org/apache/ignite/internal/raft/Status.java} | 54 ++--
.../apache/ignite/internal/raft}/WriteCommand.java | 2 +-
.../EntryCountBudgetConfigurationSchema.java | 0
.../LogStorageBudgetConfigurationSchema.java | 0
.../configuration/RaftConfigurationModule.java | 0
.../configuration/RaftConfigurationSchema.java | 0
.../UnlimitedBudgetConfigurationSchema.java | 0
.../VolatileRaftConfigurationSchema.java | 0
.../internal/raft}/service/CommandClosure.java | 4 +-
.../raft}/service/CommittedConfiguration.java | 2 +-
.../internal/raft}/service/LeaderWithTerm.java | 4 +-
.../internal/raft}/service/RaftGroupListener.java | 6 +-
.../internal/raft}/service/RaftGroupService.java | 6 +-
modules/raft/build.gradle | 7 +-
modules/raft/pom.xml | 19 +-
.../ignite/internal/raft/ItLearnersTest.java | 11 +-
.../apache/ignite/internal/raft/ItLozaTest.java | 4 +-
.../internal/raft/ItRaftGroupServiceTest.java | 6 +-
.../apache/ignite/raft/jraft/core/ItNodeTest.java | 10 +-
.../raft/server/ItJraftCounterServerTest.java | 10 +-
.../ignite/raft/server/ItJraftHlcServerTest.java | 2 +-
.../apache/ignite/raft/server/ItSafeTimeTest.java | 6 +-
.../raft/server/ItSimpleCounterServerTest.java | 4 +-
.../ignite/raft/server/JraftAbstractTest.java | 4 +-
.../raft/server/counter/CounterListener.java | 8 +-
.../raft/server/counter/GetValueCommand.java | 2 +-
.../server/counter/IncrementAndGetCommand.java | 2 +-
.../raft/server/snasphot/TestWriteCommand.java | 2 +-
.../server/snasphot/UpdateCountRaftListener.java | 8 +-
...Listener.java => JraftGroupEventsListener.java} | 24 +-
.../java/org/apache/ignite/internal/raft/Loza.java | 37 ++-
.../ignite/internal/raft/RaftGroupServiceImpl.java | 7 +-
.../internal/raft/server/RaftGroupOptions.java | 1 +
.../ignite/internal/raft/server/RaftServer.java | 5 +-
.../internal/raft/server/impl/JraftServerImpl.java | 16 +-
.../impl/RaftGroupEventsListenerAdapter.java | 68 +++++
.../apache/ignite/raft/jraft/core/NodeImpl.java | 24 +-
.../apache/ignite/raft/jraft/entity/PeerId.java | 2 +-
.../ignite/raft/jraft/option/NodeOptions.java | 8 +-
.../ignite/raft/jraft/rpc/ActionRequest.java | 2 +-
.../jraft/rpc/impl/ActionRequestProcessor.java | 8 +-
.../raft/JraftGroupEventsListenerTest.java} | 9 +-
.../org/apache/ignite/internal/raft/LozaTest.java | 2 +-
.../ignite/internal/raft/RaftGroupServiceTest.java | 4 +-
.../apache/ignite/raft/jraft/core/TestCluster.java | 8 +-
.../internal/raft/server/impl/RaftServerImpl.java | 326 ---------------------
.../service/ItAbstractListenerSnapshotTest.java | 4 +-
.../org/apache/ignite/raft/TestWriteCommand.java | 2 +-
.../apache/ignite/raft/jraft/test/TestUtils.java | 2 +-
modules/replicator/build.gradle | 3 +-
modules/replicator/pom.xml | 2 +-
.../replicator/command/SafeTimeSyncCommand.java | 2 +-
modules/runner/build.gradle | 3 +-
.../storage/ItRebalanceDistributedTest.java | 3 +-
.../app/ItIgniteInMemoryNodeRestartTest.java | 4 +-
.../runner/app/ItIgniteNodeRestartTest.java | 1 +
.../org/apache/ignite/internal/app/IgniteImpl.java | 1 +
modules/sql-engine/build.gradle | 2 +-
.../sql/engine/exec/MockedStructuresTest.java | 17 +-
.../exec/rel/TableScanNodeExecutionTest.java | 2 +-
modules/table/build.gradle | 3 +-
.../ignite/distributed/ItTablePersistenceTest.java | 6 +-
.../distributed/ItTxDistributedTestSingleNode.java | 19 +-
...butedTestThreeNodesThreeReplicasCollocated.java | 6 +-
.../ignite/internal/table/ItColocationTest.java | 8 +-
.../ignite/internal/table/InternalTable.java | 2 +-
.../internal/table/distributed/PartitionMover.java | 4 +-
.../internal/table/distributed/TableManager.java | 59 ++--
.../distributed/command/PartitionCommand.java | 2 +-
.../table/distributed/raft/PartitionListener.java | 12 +-
.../raft/RebalanceRaftGroupEventsListener.java | 46 +--
.../replicator/PartitionReplicaListener.java | 6 +-
.../distributed/storage/InternalTableImpl.java | 4 +-
.../table/distributed/PartitionMoverTest.java | 4 +-
.../table/distributed/TableManagerTest.java | 20 +-
.../raft/PartitionCommandListenerTest.java | 8 +-
.../PartitionReplicaListenerIndexLockingTest.java | 4 +-
.../replication/PartitionReplicaListenerTest.java | 6 +-
.../table/impl/DummyInternalTableImpl.java | 12 +-
modules/transactions/build.gradle | 2 +-
modules/transactions/pom.xml | 2 +-
parent/pom.xml | 2 +-
pom.xml | 2 +-
settings.gradle | 4 +-
152 files changed, 685 insertions(+), 894 deletions(-)
rename modules/{raft-client => raft-api}/README.md (100%)
rename modules/{raft-client => raft-api}/build.gradle (88%)
rename modules/{raft-client => raft-api}/pom.xml (82%)
rename modules/{raft-client/src/main/java/org/apache/ignite/raft/client =>
raft-api/src/main/java/org/apache/ignite/internal/raft}/Command.java (95%)
rename modules/{raft-client/src/main/java/org/apache/ignite/raft/client =>
raft-api/src/main/java/org/apache/ignite/internal/raft}/ElectionPriority.java
(96%)
rename modules/{raft-client/src/main/java/org/apache/ignite/raft/client =>
raft-api/src/main/java/org/apache/ignite/internal/raft}/Peer.java (96%)
copy
modules/{network/src/test/java/org/apache/ignite/internal/network/messages/NetworkMessage1.java
=> raft-api/src/main/java/org/apache/ignite/internal/raft/RaftError.java} (76%)
copy modules/{raft/src/main/java/org/apache/ignite/internal/raft/server =>
raft-api/src/main/java/org/apache/ignite/internal/raft}/RaftGroupEventsListener.java
(83%)
create mode 100644
modules/raft-api/src/main/java/org/apache/ignite/internal/raft/RaftManager.java
rename modules/{raft-client/src/main/java/org/apache/ignite/raft/client =>
raft-api/src/main/java/org/apache/ignite/internal/raft}/ReadCommand.java (95%)
rename modules/{raft/src/main/java/org/apache/ignite/internal/raft/server =>
raft-api/src/main/java/org/apache/ignite/internal/raft}/ReplicationGroupOptions.java
(97%)
copy
modules/{sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/session/SessionId.java
=> raft-api/src/main/java/org/apache/ignite/internal/raft/Status.java} (56%)
rename modules/{raft-client/src/main/java/org/apache/ignite/raft/client =>
raft-api/src/main/java/org/apache/ignite/internal/raft}/WriteCommand.java (95%)
rename modules/{raft =>
raft-api}/src/main/java/org/apache/ignite/internal/raft/configuration/EntryCountBudgetConfigurationSchema.java
(100%)
rename modules/{raft =>
raft-api}/src/main/java/org/apache/ignite/internal/raft/configuration/LogStorageBudgetConfigurationSchema.java
(100%)
rename modules/{raft =>
raft-api}/src/main/java/org/apache/ignite/internal/raft/configuration/RaftConfigurationModule.java
(100%)
rename modules/{raft =>
raft-api}/src/main/java/org/apache/ignite/internal/raft/configuration/RaftConfigurationSchema.java
(100%)
rename modules/{raft =>
raft-api}/src/main/java/org/apache/ignite/internal/raft/configuration/UnlimitedBudgetConfigurationSchema.java
(100%)
rename modules/{raft =>
raft-api}/src/main/java/org/apache/ignite/internal/raft/configuration/VolatileRaftConfigurationSchema.java
(100%)
rename modules/{raft-client/src/main/java/org/apache/ignite/raft/client =>
raft-api/src/main/java/org/apache/ignite/internal/raft}/service/CommandClosure.java
(94%)
rename modules/{raft-client/src/main/java/org/apache/ignite/raft/client =>
raft-api/src/main/java/org/apache/ignite/internal/raft}/service/CommittedConfiguration.java
(98%)
rename modules/{raft-client/src/main/java/org/apache/ignite/raft/client =>
raft-api/src/main/java/org/apache/ignite/internal/raft}/service/LeaderWithTerm.java
(93%)
rename modules/{raft-client/src/main/java/org/apache/ignite/raft/client =>
raft-api/src/main/java/org/apache/ignite/internal/raft}/service/RaftGroupListener.java
(95%)
rename modules/{raft-client/src/main/java/org/apache/ignite/raft/client =>
raft-api/src/main/java/org/apache/ignite/internal/raft}/service/RaftGroupService.java
(98%)
rename
modules/raft/src/main/java/org/apache/ignite/internal/raft/{server/RaftGroupEventsListener.java
=> JraftGroupEventsListener.java} (71%)
create mode 100644
modules/raft/src/main/java/org/apache/ignite/internal/raft/server/impl/RaftGroupEventsListenerAdapter.java
rename
modules/{table/src/test/java/org/apache/ignite/internal/table/distributed/raft/RebalanceRaftGroupEventsListenerTest.java
=>
raft/src/test/java/org/apache/ignite/internal/raft/JraftGroupEventsListenerTest.java}
(90%)
delete mode 100644
modules/raft/src/testFixtures/java/org/apache/ignite/internal/raft/server/impl/RaftServerImpl.java
rename modules/raft/src/testFixtures/java/org/apache/ignite/{raft/client =>
internal/raft}/service/ItAbstractListenerSnapshotTest.java (99%)
