Struct adder_codec_core::codec::encoder::Encoder

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

Struct for encoding Events to a stream

Implementations

impl<W: Write> Encoder<W>

pub fn new(compression: Box<dyn WriteCompression<W>>) -> Selfwhere Self: Sized,

Create a new Encoder with the given 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

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

Ingest a vector of an array of events