pub enum ReadOutput {
Batch(SequencedRecordBatch),
NextSeqNum(u64),
}๐Deprecated since 0.21.1: 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)
๐Deprecated since 0.21.1: 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)
๐Deprecated since 0.21.1: 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
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