Package-level declarations
Types
Link copied to clipboard
class MongoCheckpointStore(client: MongoClient, databaseName: String, dispatcher: CoroutineDispatcher = VirtualThreads.dispatcher, ddl: Ddl = Ddl.AUTO, operationTimeout: Duration = MongoTimeouts.OPERATION) : CheckpointStore
The CheckpointStore on MongoDB: one document per (group, subscription, partition) in wow_checkpoint, keyed by a unique index.
Link copied to clipboard
class MongoLeaseStore(client: MongoClient, databaseName: String, clock: Clock = Clock.systemUTC(), dispatcher: CoroutineDispatcher = VirtualThreads.dispatcher, ddl: Ddl = Ddl.AUTO, operationTimeout: Duration = MongoTimeouts.OPERATION) : LeaseStore
The LeaseStore on MongoDB: one document per (group, partition) in wow_lease and one per (group, node), with the node's internal address and the lease groups it serves, in wow_lease_member (one per service and node, its key field holding the service), each keyed by a unique index.