pub struct PullChangesResponse {
pub stream_id: StreamId,
pub from_seq_no: SeqNo,
pub next_seq_no: SeqNo,
pub changes: Vec<StampedChange>,
pub truncated: bool,
pub compacted_before_seq_no: Option<SeqNo>,
}Expand description
Delta response for one pull step.
Fields§
§stream_id: StreamIdStream identity chosen during process handshake.
from_seq_no: SeqNoEcho of request cursor.
next_seq_no: SeqNoNext cursor the caller should request.
changes: Vec<StampedChange>Returned changes in ascending seq_no.
truncated: booltrue when additional changes are available after this batch.
compacted_before_seq_no: Option<SeqNo>When present, requested history before this cursor was compacted away.
Consumers should rebuild from a checkpoint and resume from this cursor.
Trait Implementations§
Auto Trait Implementations§
impl Freeze for PullChangesResponse
impl RefUnwindSafe for PullChangesResponse
impl Send for PullChangesResponse
impl Sync for PullChangesResponse
impl Unpin for PullChangesResponse
impl UnsafeUnpin for PullChangesResponse
impl UnwindSafe for PullChangesResponse
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