pub enum ReadOutput {
Batch(SequencedRecordBatch),
NextSeqNum(u64),
}This crate has been renamed to s2-sdk. Please update your Cargo.toml to use s2-sdk instead.
Expand description
Batch of records or the next sequence number on the stream.
Variants§
Batch(SequencedRecordBatch)
This crate has been renamed to s2-sdk. Please update your Cargo.toml to use s2-sdk instead.
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)
This crate has been renamed to s2-sdk. Please update your Cargo.toml to use s2-sdk instead.
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
1.0.0 (const: unstable) · Source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
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 UnsafeUnpin 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
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>
T in a tonic::Request