[−][src]Module tempest::pipeline

Topology pipeline utilities

Structs

Pipeline	A pipeline is a collection of tasks and defines how they relate to each other in the form a directed acyclic graph.
PipelineAggregate	This is a holding pen that aggregates edge messages returned from a `TaskService`.
PipelineAvailable	This stores a queue of all available messages for a given Task by name.
PipelineInflight	All messages inflight (i.e. being worked on by tasks).
PipelineMsgState	This stores a `MsgId` and along with its state.

Enum for communicating the inflight status of pipeline messages.