Coordinated

class Coordinated<A>(val value: A)

A task that requires coordination — it is not safe to apply without a consensus round-trip. This is the escalation path: tasks that are non-idempotent, require strict exactly-once delivery, or whose correctness depends on a globally-agreed ordering must be placed here.

The type has no Quilted bound: it explicitly allows non-monotone values. A Coordinated value cannot be passed to embroider or joinAll — those combinators accept only CoordinationFree. This makes the type boundary a compile-time gate: a caller who picks Coordinated is automatically routed toward the consensus path in WarpNode (#813).

Apply a coordinated task with commit, which applies your transform to the wrapped value. In WarpNode, coordinated tasks are backed by a Raft cluster (supplied as the raftNode constructor parameter) that achieves exactly-once execution in the common case and under tested roster-churn scenarios. Two residual timing windows can cause duplicate execution or task stranding in rare cases (see #879). The Results ORMap backstop absorbs duplicate results from the dual-leader window.

Type Parameters

A

the value type — no monotone constraint required.

See also

Constructors

Link copied to clipboard
constructor(value: A)

Properties

Link copied to clipboard
val value: A

the value to be processed under coordination.

Functions

Link copied to clipboard
fun <R> commit(transform: (A) -> R): R

Apply transform to value and return the result.

Link copied to clipboard
open operator override fun equals(other: Any?): Boolean
Link copied to clipboard
open override fun hashCode(): Int
Link copied to clipboard
open override fun toString(): String