wow-core/me.ahoo.wow.serialization.event

Package-level declarations

Types

AbstractEventStreamJsonSerializer

abstract class AbstractEventStreamJsonSerializer<M : DomainEventStream>(messageType: Class<M>) : MessageSerializer<M>

DelegatingDomainEventRecord

class DelegatingDomainEventRecord(val actual: ObjectNode) : DomainEventRecord

DelegatingEventStreamRecord

class DelegatingEventStreamRecord(val actual: ObjectNode) : EventStreamRecord

DomainEventJsonDeserializer

object DomainEventJsonDeserializer : StdDeserializer<DomainEvent<*>>

DomainEventJsonSerializer

object DomainEventJsonSerializer : MessageSerializer<DomainEvent<*>>

DomainEventRecord

interface DomainEventRecord : StreamEventRecord, NamedBoundedContextMessageRecord, MessageAggregateNameRecord, MessageAggregateIdRecord, OwnerIdRecord, MessageCommandIdRecord, MessageVersionRecord

DomainEventRecords

object DomainEventRecords

EventStreamJsonDeserializer

object EventStreamJsonDeserializer : StdDeserializer<DomainEventStream>

EventStreamJsonSerializer

object EventStreamJsonSerializer : AbstractEventStreamJsonSerializer<DomainEventStream>

EventStreamRecord

interface EventStreamRecord : NamedBoundedContextMessageRecord, MessageCommandIdRecord, MessageVersionRecord, MessageRequestIdRecord, MessageAggregateIdRecord, OwnerIdRecord, MessageAggregateNameRecord

FlatEventStreamRecord

class FlatEventStreamRecord(val id: String, rawAggregateId: AggregateId, val header: ObjectNode, val version: Int, val ownerId: String, val commandId: String, val requestId: String, val body: JsonNode, val createTime: Long) : EventStreamRecord

JsonDomainEvent

data class JsonDomainEvent(val id: String, val header: Header, val bodyType: String, val body: JsonNode, val aggregateId: AggregateId, val ownerId: String, val version: Int, val sequence: Int, val revision: String, val commandId: String, val name: String, val isLast: Boolean = true, val createTime: Long = System.currentTimeMillis()) : DomainEvent<JsonNode> , NamedAggregate

StateEventJsonDeserializer

object StateEventJsonDeserializer : StdDeserializer<StateEvent<*>>

StateEventJsonSerializer

object StateEventJsonSerializer : AbstractEventStreamJsonSerializer<StateEvent<*>>

StateJsonRecord

data class StateJsonRecord(val actual: ObjectNode) : StateRecord

interface StateRecord : JsonRecord

StreamDomainEventRecord

class StreamDomainEventRecord(val actual: ObjectNode, streamedAggregateId: AggregateId, streamedVersion: Int, streamedOwnerId: String, streamedHeader: Header, streamedCommandId: String, val sequence: Int, val isLast: Boolean, streamedCreateTime: Long) : DomainEventRecord

StreamEventRecord

interface StreamEventRecord : MessageIdRecord, MessageBodyTypeRecord, MessageBodyRecord, MessageNameRecord

Functions

inline fun <S> StateRecord.state(): S

toDomainEventRecord

fun ObjectNode.toDomainEventRecord(): DomainEventRecord

toEventStreamRecord

fun ObjectNode.toEventStreamRecord(): EventStreamRecord