Module core 

Core streaming abstractions and traits.

Re-exports

pub use stream::Stream;

pub use stream::StreamConfig;

pub use stream::StreamElement;

pub use stream::StreamMessage;

pub use stream::StreamMetadata;

pub use stream::StreamSink;

pub use stream::StreamSource;

Modules

stream

Core stream types and traits.

Structs

BackpressureConfig

Configuration for backpressure management.

BackpressureManager

Manages backpressure for a stream.

FailureRecord

Record of a failure event.

FilterOperator

A filter operator.

FlatMapOperator

A flat map operator.

FlowControlConfig

Configuration for flow control.

FlowControlMetrics

Metrics for flow control.

FlowController

Flow controller for managing stream throughput.

LoadMetrics

Metrics for load monitoring.

LoggingSink

A logging sink operator for debugging.

MapOperator

A map operator.

RecoveryConfig

Configuration for recovery.

RecoveryManager

Manages recovery from failures.

Enums

BackpressureStrategy

Strategy for handling backpressure.

RecoveryStrategy

Strategy for recovering from failures.

Traits

SinkOperator

A sink operator that consumes stream elements.

SourceOperator

A source operator that produces stream elements.

StreamOperator

Base trait for stream operators.

TransformOperator

A transform operator that modifies stream elements.