Struct hopper::Sender

pub struct Sender<T> { /* fields omitted */ }

The 'send' side of hopper, similar to std::sync::mpsc::Sender.

Methods

impl<T> Sender<T> where
    T: Serialize, 

pub fn flush(&mut self) -> Result<(), Error>

Attempt to flush any outstanding disk writes to the deque

This function will attempt to flush outstanding disk writes, which may fail if the in-memory buffer is full. This function is useful when traffic patterns are bursty, meaning a write may end up being stranded in limbo for a good spell.

pub fn send(&mut self, event: T) -> Result<(), (T, Error)>

Send a event into the queue

This function will fail with IO errors if the underlying queue files are temporarily exhausted -- say, due to lack of file descriptors -- of with Full if there is no more space in the in-memory buffer or on disk, as per the max_disk_files setting from channel_with_explicit_capacity. Ownership of the event will be returned back to the caller on failure.

pub fn name(&self) -> &str

Return the sender's name

Trait Implementations

impl<T: Debug> Debug for Sender<T>

fn fmt(&self, __arg_0: &mut Formatter) -> Result

Formats the value using the given formatter.

impl<'de, T> Clone for Sender<T> where
    T: Serialize + Deserialize<'de>, 

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

Returns a copy of the value.

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

Performs copy-assignment from source.