[][src]Module tempest::topology

Topology module and actors

Structs

PipelineActor

Main actor for tracking messages and where they are in the pipeline at any given time.

SourceAckMsg

Wrapper for acking messages by MsgId

SourceActor

Main actor for interacting with Source instances.

TopologyActor

Main actor for running and coordinating topologies.

TopologyBuilder

Builder for constructing and configuring topology instances.

TopologyOptions

Topology configuration options

Enums

TopologyFailurePolicy

Enum for configuring how to process message failures.

TopologyMaxPending

Enum for configuring the maximum number of pending messages.

Traits

Topology

Topology trait for building topologies.