Module sides

Structs

ArrangeJoinSide 🔒

Join side of Arrange Executor’s stream

StreamJoinSide 🔒

Join side of Lookup Executor’s stream

Enums

ArrangeMessage

Message from the arrange_join_stream.

Functions

align_barrier

A biased barrier aligner which prefers message from the right side. Barrier message will be available for both left and right side, instead of being combined.

poll_until_barrier

stream_lookup_arrange_prev_epoch

Join the stream with the previous stable snapshot of the arrangement.

stream_lookup_arrange_this_epoch

Join the stream with the current state of the arrangement.

Type Aliases

BarrierAlignedMessage