Struct AppendSession 

pub struct AppendSession { /* private fields */ }

A session for high-throughput appending with backpressure control. It can be created from append_session.

Supports pipelining multiple AppendInputs while preserving submission order.

Implementations

impl AppendSession

pub async fn submit( &self, input: AppendInput, ) -> Result<BatchSubmitTicket, S2Error>

Submit a batch of records for appending.

Internally, it waits on reserve, then submits using the permit. This provides backpressure when inflight limits are reached. For explicit control, use reserve followed by BatchSubmitPermit::submit.

Note: After all submits, you must call close to ensure all batches are appended.

pub async fn reserve(&self, bytes: u32) -> Result<BatchSubmitPermit, S2Error>

Reserve capacity for a batch to be submitted. Useful in select! loops where you want to interleave submission with other async work. See submit for a simpler API.

Waits when inflight limits are reached, providing explicit backpressure control. The returned permit must be used to submit the batch.

Note: After all submits, you must call close to ensure all batches are appended.

Cancel safety

This method is cancel safe. Internally, it only awaits Semaphore::acquire_many_owned and Sender::reserve_owned, both of which are cancel safe.

pub async fn close(self) -> Result<(), S2Error>

Close the session and wait for all submitted batch of records to be appended.