Expand description
Pipeline topology building and running.
Re-exports§
pub use builder::TopologyBuilder;pub use fanout::Fanout;pub use healthcheck::run_all as run_healthchecks;pub use running::RunningTopology;
Modules§
- build_
impl - Dispatch functions for building Kinetic components from configuration.
- builder
- Builds and wires the DAG of pipeline components.
- fanout
- Fanout mechanism for cloning EventBatches to multiple downstream channels.
- healthcheck
- Sink healthcheck runner.
- running
- Management of a running topology, including graceful shutdown and hot-reload.
Traits§
- Healthcheck
- A trait for components that can check their connectivity/health at startup.