Module barrier 

Fixed processing targets over the shared durable receiver.

Structs

BarrierSnapshot

Settled obligations from one bounded sync run.

BarrierTopic

One fixed target and its latest durable progress (STR-042 and STR-043).

GroupBarrierRun

Fixed starting groups plus discoveries attributed to Welcomes at or below the fixed H.

Enums

BarrierCause

Why one fixed processing obligation is unfinished.

BarrierError

BarrierFailure

Why a bounded sync stopped before every obligation completed.

Functions

receive_through_current

Sample targets once and query missing receipt without first waiting for a live stream. Traffic after these targets cannot extend the call.

receive_through_current_until

Target sampling and processing use one deadline.

receive_with_welcomes_until

Process starting groups and enrolled Welcome discoveries under one deadline. Later local groups and Welcomes above the sampled head cannot extend the run.

wait_through

Wait for all independent obligations before reporting blocked work. Prefer a healthy receiver for caller-supplied targets, with bounded Query fallback.