kinetic_buffers/lib.rs
1//! Buffering implementations for Kinetic.
2//!
3//! Provides memory and disk-based buffers that sit between transforms and sinks,
4//! with configurable backpressure policies.
5
6#![deny(clippy::unwrap_used)]
7
8pub mod disk;
9pub mod memory;
10
11pub use disk::DiskBuffer;
12pub use memory::{BufferReceiver, BufferSender, WhenFull, channel};