Uses of Class
com.loomcache.server.sharding.PartitionRouter
Packages that use PartitionRouter
Package
Description
Multi-Raft sharding infrastructure for LoomCache.
-
Uses of PartitionRouter in com.loomcache.server.datastructures
Methods in com.loomcache.server.datastructures with parameters of type PartitionRouterModifier and TypeMethodDescriptionvoidDataStructureRegistry.ensurePartitionWriteRedirect(int partitionId, int sourceGroup, PartitionRouter router, Function<Integer, DataStructureRegistry> registryLookup) voidDataStructureRegistry.setPartitionRouter(PartitionRouter partitionRouter) Set the partition router. -
Uses of PartitionRouter in com.loomcache.server.metrics
Methods in com.loomcache.server.metrics with parameters of type PartitionRouterModifier and TypeMethodDescriptionvoidLoomMetrics.registerIndexMetrics(DataStructureRegistry dataStructures, @Nullable PartitionRouter partitionRouter) Register index observability metrics for query planning. -
Uses of PartitionRouter in com.loomcache.server.sharding
Constructors in com.loomcache.server.sharding with parameters of type PartitionRouterModifierConstructorDescriptionCrossGroupQueryExecutor(ShardedDataStructureRegistry shardedRegistry, PartitionRouter router) Creates an executor with the default timeout (10 seconds).CrossGroupQueryExecutor(ShardedDataStructureRegistry shardedRegistry, PartitionRouter router, Duration timeout) Creates an executor with a custom timeout.CrossGroupQueryExecutor(ShardedDataStructureRegistry shardedRegistry, PartitionRouter router, Duration timeout, CrossGroupQueryExecutor.GroupQueryFence groupQueryFence) CrossGroupQueryExecutor(ShardedDataStructureRegistry shardedRegistry, PartitionRouter router, Duration timeout, CrossGroupQueryExecutor.GroupQueryFence groupQueryFence, CrossGroupQueryExecutor.VisibilityBarrier visibilityBarrier) CrossGroupTransactionContext(Transaction transaction, PartitionRouter router) Create a cross-group context by routing all keys through the partition router.CrossGroupTransactionExecutor(PartitionRouter router, GroupLockManager lockManager) Create a cross-group transaction executor (local lock-based fallback).CrossGroupTransactionExecutor(PartitionRouter router, GroupLockManager lockManager, @Nullable CrossGroupTransactionExecutor.RaftTransactionSubmitter raftSubmitter, Duration lockTimeout) Create a cross-group transaction executor with Raft-serialized transactions.PartitionRebalancer(PartitionRouter router, ShardedDataStructureRegistry shardedRegistry) Creates a new rebalancer for the given router and sharded registry.ShardedDataStructureRegistry(PartitionRouter router, int instanceNumber) Creates a new sharded registry backed by the given partition router.ShardedDataStructureRegistry(PartitionRouter router, int instanceNumber, int idGeneratorNodeId) -
Uses of PartitionRouter in com.loomcache.server.transaction
Constructors in com.loomcache.server.transaction with parameters of type PartitionRouterModifierConstructorDescriptionTransactionManager(DataStructureRegistry registry, @Nullable BatchExecutionHandler batchHandler, @Nullable CrossGroupTransactionExecutor crossGroupExecutor, @Nullable PartitionRouter partitionRouter) Creates a new transaction manager with optional Raft-replicated commit. -
Uses of PartitionRouter in com.loomcache.server.transaction.twopc
Constructors in com.loomcache.server.transaction.twopc with parameters of type PartitionRouterModifierConstructorDescriptionTwoPhaseCoordinator(@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)