pub trait EventSink: Send {
// Required methods
fn begin(
&mut self,
schema: Arc<Schema>,
plan: WritePlan,
) -> LadduDataResult<()>;
fn write_batch(&mut self, batch: &EventBatch) -> LadduDataResult<()>;
fn finish(&mut self) -> LadduDataResult<()>;
// Provided method
fn retains_batches(&self) -> bool { ... }
}Expand description
Consumer of schema-compatible event batches.
Required Methods§
Sourcefn begin(&mut self, schema: Arc<Schema>, plan: WritePlan) -> LadduDataResult<()>
fn begin(&mut self, schema: Arc<Schema>, plan: WritePlan) -> LadduDataResult<()>
Begins a write operation.
§Errors
Returns LadduDataError when the plan or schema is unsupported or
output initialization fails.
Sourcefn write_batch(&mut self, batch: &EventBatch) -> LadduDataResult<()>
fn write_batch(&mut self, batch: &EventBatch) -> LadduDataResult<()>
Writes one batch.
§Errors
Returns LadduDataError when the batch schema is incompatible or the
output cannot be written.
Sourcefn finish(&mut self) -> LadduDataResult<()>
fn finish(&mut self) -> LadduDataResult<()>
Finishes and flushes the write operation.
§Errors
Returns LadduDataError when buffered output cannot be finalized.
Provided Methods§
Sourcefn retains_batches(&self) -> bool
fn retains_batches(&self) -> bool
Returns whether written batches remain resident in memory.
Dyn Compatibility§
This trait is dyn compatible.
In older versions of Rust, dyn compatibility was called "object safety".