Module streaming 

In-memory streaming API — Source, Sink, Subscription with broadcast fan-out.

Re-exports

pub use channel::channel;

pub use channel::AsyncConsumer;

pub use channel::Producer;

pub use checkpoint::CheckpointError;

pub use checkpoint::StreamCheckpointConfig;

pub use config::BackpressureStrategy;

pub use config::ChannelConfig;

pub use config::SourceConfig;

pub use config::WaitStrategy;

pub use error::RecvError;

pub use error::StreamingError;

pub use error::TryPushError;

pub use sink::Sink;

pub use source::create;

pub use source::create_with_config;

pub use source::Record;

pub use source::Source;

pub use subscription::Subscription;

Modules

channel

Bounded MPSC channel backed by crossfire.

checkpoint

Streaming checkpoint configuration.

config

Configuration types for channels, sources, and sinks.

error

Streaming error types.

sink

Sink — consumption endpoint with broadcast fan-out to multiple subscribers.

source

Source — entry point for data into a streaming pipeline.

subscription

Subscription — receive records from a Sink.