Crate kinetic_buffers 

Buffering implementations for Kinetic.

Provides memory and disk-based buffers that sit between transforms and sinks, with configurable backpressure policies.

Re-exports

pub use disk::DiskBuffer;

pub use memory::BufferReceiver;

pub use memory::BufferSender;

pub use memory::WhenFull;

pub use memory::channel;

Modules

disk

Persistent disk-backed buffering for Kinetic.

memory

In-memory buffering with backpressure for Kinetic.