kuilt-quilter/us.tractat.kuilt.quilter/QuiltMessage

QuiltMessage

@Serializable

Wire messages exchanged between Quilter instances.

Delta carries a lattice fragment tagged with the sender's monotonic sequence number. Ack tells the sender that the acker has absorbed all deltas through seq, enabling GC of the delta buffer. FullState ships the entire current state — on first contact with a new peer, and in reply to a FullStateRequest. RootDigest is what the anti-entropy tick sends instead of the state: a hash of it, answered with a FullStateRequest only when the recipient's own hash differs.

Type Parameters

the us.tractat.kuilt.crdt.Quilted state type.

Inheritors

Types

Ack

@Serializable

@SerialName(value = "ack")

class Ack<S>(val acker: ReplicaId, val sender: ReplicaId, val seq: Long) : QuiltMessage<S>

Acknowledgement: acker has absorbed all deltas from sender through seq, so sender may GC every pending delta with seq ≤ seq.

Delivered

@Serializable

@SerialName(value = "delivered")

class Delivered<S>(val sender: ReplicaId, val vector: VersionVector) : QuiltMessage<S>

A delivered-version-vector gossip from sender — sender's whole-room contiguous delivered VersionVector (`author → highest gap-free seq it has applied), the per-replica row of the matrix clock that decides causal stability for RGA GC (ADR-003 addendum v3, #262).

Delta

@Serializable

@SerialName(value = "delta")

class Delta<S>(val sender: ReplicaId, val seq: Long, val delta: S) : QuiltMessage<S>

A lattice delta broadcast by sender, tagged with sender's monotonic per-seam sequence number.

FullState

@Serializable

@SerialName(value = "fullState")

class FullState<S>(val sender: ReplicaId, val state: S, val upThrough: Long = 0) : QuiltMessage<S>

The complete current state — sent once on first contact with a peer that has never been seen before. The recipient absorbs it with us.tractat.kuilt.crdt.Quilted.piece.

FullStateRequest

@Serializable

@SerialName(value = "fullStateRequest")

class FullStateRequest<S>(val requester: ReplicaId, val sender: ReplicaId) : QuiltMessage<S>

Sent by requester when a RootDigest from sender disagreed with its own root: please ship the state. The recipient answers with a FullState.

Resend

@Serializable

@SerialName(value = "resend")

class Resend<S>(val requester: ReplicaId, val sender: ReplicaId, val fromSeq: Long, val toSeq: Long) : QuiltMessage<S>

Gap retransmission request: requester has detected that it is missing deltas from sender in the range [fromSeq..toSeq] inclusive. sender should re-broadcast each buffered delta in that range.

RootDigest

@Serializable

@SerialName(value = "rootDigest")

class RootDigest<S>(val sender: ReplicaId, val root: Long, val upThrough: Long) : QuiltMessage<S>

A hash of sender's whole state, sent on the anti-entropy tick in place of the state itself (#1955). The recipient compares it with its own root and replies with a FullStateRequest only if they differ, so a converged round costs one small frame instead of the entire CRDT.