SourceTriggerPayload

@Serializable
data class SourceTriggerPayload(val triggeringSource: NodeIdentity, val nodeAction: NodeAction = NodeAction.EXECUTE, val epoch: Long = 0, val hopTtl: Int = DEFAULT_HOP_TTL) : EventPayload(source)

Identifies the node that just changed and the verb it owns, delivered to every node that lists it as a source with a firing invocationTrigger.

nodeAction defaults to NodeAction.EXECUTE so a payload that predates the field (or omits it) yields the original forward behaviour. epoch and hopTtl default so that a pre-propagation-metadata payload deserialises to a safe "fresh propagation, full TTL budget" value.

Constructors

Link copied to clipboard
constructor(triggeringSource: NodeIdentity, nodeAction: NodeAction = NodeAction.EXECUTE, epoch: Long = 0, hopTtl: Int = DEFAULT_HOP_TTL)

Types

Link copied to clipboard
object Companion

Properties

Link copied to clipboard
val epoch: Long

Originating host's monotonic propagation token. Lets a receiver dedupe an SSE-redelivered payload within one logical propagation. 0 for payloads predating this field.

Link copied to clipboard
val hopTtl: Int

Remaining cross-host hops. Decremented at each host boundary; at 0 the receiver updates local state but does not re-propagate outward, bounding cross-server cycles. Defaults to DEFAULT_HOP_TTL.

Link copied to clipboard

The originating node's durable verb — applied by the receiver, not its own.

Link copied to clipboard

Identity of the node whose change woke the receiver.