pub struct SinceBatch {
pub nodes: Vec<Node>,
pub from_seq: u64,
pub to_seq: u64,
pub head_seq: u64,
pub has_more: bool,
}Expand description
One page of the changefeed returned by since(). The replication contract:
apply nodes in ascending seq order, advance your cursor to to_seq, and keep
paging while has_more is true; then attach to the live subscribe edge.
head_seq tells the consumer how far the log currently extends (how far behind
it is).
Fields§
§nodes: Vec<Node>Writes in (from_seq, to_seq], ascending by seq.
from_seq: u64The exclusive cursor this page started from (echoes the request).
to_seq: u64Seq of the last node in this page — the consumer’s next cursor.
head_seq: u64Current head seq of the log (latest committed write).
has_more: boolTrue when more writes remain past to_seq (the page hit limit).
Trait Implementations§
Source§impl Clone for SinceBatch
impl Clone for SinceBatch
Source§fn clone(&self) -> SinceBatch
fn clone(&self) -> SinceBatch
Returns a duplicate of the value. Read more
1.0.0 (const: unstable) · Source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
Performs copy-assignment from
source. Read moreSource§impl Debug for SinceBatch
impl Debug for SinceBatch
Auto Trait Implementations§
impl Freeze for SinceBatch
impl RefUnwindSafe for SinceBatch
impl Send for SinceBatch
impl Sync for SinceBatch
impl Unpin for SinceBatch
impl UnsafeUnpin for SinceBatch
impl UnwindSafe for SinceBatch
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,
impl<A, B, T> HttpServerConnExec<A, B> for Twhere
B: Body,
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> IntoEither for T
impl<T> IntoEither for T
Source§fn into_either(self, into_left: bool) -> Either<Self, Self>
fn into_either(self, into_left: bool) -> Either<Self, Self>
Converts
self into a Left variant of Either<Self, Self>
if into_left is true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moreSource§fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
Converts
self into a Left variant of Either<Self, Self>
if into_left(&self) returns true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read more