wow-core/me.ahoo.wow.eventsourcing.state

Package-level declarations

Types

DistributedStateEventBus

interface DistributedStateEventBus : StateEventBus, DistributedMessageBus<StateEvent<*>, StateEventExchange<*>>

InMemoryStateEventBus

class InMemoryStateEventBus(val sinkSupplier: (NamedAggregate) -> Sinks.Many<StateEvent<*>> = { Sinks.many().multicast().onBackpressureBuffer() }) : InMemoryMessageBus<StateEvent<*>, StateEventExchange<*>> , LocalStateEventBus

LocalFirstStateEventBus

class LocalFirstStateEventBus(val distributedBus: DistributedStateEventBus, val localBus: LocalStateEventBus = InMemoryStateEventBus()) : StateEventBus, LocalFirstMessageBus<StateEvent<*>, StateEventExchange<*>>

LocalStateEventBus

interface LocalStateEventBus : StateEventBus, LocalMessageBus<StateEvent<*>, StateEventExchange<*>>

SendStateEventFilter

@Order(value = 2147483647, after = [SendDomainEventStreamFilter::class])

class SendStateEventFilter(stateEventBus: StateEventBus) : ExchangeFilter<ServerCommandExchange<*>>

SimpleStateEventExchange

class SimpleStateEventExchange<S : Any>(val message: StateEvent<S>, val attributes: MutableMap<String, Any> = ConcurrentHashMap()) : StateEventExchange<S>

interface StateEvent<S : Any> : DomainEventStream, ReadOnlyStateAggregate<S>

interface StateEventBus : MessageBus<StateEvent<*>, StateEventExchange<*>> , TopicKindCapable

data class StateEventData<S : Any>(val delegate: DomainEventStream, val state: S, val firstOperator: String = delegate.header.operator.orEmpty(), val firstEventTime: Long = delegate.createTime, val deleted: Boolean = false) : StateEvent<S> , Decorator<DomainEventStream> , DomainEventStream

StateEventExchange

interface StateEventExchange<S : Any> : MessageExchange<StateEventExchange<S>, StateEvent<S>>