wow-core/me.ahoo.wow.sharding/SimpleShardingRegistrar

SimpleShardingRegistrar

class SimpleShardingRegistrar(registrar: MutableMap<String, AggregateIdSharding> = ConcurrentHashMap()) : ShardingRegistrar, MutableMap<String, AggregateIdSharding>

Simple thread-safe implementation of ShardingRegistrar using ConcurrentHashMap.

This class provides a basic implementation of the ShardingRegistrar interface using a ConcurrentHashMap for storage, making it safe for concurrent access in multi-threaded environments.

Example usage:

val registrar = SimpleShardingRegistrar()

// Register sharding strategies
registrar["orders"] = SingleAggregateIdSharding("order-node-1")
registrar["users"] = SingleAggregateIdSharding("user-node-1")

// Or using the register method
val namedSharding = MyNamedSharding("products")
registrar.register(namedSharding)

// Retrieve sharding strategies
val orderSharding = registrar["orders"]

See also

ShardingRegistrar

ConcurrentHashMap

Constructors

SimpleShardingRegistrar

constructor(registrar: MutableMap<String, AggregateIdSharding> = ConcurrentHashMap())

Properties

open override val entries: MutableSet<MutableMap.MutableEntry<String, AggregateIdSharding>>

open override val keys: MutableSet<String>

open override val size: Int

open override val values: MutableCollection<AggregateIdSharding>

Functions

open override fun clear()

open override fun containsKey(key: String): Boolean

open override fun containsValue(value: AggregateIdSharding): Boolean

open operator override fun get(key: String): AggregateIdSharding?

open override fun isEmpty(): Boolean

@IgnorableReturnValue

open override fun put(key: String, value: AggregateIdSharding): AggregateIdSharding?

open override fun putAll(from: Map<out String, AggregateIdSharding>)

open fun register(namedAggregateIdSharding: NamedAggregateIdSharding): AggregateIdSharding?

Registers a named sharding strategy in this registrar.

fun Map<String, String>?.toHeader(): Header

Converts a nullable map of strings to a Header instance.