pub struct HandoffResult {
pub snapshot_end_ts: Option<u64>,
pub stream_start_ts: Option<u64>,
pub overlap_events_dropped: Option<u64>,
pub stream_watermark_gap: Option<u64>,
}Fields§
§snapshot_end_ts: Option<u64>§stream_start_ts: Option<u64>§overlap_events_dropped: Option<u64>Number of overlap events dropped during handoff deduplication.
None means the connector does not measure overlap at handoff (e.g. PostgreSQL).
Some(0) means the handoff was clean — no duplicate events were observed.
stream_watermark_gap: Option<u64>Optional source-specific watermark distance observed at handoff.
For PostgreSQL this is an LSN delta in bytes. Connectors that cannot
provide a reliable watermark distance should leave this as None.
Trait Implementations§
Source§impl Clone for HandoffResult
impl Clone for HandoffResult
Source§fn clone(&self) -> HandoffResult
fn clone(&self) -> HandoffResult
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 HandoffResult
impl Debug for HandoffResult
impl Eq for HandoffResult
Source§impl PartialEq for HandoffResult
impl PartialEq for HandoffResult
Source§fn eq(&self, other: &HandoffResult) -> bool
fn eq(&self, other: &HandoffResult) -> bool
Tests for
self and other values to be equal, and is used by ==.impl StructuralPartialEq for HandoffResult
Auto Trait Implementations§
impl Freeze for HandoffResult
impl RefUnwindSafe for HandoffResult
impl Send for HandoffResult
impl Sync for HandoffResult
impl Unpin for HandoffResult
impl UnsafeUnpin for HandoffResult
impl UnwindSafe for HandoffResult
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