spi/me.ahoo.wow.spi.wait

Package-level declarations

Types

class Origin @InternalWowApi constructor(val node: String, val address: String, val service: String)

The node a wait started on: its node id, its internal address (host:port of the internal signal entry, never the public one) and its service. A signal goes straight to it, not through a load balancer.

WaitContext

class WaitContext @InternalWowApi constructor(val waitId: String, val origin: Origin, val remaining: List<Hop>, val deadline: Long)

What travels with a command's messages and its log entry while its caller waits beyond COMMITTED: transport metadata, never a fact, invisible to domain code.

Functions

toContext

@InternalWowApi

fun WaitWire.toContext(): WaitContext

The context this wire form carries.

toWire

@InternalWowApi

fun WaitContext.toWire(): WaitWire

This context on the wire, as Wow-Call and the cluster channel carry it.