kuilt-quilter/us.tractat.kuilt.quilter/RgaGcCoordinator/RgaGcCoordinator

RgaGcCoordinator

constructor(state: StateFlow<Rga<V>>, cutFrontier: StateFlow<CutFrontier>, delivered: StateFlow<VersionVector>, applyCompaction: (Patch<Rga<V>>) -> Unit, windowPolicy: WindowPolicy = WindowPolicy.never(), scope: CoroutineScope)

Parameters

state

live Rga state (updated by Quilter on every incoming delta).

cutFrontier

the atomically-published causal-stability cut + frontier from Quilter.cutFrontier.

delivered

this replica's contiguous delivered VV from Quilter.deliveredLocal.

applyCompaction

called with each compaction Patch; the caller wires this to Quilter.apply so the delta propagates to all peers.

windowPolicy

optional history-windowing policy (default WindowPolicy.never).

scope

the CoroutineScope for background coroutines.