pub enum ReadOutput {
Batch(SequencedRecordBatch),
NextSeqNum(u64),
}
Expand description
Batch of records or the next sequence number on the stream.
Variants§
Batch(SequencedRecordBatch)
Batch of records. It can only be empty when not in a session context, if the request cannot be satisfied without violating its limit.
NextSeqNum(u64)
Tail of the stream, i.e. sequence number that will be assigned to the next record. It will be returned if the requested starting position is greater than the tail, or only in case of a limited read, equal to it. It will also be returned if there are no records on the stream between the requested starting position and the tail.
Trait Implementations§
Source§impl Clone for ReadOutput
impl Clone for ReadOutput
Source§fn clone(&self) -> ReadOutput
fn clone(&self) -> ReadOutput
Returns a duplicate of the value. Read more
1.0.0 · Source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
Performs copy-assignment from
source
. Read moreAuto Trait Implementations§
impl Freeze for ReadOutput
impl RefUnwindSafe for ReadOutput
impl Send for ReadOutput
impl Sync for ReadOutput
impl Unpin for ReadOutput
impl UnwindSafe for ReadOutput
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
Mutably borrows from an owned value. Read more
Source§impl<T> CloneToUninit for Twhere
T: Clone,
impl<T> CloneToUninit for Twhere
T: Clone,
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>
Wrap the input message
T
in a tonic::Request