wow-r2dbc/me.ahoo.wow.r2dbc

Package-level declarations

Types

ConnectionFactoryRegistrar

interface ConnectionFactoryRegistrar : Map<String, ConnectionFactory>

interface Database

EventStreamDatabase

interface EventStreamDatabase : Database

EventStreamSchema

interface EventStreamSchema

EventStreamStatement

data class EventStreamStatement(val load: String, val loadByEventTime: String, val append: String, val last: String)

EventStreamStatementGenerator

object EventStreamStatementGenerator

R2dbcEventStore

class R2dbcEventStore(database: Database, eventStreamSchema: EventStreamSchema) : AbstractEventStore

R2dbcSnapshotRepository

class R2dbcSnapshotRepository(database: Database, snapshotSchema: SnapshotSchema) : SnapshotRepository

ShardingDatabase

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

ShardingEventStreamSchema

class ShardingEventStreamSchema(sharding: AggregateIdSharding) : EventStreamSchema

ShardingSnapshotSchema

class ShardingSnapshotSchema(sharding: AggregateIdSharding) : SnapshotSchema

SimpleConnectionFactoryRegistrar

class SimpleConnectionFactoryRegistrar(connectionFactories: Map<String, ConnectionFactory>) : ConnectionFactoryRegistrar, Map<String, ConnectionFactory>

class SimpleDatabase(connectionFactory: ConnectionFactory) : EventStreamDatabase, SnapshotDatabase

SimpleEventStreamSchema

class SimpleEventStreamSchema : EventStreamSchema

SimpleSnapshotSchema

class SimpleSnapshotSchema : SnapshotSchema

SnapshotDatabase

interface SnapshotDatabase : Database

interface SnapshotSchema

SnapshotStatement

data class SnapshotStatement(val load: String, val loadByVersion: String, val save: String, val scan: String)

SnapshotStatementGenerator

object SnapshotStatementGenerator

Properties

EVENT_STREAM_LOGIC_NAME_PREFIX

const val EVENT_STREAM_LOGIC_NAME_PREFIX: String

EVENT_STREAM_TABLE

const val EVENT_STREAM_TABLE: String

const val SNAPSHOT_TABLE: String