Uses of Class
com.loomcache.server.datastructures.DataStructureRegistry

Packages that use DataStructureRegistry

Package	Description
com.loomcache.server.cache
com.loomcache.server.cluster
com.loomcache.server.datastructures
com.loomcache.server.handler
com.loomcache.server.jcache
com.loomcache.server.management
com.loomcache.server.metrics
com.loomcache.server.rest
com.loomcache.server.sharding	Multi-Raft sharding infrastructure for LoomCache.
com.loomcache.server.transaction
com.loomcache.server.transaction.twopc
com.loomcache.server.wan

Uses of DataStructureRegistry in com.loomcache.server.cache

Constructors in com.loomcache.server.cache with parameters of type DataStructureRegistry

Modifier	Constructor	Description
	CacheWarmer(DataStructureRegistry registry, @Nullable WarmingConfig config, @Nullable WarmingListener listener, @Nullable AccessTracker accessTracker)	Create a CacheWarmer with the given configuration.

Uses of DataStructureRegistry in com.loomcache.server.cluster

Constructors in com.loomcache.server.cluster with parameters of type DataStructureRegistry

Modifier	Constructor	Description
	PartitionMigrationPipeline(int instanceNumber, DataStructureRegistry registry, PartitionTable partitionTable)
	PartitionMigrationPipeline(int instanceNumber, DataStructureRegistry registry, PartitionTable partitionTable, int maxConcurrent, int maxRetries)
	PartitionMigrationPipeline(int instanceNumber, DataStructureRegistry registry, PartitionTable partitionTable, @Nullable PartitionMigrationPipeline.MigrationDataSender dataSender, @Nullable PartitionMigrationPipeline.OwnershipCommitter ownershipCommitter, int maxConcurrent, int maxRetries)
	PartitionMigrationPipeline(int instanceNumber, DataStructureRegistry defaultRegistry, IntFunction<DataStructureRegistry> registryForSlot, PartitionTable partitionTable, @Nullable PartitionMigrationPipeline.MigrationDataSender dataSender, @Nullable PartitionMigrationPipeline.OwnershipCommitter ownershipCommitter, int maxConcurrent, int maxRetries)	Session 10 ESC-12.3: sharded-aware constructor for the historical one-registry-per-slot mode.
	PartitionMigrationPipeline(int instanceNumber, DataStructureRegistry defaultRegistry, IntFunction<DataStructureRegistry> registryForSlot, IntFunction<Collection<DataStructureRegistry>> registriesForSlot, Function<String, DataStructureRegistry> registryForKey, PartitionTable partitionTable, @Nullable PartitionMigrationPipeline.MigrationDataSender dataSender, @Nullable PartitionMigrationPipeline.OwnershipCommitter ownershipCommitter, int maxConcurrent, int maxRetries)

Constructor parameters in com.loomcache.server.cluster with type arguments of type DataStructureRegistry

Modifier	Constructor	Description
	PartitionMigrationPipeline(int instanceNumber, DataStructureRegistry defaultRegistry, IntFunction<DataStructureRegistry> registryForSlot, PartitionTable partitionTable, @Nullable PartitionMigrationPipeline.MigrationDataSender dataSender, @Nullable PartitionMigrationPipeline.OwnershipCommitter ownershipCommitter, int maxConcurrent, int maxRetries)	Session 10 ESC-12.3: sharded-aware constructor for the historical one-registry-per-slot mode.
	PartitionMigrationPipeline(int instanceNumber, DataStructureRegistry defaultRegistry, IntFunction<DataStructureRegistry> registryForSlot, IntFunction<Collection<DataStructureRegistry>> registriesForSlot, Function<String, DataStructureRegistry> registryForKey, PartitionTable partitionTable, @Nullable PartitionMigrationPipeline.MigrationDataSender dataSender, @Nullable PartitionMigrationPipeline.OwnershipCommitter ownershipCommitter, int maxConcurrent, int maxRetries)
	PartitionMigrationPipeline(int instanceNumber, DataStructureRegistry defaultRegistry, IntFunction<DataStructureRegistry> registryForSlot, IntFunction<Collection<DataStructureRegistry>> registriesForSlot, Function<String, DataStructureRegistry> registryForKey, PartitionTable partitionTable, @Nullable PartitionMigrationPipeline.MigrationDataSender dataSender, @Nullable PartitionMigrationPipeline.OwnershipCommitter ownershipCommitter, int maxConcurrent, int maxRetries)

Uses of DataStructureRegistry in com.loomcache.server.datastructures

Method parameters in com.loomcache.server.datastructures with type arguments of type DataStructureRegistry

Modifier and Type	Method	Description
void	DataStructureRegistry.ensurePartitionWriteRedirect(int partitionId, int sourceGroup, PartitionRouter router, Function<Integer, DataStructureRegistry> registryLookup)

Uses of DataStructureRegistry in com.loomcache.server.handler

Constructors in com.loomcache.server.handler with parameters of type DataStructureRegistry

