Module tempest::pipeline

Structs

Pipeline
PipelineAggregate	This is a holding pen which aggregates all edge messages returned from TaskService by its index. We store all these so they can be released at one time into the next set of downstream decendant tasks
PipelineAvailable	This stores a queue of all available messages for given Task name.
PipelineInflight	Pipeline messages that are currently inflight (being processed) by TaskService handlers
PipelineMsgState	This stores the original message id and it's state as moves through a pipeline

Enums

PipelineInflightStatus

Enum for communicating the inflight status of pipeline messages.