Enum vector_buffers::topology::channel::SenderAdapter

pub enum SenderAdapter<T: Bufferable> {
    InMemory(LimitedSender<T>),
    DiskV2(Arc<Mutex<BufferWriter<T, ProductionFilesystem>>>),
}

Adapter for papering over various sender backends.

Variants

InMemory(LimitedSender<T>)

The in-memory channel buffer.

DiskV2(Arc<Mutex<BufferWriter<T, ProductionFilesystem>>>)

The disk v2 buffer.

Implementations

impl<T> SenderAdapter<T>

where T: Bufferable,

pub fn capacity(&self) -> Option<usize>

Trait Implementations

impl<T: Clone + Bufferable> Clone for SenderAdapter<T>

fn clone(&self) -> SenderAdapter<T>

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<T: Debug + Bufferable> Debug for SenderAdapter<T>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<T: Bufferable> From<LimitedSender<T>> for SenderAdapter<T>

fn from(v: LimitedSender<T>) -> Self

Converts to this type from the input type.