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