Skip to main content

laminar_core/streaming/
mod.rs

1//! In-memory streaming API — a bounded Source queue drained by its single Sink.
2
3mod arrow_admission;
4pub mod channel;
5pub mod checkpoint;
6pub mod config;
7pub mod error;
8pub mod sink;
9pub mod source;
10
11pub use arrow_admission::{
12    retained_arrow_bytes, validate_source_max_queued_bytes, DEFAULT_SOURCE_MAX_QUEUED_BYTES,
13    MAX_SOURCE_QUEUED_BYTES,
14};
15pub use channel::{channel, AsyncConsumer, Producer};
16pub use checkpoint::StreamCheckpointConfig;
17pub use config::{BackpressureStrategy, ChannelConfig, SourceConfig, WaitStrategy};
18pub use error::{RecvError, StreamingError, TryPushError};
19pub use sink::Sink;
20#[cfg(feature = "cluster")]
21pub use source::create_for_schema_planning;
22pub use source::{create, create_with_config, Record, Source};