pub struct BatchAppendResult {
pub batch_index: usize,
pub responses: Vec<Result<AppendRowsResponse, Status>>,
pub bytes_sent: usize,
}
Expand description
Result of processing a single table batch in concurrent append operations.
Contains the batch processing results along with metadata about the operation, including the original batch index for result ordering and total bytes sent for monitoring and debugging purposes.
Fields§
§batch_index: usize
Original index of the batch in the input vector.
Allows callers to correlate results with their original batch ordering even when results are returned in completion order rather than submission order.
responses: Vec<Result<AppendRowsResponse, Status>>
Collection of append operation responses for this batch.
Each batch may generate multiple append requests due to size limits, resulting in multiple responses. All responses must be checked for errors to ensure complete batch success.
bytes_sent: usize
Total bytes sent for this batch across all requests.
Implementations§
Source§impl BatchAppendResult
impl BatchAppendResult
Sourcepub fn new(
batch_index: usize,
responses: Vec<Result<AppendRowsResponse, Status>>,
bytes_sent: usize,
) -> Self
pub fn new( batch_index: usize, responses: Vec<Result<AppendRowsResponse, Status>>, bytes_sent: usize, ) -> Self
Creates a new batch append result.
Combines all result metadata into a single cohesive structure for easier handling by calling code.
Sourcepub fn is_success(&self) -> bool
pub fn is_success(&self) -> bool
Returns true if all responses in this batch are successful.
Convenience method to quickly check batch success without iterating through individual responses.
Trait Implementations§
Auto Trait Implementations§
impl Freeze for BatchAppendResult
impl !RefUnwindSafe for BatchAppendResult
impl Send for BatchAppendResult
impl Sync for BatchAppendResult
impl Unpin for BatchAppendResult
impl !UnwindSafe for BatchAppendResult
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Source§impl<T> Instrument for T
impl<T> Instrument for T
Source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
Source§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
Source§impl<T> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
Source§fn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
T
in a tonic::Request