wow-r2dbc/me.ahoo.wow.r2dbc/ShardingDatabase

ShardingDatabase

class ShardingDatabase(registrar: ConnectionFactoryRegistrar, aggregateIdSharding: AggregateIdSharding) : Database, EventStreamDatabase, SnapshotDatabase

Constructors

Link copied to clipboard
constructor(registrar: ConnectionFactoryRegistrar, aggregateIdSharding: AggregateIdSharding)

Functions

Link copied to clipboard
open override fun createConnection(aggregateId: AggregateId): Publisher<out Connection>
Link copied to clipboard
fun sharding(aggregateId: AggregateId): ConnectionFactory