Module barrier 

Checkpoint barrier types and cross-thread injection. Checkpoint barrier protocol.

The coordinator injects barriers into sources via CheckpointBarrierInjector. Sources deliver barriers alongside events. The fast path (no pending barrier) is a single AtomicU64 load (~10ns).

Modules

flags

Barrier flags — packed into the flags field.

Structs

BarrierPollHandle

Handle used by source operators to poll for pending barriers.

CheckpointBarrier

A checkpoint barrier that flows through the dataflow graph.

CheckpointBarrierInjector

Cross-thread barrier injector for source operators.

Enums

StreamMessage

A message that flows through streaming channels.