Uses of Interface
com.loomcache.server.consensus.RaftGroupManagerApi
Packages that use RaftGroupManagerApi
Package
Description
Multi-Raft sharding infrastructure for LoomCache.
-
Uses of RaftGroupManagerApi in com.loomcache.server.consensus
Classes in com.loomcache.server.consensus that implement RaftGroupManagerApiModifier and TypeClassDescriptionclassManages multiple independent Raft groups for horizontal scalability. -
Uses of RaftGroupManagerApi in com.loomcache.server.cp
Constructors in com.loomcache.server.cp with parameters of type RaftGroupManagerApiModifierConstructorDescriptionConsistencySubsystem(RaftGroupManagerApi raftGroupManager) Creates a new ConsistencySubsystem with the given Raft group manager using the Hazelcast-compatible default five-minute CP session timeout.ConsistencySubsystem(RaftGroupManagerApi raftGroupManager, long sessionTimeoutMs) Creates a new ConsistencySubsystem with the given Raft group manager and session timeout. -
Uses of RaftGroupManagerApi in com.loomcache.server.sharding
Constructors in com.loomcache.server.sharding with parameters of type RaftGroupManagerApiModifierConstructorDescriptionPartitionRouter(int numPartitions, RaftGroupManagerApi raftGroupManager) Creates a router with the specified partition count and a single Raft group.PartitionRouter(int numPartitions, RaftGroupManagerApi raftGroupManager, PartitioningStrategy<Object> partitioningStrategy) Creates a router with the specified partition count, Raft manager, and partitioning strategy.PartitionRouter(RaftGroupManagerApi raftGroupManager) Creates a router with the default partition count (271) and a single Raft group. -
Uses of RaftGroupManagerApi in com.loomcache.server.transaction.twopc
Constructors in com.loomcache.server.transaction.twopc with parameters of type RaftGroupManagerApiModifierConstructorDescriptionTwoPhaseCoordinator(@NonNull String nodeId, @NonNull RaftGroupManagerApi raftGroupManager, @NonNull PartitionRouter partitionRouter, @NonNull PeerMessageDispatch dispatch, @NonNull ScheduledExecutorService scheduler) TwoPhaseCoordinator(@NonNull String nodeId, @NonNull RaftGroupManagerApi raftGroupManager, @NonNull PartitionRouter partitionRouter, @NonNull PeerMessageDispatch dispatch, @NonNull ScheduledExecutorService scheduler, @NonNull Duration prepareTimeout, @NonNull Duration decideTimeout, @NonNull Duration decidedRetention) TwoPhaseCoordinator(@NonNull String nodeId, @NonNull RaftGroupManagerApi raftGroupManager, @NonNull PartitionRouter partitionRouter, @NonNull PeerMessageDispatch dispatch, @NonNull ScheduledExecutorService scheduler, @NonNull Duration prepareTimeout, @NonNull Duration decideTimeout, @NonNull Duration decidedRetention, @NonNull Duration dispatchRetryDelay, int dispatchMaxAttempts) TwoPhaseParticipant(@NonNull String nodeId, @NonNull RaftGroupManagerApi raftGroupManager, @NonNull PeerMessageDispatch dispatch, @NonNull CrossGroupTransactionExecutor applyExecutor, @NonNull Function<Integer, @Nullable DataStructureRegistry> registryResolver, @NonNull ScheduledExecutorService scheduler) TwoPhaseParticipant(@NonNull String nodeId, @NonNull RaftGroupManagerApi raftGroupManager, @NonNull PeerMessageDispatch dispatch, @NonNull CrossGroupTransactionExecutor applyExecutor, @NonNull Function<Integer, @Nullable DataStructureRegistry> registryResolver, @NonNull ScheduledExecutorService scheduler, @NonNull Duration orphanedIntentTimeout, @NonNull Duration unilateralAbortGrace) TwoPhaseParticipant(@NonNull String nodeId, @NonNull RaftGroupManagerApi raftGroupManager, @NonNull PeerMessageDispatch dispatch, @NonNull CrossGroupTransactionExecutor applyExecutor, @NonNull Function<Integer, @Nullable DataStructureRegistry> registryResolver, @NonNull ScheduledExecutorService scheduler, @NonNull Duration orphanedIntentTimeout, @NonNull Duration unilateralAbortGrace, @NonNull Duration completedDecisionRetention)