Modifier	Constructor	Description
	BatchExecutionHandler(DataStructureRegistry registry, int instanceNumber, RaftNode raftNode)	Create a batch execution handler for a specific cluster node.
	CqcSubscriptionHandler(DataStructureRegistry registry, TcpServer tcpServer, int instanceNumber)
	DataOperationHandler(DataStructureRegistry registry, int instanceNumber)	Creates a new DataOperationHandler.
	ExecutorServiceHandler(DataStructureRegistry registry, int instanceNumber, KryoSerializer kryoSerializer)	Create an executor service handler.
	ExecutorServiceHandler(DataStructureRegistry registry, int instanceNumber, KryoSerializer kryoSerializer, ExecutorTaskAllowlist taskAllowlist)
	ExecutorServiceHandler(DataStructureRegistry registry, int instanceNumber, KryoSerializer kryoSerializer, ExecutorTaskAllowlist taskAllowlist, BooleanSupplier executionEnabled)
	ExecutorServiceHandler(DataStructureRegistry registry, int instanceNumber, KryoSerializer kryoSerializer, ExecutorTaskAllowlist taskAllowlist, BooleanSupplier executionEnabled, int maxTaskPayloadBytes)
	QueryHandler(DataStructureRegistry dataStructureRegistry, int instanceNumber)	Create a query handler.

Uses of DataStructureRegistry in com.loomcache.server.jcache

Methods in com.loomcache.server.jcache that return DataStructureRegistry

Modifier and Type	Method	Description
@Nullable DataStructureRegistry	LoomJCacheConfig.distributedRegistry()	Registry used to resolve the backing Raft-replicated map when LoomJCacheConfig.distributedEnabled() is true.

Methods in com.loomcache.server.jcache with parameters of type DataStructureRegistry

Modifier and Type	Method	Description
static <K,V> JCacheDistributedMapAdapter<K,V>	JCacheDistributedMapAdapter.create(DataStructureRegistry registry, KryoSerializer serializer, String cacheName, Class<K> keyType, Class<V> valueType)	Convenience factory that looks up (or creates) the underlying DistributedMap via the given registry.
static <K,V> JCacheDistributedMapAdapter<K,V>	JCacheDistributedMapAdapter.create(DataStructureRegistry registry, KryoSerializer serializer, String cacheName, Class<K> keyType, Class<V> valueType, Collection<Class<?>> allowedEmbeddedTypes)	Create an adapter with additional embedded payload types allowed for Object-typed caches.
LoomJCacheConfig.Builder<K,V>	LoomJCacheConfig.Builder.distributedRegistry(@Nullable DataStructureRegistry registry)	Set the registry used to resolve the backing DistributedMap when distributed mode is enabled.

Constructors in com.loomcache.server.jcache with parameters of type DataStructureRegistry

Modifier	Constructor	Description
	LoomCachingProvider(@Nullable DataStructureRegistry registry)	Construct a provider that hands out distributed (Raft-replicated) caches.
	LoomCachingProvider(@Nullable DataStructureRegistry registry, String host, int port)	Construct a provider whose distributed caches route through the cluster protocol exposed by the given node endpoint.
	LoomJCacheManager(URI uri, @Nullable javax.cache.spi.CachingProvider cachingProvider, @Nullable ClassLoader classLoader, @Nullable Properties properties, @Nullable DataStructureRegistry distributedRegistry)	Full constructor including an optional DataStructureRegistry for distributed (Raft-replicated) JCache state (P1.4).
	LoomJCacheManager(URI uri, @Nullable javax.cache.spi.CachingProvider cachingProvider, @Nullable ClassLoader classLoader, @Nullable Properties properties, @Nullable DataStructureRegistry distributedRegistry, @Nullable com.loomcache.server.jcache.LoomJCacheClusterClient distributedClusterClient)

Uses of DataStructureRegistry in com.loomcache.server.management

Constructors in com.loomcache.server.management with parameters of type DataStructureRegistry

Modifier	Constructor	Description
	ManagementApiHandler(@NonNull DataStructureRegistry registry, int instanceNumber, @Nullable Supplier<Map<String,Object>> clusterTopologySupplier, @Nullable Supplier<Map<String,Object>> metricsSupplier, @Nullable Supplier<Map<String,Object>> configSupplier)

Uses of DataStructureRegistry in com.loomcache.server.metrics

Methods in com.loomcache.server.metrics with parameters of type DataStructureRegistry

Modifier and Type	Method	Description
void	LoomMetrics.registerCacheMetrics(DataStructureRegistry dataStructures)	Register all cache data structure metrics.
void	LoomMetrics.registerIndexMetrics(DataStructureRegistry dataStructures, @Nullable PartitionRouter partitionRouter)	Register index observability metrics for query planning.

Constructors in com.loomcache.server.metrics with parameters of type DataStructureRegistry

Modifier	Constructor	Description
	CacheAnalytics(io.micrometer.core.instrument.MeterRegistry registry, OperationsTracker operationsTracker, CapacityPlanner capacityPlanner, AccessPatternAnalyzer accessPatternAnalyzer, @Nullable DataStructureRegistry dataStructureRegistry)	Create a new CacheAnalytics instance with live data structure access.

Uses of DataStructureRegistry in com.loomcache.server.rest

Constructors in com.loomcache.server.rest with parameters of type DataStructureRegistry

