Module mz_timely_util::builder_async

Types to build async operators with general shapes.

Structs

• AsyncInputHandle
  Async handle to an operator’s input stream
• AsyncOutputHandle
• Button
• ButtonHandle
  A button that can be used to coordinate an action after all workers have pressed it.
• ConnectedToMany
  A marker type representing an input connected to many outputs.
• ConnectedToOne
  A marker type representing an input connected to exactly one output.
• Disconnected
  A marker type representing a disconnected input.
• OperatorBuilder
  Builds async operators with generic shape.
• PressOnDropButton

Enums

• Event
  An event of an input stream

Traits

• CapabilityTrait
• InputConnection
  A trait describing the connection behavior between an input of an operator and zero or more of its outputs.
• OutputIndex
  A helper trait abstracting over an output handle. It facilitates passing type erased output handles during operator construction. It is not meant to be implemented by users.

Functions

• button
  Creates a new coordinated button the worker configuration described by scope.