Struct WriteRecordBatchBuilder 

pub struct WriteRecordBatchBuilder { /* private fields */ }

Builder for writing multiple records across entries in a single request.

Implementations

impl WriteRecordBatchBuilder

pub fn add_record(self, record: Record) -> Self

Add a record to the batch.

Arguments

• record - The record to add to the batch.

Returns

Returns the builder for chaining.

pub fn append_record(&mut self, record: Record)

Add record to the batch without chaining.

Arguments

• record - The record to append to the batch.

pub fn add_records(self, records: Vec<Record>) -> Self

Add records to the batch.

Arguments

• records - The records to add to the batch.

Returns

Returns the builder for chaining.

pub fn append_records(&mut self, records: Vec<Record>)

Add records to the batch without chaining.

Arguments

• records - The records to append to the batch.

pub async fn send( self, ) -> Result<BTreeMap<(String, u64), ReductError>, ReductError>

Build the request and send it to the server.

Returns

Returns a map of (entry, timestamp) to errors for any records that failed to write.

Errors

• ReductError - If the request was not successful.

pub fn size(&self) -> usize

Get the size of the batch in bytes.

pub fn record_count(&self) -> usize

Get the number of records in the batch.

pub fn last_access(&self) -> SystemTime

Get the last time a record was added to the batch.

Can be used for sending the batch after a certain period of time.

pub fn clear(&mut self)

Clear the batch of records.