Package-level declarations
Types
Link copied to clipboard
Interface for sharding aggregate IDs across multiple nodes or partitions.
Link copied to clipboard
class CompositeAggregateIdSharding(registrar: Map<NamedAggregate, AggregateIdSharding>) : AggregateIdSharding
Composite sharding implementation that routes aggregates based on their type.
Link copied to clipboard
class CosIdShardingDecorator(sharding: PreciseSharding<Long>, hashFunction: (String) -> Long = DEFAULT_HASH_FUNCTION) : AggregateIdSharding
Decorator that adapts a numeric sharding strategy for aggregate IDs using a hash function.
Link copied to clipboard
Named sharding implementation for aggregate IDs.
Link copied to clipboard
Registry for managing aggregate ID sharding strategies by name.
Link copied to clipboard
class SimpleShardingRegistrar(registrar: MutableMap<String, AggregateIdSharding> = ConcurrentHashMap()) : ShardingRegistrar, MutableMap<String, AggregateIdSharding>
Simple thread-safe implementation of ShardingRegistrar using ConcurrentHashMap.
Link copied to clipboard
Simple sharding implementation that always routes to a single node.