Struct adder_codec_core::codec::encoder::Encoder

pub struct Encoder<W: Write> { /* private fields */ }

Struct for encoding Events to a stream

Implementations

impl<W: Write + 'static> Encoder<W>

pub fn new_empty(compression: EmptyOutput<Sink>) -> Selfwhere Self: Sized,

Create a new Encoder with an empty compression scheme

pub fn new_raw(compression: RawOutput<W>) -> Selfwhere Self: Sized,

Create a new Encoder with the given raw compression scheme

pub fn new_raw_interleaved(compression: RawOutputInterleaved<W>) -> Selfwhere Self: Sized,

Create a new Encoder with the given raw compression scheme

pub fn meta(&self) -> &CodecMetadata

Returns a reference to the metadata of the underlying compression scheme

pub fn flush_writer(&mut self) -> Result<()>

Flush the BitWriter. Does not flush the internal BufWriter.

pub fn close_writer(self) -> Result<Option<W>, CodecError>

Close the encoder’s writer and return it, consuming the encoder in the process.

pub fn ingest_event(&mut self, event: Event) -> Result<(), CodecError>

Ingest an event

pub fn ingest_events(&mut self, events: &[Event]) -> Result<(), CodecError>

Ingest an array of events

TODO: Make this move events, not by reference

pub fn ingest_events_events( &mut self, events: &[Vec<Event>] ) -> Result<(), CodecError>

Ingest a vector of an array of events