wow-tck/me.ahoo.wow.tck.wire/WireSamples

WireSamples

object WireSamples

Deterministic messages for the v9 wire-format golden tests.

Every id, timestamp and header value is fixed, so serializing a sample gives the same bytes on every run. The headers are stamped the way the 9.2.x runtime stamps them: request headers and local_first and the operator from the web edge, trace_id from command creation, command_wait_* from a real WaitPlan propagated by the gateway, and the event-side headers from the default propagators (MessagePropagators.DEFAULT, the ServiceLoader contributions).

The golden files built from these samples are frozen v9 wire contracts (design WP G1); see the golden tests in wow-core, wow-kafka, wow-redis and wow-spring-boot-starter.

Properties

const val AGGREGATE_ID: String

val chainWaitPlan: WaitPlan

The wait plan the gateway propagates on chainWaitCommandMessage: a saga chain ending in a snapshot.

CHANGED_EVENT_ID

const val CHANGED_EVENT_ID: String

COMMAND_CREATE_TIME

const val COMMAND_CREATE_TIME: Long

const val COMMAND_ID: String

COMMAND_WAIT_ENDPOINT

const val COMMAND_WAIT_ENDPOINT: String

CREATED_EVENT_ID

const val CREATED_EVENT_ID: String

EVENT_CREATE_TIME

const val EVENT_CREATE_TIME: Long

EVENT_STREAM_ID

const val EVENT_STREAM_ID: String

const val OPERATOR: String

const val OWNER_ID: String

const val REMOTE_IP: String

const val REQUEST_ID: String

SAGA_COMMAND_ID

const val SAGA_COMMAND_ID: String

const val SIGNAL_TIME: Long

const val SPACE_ID: String

val stageWaitPlan: WaitPlan

The wait plan the gateway propagates on commandMessage: wait for a named projection.

const val TENANT_ID: String

const val USER_AGENT: String

WAIT_COMMAND_ID

const val WAIT_COMMAND_ID: String

const val WAIT_SIGNAL_ID: String

Functions

chainWaitCommandMessage

fun chainWaitCommandMessage(): CommandMessage<MockCreateAggregate>

The same command waiting on a saga chain, which adds the command_wait_chain and command_wait_tail_* keys.

fun commandMessage(): CommandMessage<MockCreateAggregate>

A create command as the web edge and the gateway send it, waiting for a named projection.

domainEventStream

fun domainEventStream(): DomainEventStream

The event stream the aggregate appends for commandMessage, with headers propagated from the command.

failedWaitSignal

fun failedWaitSignal(): WaitSignal

A failed signal, which carries the error code, message and binding errors.

processedWaitSignal

fun processedWaitSignal(): WaitSignal

The signal a processor posts to the remote wait endpoint after processing commandMessage.

fun stateEvent(): StateEvent<MockStateAggregate>

The state event published after sourcing domainEventStream.