Modifier	Constructor	Description
	RestApiServer(int port, DataStructureRegistry registry)	Deprecated. Create a REST API server bound to loopback (127.0.0.1) by default.
	RestApiServer(int port, String bindAddress, DataStructureRegistry registry)	Deprecated. Create a REST API server bound to a specific address.

Uses of DataStructureRegistry in com.loomcache.server.sharding

Methods in com.loomcache.server.sharding that return DataStructureRegistry

Modifier and Type	Method	Description
DataStructureRegistry	ShardedDataStructureRegistry.getRegistryForGroup(int groupId)	Returns the registry for the specified Raft group, creating it if necessary.
DataStructureRegistry	ShardedDataStructureRegistry.getRegistryForKey(String key)	Returns the registry for the Raft group that owns the given key.
@Nullable DataStructureRegistry	ShardedDataStructureRegistry.removeRegistry(int groupId)	Removes and returns the registry for a specific group.

Method parameters in com.loomcache.server.sharding with type arguments of type DataStructureRegistry

Modifier and Type	Method	Description
<V> V	ShardedDataStructureRegistry.executeOnGroup(int groupId, Function<DataStructureRegistry, V> operation)	Executes an operation on the registry of a specific Raft group.
<V> List<V>	CrossGroupQueryExecutor.partitionQuery(Object partitionKey, Function<DataStructureRegistry, List<V>> query, int limit)	Executes a partition-constrained query against the single owning group.
<V> Map<Integer,V>	ShardedDataStructureRegistry.scatterGather(Function<DataStructureRegistry, V> operation)	Executes an operation on every instantiated group registry and collects results.
<V> List<V>	CrossGroupQueryExecutor.scatterQuery(Function<DataStructureRegistry, List<V>> query, int limit)

Uses of DataStructureRegistry in com.loomcache.server.transaction

Methods in com.loomcache.server.transaction with parameters of type DataStructureRegistry

Modifier and Type	Method	Description
static TransactionManager	TransactionManager.withLocalCommitFallbackForTests(DataStructureRegistry registry)	Creates a manager that may use the legacy in-memory commit path when an operation is not representable as a replicated batch.

Constructors in com.loomcache.server.transaction with parameters of type DataStructureRegistry

Modifier	Constructor	Description
	TransactionContext(DataStructureRegistry registry, long timeoutMillis)	Creates a new transaction context.
	TransactionContext(DataStructureRegistry registry, UUID transactionId, long timeoutMillis)	Creates a new transaction context with a caller-specified id.
	TransactionManager(DataStructureRegistry registry)	Creates a new transaction manager with a local (non-replicated) commit path.
	TransactionManager(DataStructureRegistry registry, @Nullable BatchExecutionHandler batchHandler, @Nullable CrossGroupTransactionExecutor crossGroupExecutor, @Nullable PartitionRouter partitionRouter)	Creates a new transaction manager with optional Raft-replicated commit.

Uses of DataStructureRegistry in com.loomcache.server.transaction.twopc

Constructor parameters in com.loomcache.server.transaction.twopc with type arguments of type DataStructureRegistry

Modifier	Constructor	Description
	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)

Uses of DataStructureRegistry in com.loomcache.server.wan

Constructors in com.loomcache.server.wan with parameters of type DataStructureRegistry

Modifier	Constructor	Description
	WanConsumer(@NonNull DataStructureRegistry registry, @NonNull WanConsumer.ConflictResolver conflictResolver)	Create a WAN consumer.
	WanConsumer(@NonNull DataStructureRegistry registry, @NonNull WanConsumer.ConflictResolver conflictResolver, long gapTimeoutMs)	Create a WAN consumer with configurable gap timeout.
	WanReplicationManager(@NonNull String localClusterId, int instanceNumber, @NonNull DataStructureRegistry registry)	Create a WAN replication manager with default batch settings.
	WanReplicationManager(@NonNull String localClusterId, int instanceNumber, @NonNull DataStructureRegistry registry, int defaultBatchSize, long defaultFlushIntervalMs)	Create a new WAN replication manager.
	WanReplicationManager(@NonNull String localClusterId, int instanceNumber, @NonNull DataStructureRegistry registry, int defaultBatchSize, long defaultFlushIntervalMs, @NonNull WanAcknowledgeType acknowledgeType)	Create a new WAN replication manager.
	WanReplicationManager(@NonNull String localClusterId, int instanceNumber, @NonNull DataStructureRegistry registry, int defaultBatchSize, long defaultFlushIntervalMs, @NonNull WanAcknowledgeType acknowledgeType, boolean persistWanReplicatedData)	Create a new WAN replication manager.
	WanReplicationManager(@NonNull String localClusterId, int instanceNumber, @NonNull DataStructureRegistry registry, @NonNull WanAcknowledgeType acknowledgeType)	Create a WAN replication manager with default batch settings.
	WanReplicationManager(@NonNull String localClusterId, int instanceNumber, @NonNull DataStructureRegistry registry, @NonNull WanAcknowledgeType acknowledgeType, boolean persistWanReplicatedData)	Create a WAN replication manager with default batch settings.