Struct asink::msgpack::MsgpackSink

pub struct MsgpackSink { /* private fields */ }

Sink with a file encoded by msgpack

Each data send to this sink will be serialized into msgpack binary, and write to a file. You must use stream api to read this file.

Implementations

impl MsgpackSink

pub fn from_path(path: &Path) -> Self

initialize with a path for msgpack file

pub fn from_str(path: &str) -> Self

initialize with a path for msgpack file

Trait Implementations

impl Clone for MsgpackSink

fn clone(&self) -> MsgpackSink

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for MsgpackSink

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

Formats the value using the given formatter.

impl<Doc: 'static + Send + Serialize> Sink<Doc> for MsgpackSink

fn run(self) -> (Sender<Doc>, JoinHandle<()>)

Start a thread for sink