ResyncCoordinator class

Receiver-side reliable-sync coordinator.

Holds lastEpoch (the highest epoch fully applied) and a resyncing flag (a ResyncActionRequestSnapshot is outstanding until a covering Snapshot lands, so further ahead-of-cursor deltas are ignored instead of re-requesting).

ingest advances lastEpoch on Apply — the caller MUST fold the frame's ops into its projection on Apply. Mirrors the ReliableSync.step Lean model.

Constructors

ResyncCoordinator([Epoch _lastEpoch = 0])

A coordinator that has already applied through lastEpoch (0 = fresh; a Snapshot seeds the first real epoch).

Properties

hashCode → int

The hash code for this object.

no setter, inherited

isResyncing → bool

Whether a resync request is outstanding (awaiting a covering snapshot).

no setter

lastEpoch → int

The highest epoch fully applied.

no setter

runtimeType → Type

A representation of the runtime type of the object.

no setter, inherited

Methods

ack() → IpcMessage

The IpcMessageOutboxAck control frame to advertise this receiver's resume cursor on reconnect (and for periodic retention advance).

ingest(IpcMessage msg) → ResyncAction

Classify an inbound IpcMessage. CrdtSync is handled by the CRDT plane, and the reverse-channel control frames (IpcMessageResyncRequest / IpcMessageOutboxAck) are for the sender's driver, not this data receiver, so both are ignored here.

ingestDelta(Delta delta) → ResyncAction

Classify + fold an inbound Delta. On Apply this advances lastEpoch to delta.epoch (multi-epoch-span aware) and clears the resyncing flag.

ingestSnapshot(Epoch snapshotEpoch) → ResyncAction

Adopt a Snapshot at snapshotEpoch — a full-state frame always applies, setting lastEpoch and clearing the resyncing flag.

noSuchMethod(Invocation invocation) → dynamic

Invoked when a nonexistent method or property is accessed.

inherited

toString() → String

A string representation of this object.

inherited

Operators

operator ==(Object other) → bool

The equality operator.

inherited