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