Struct WatchCursor 

pub struct WatchCursor(/* private fields */);

Opaque position in a watch stream for resuming after disconnect.

Backends store whatever they need to resume (NATS: u64 revision). Callers should treat this as opaque and only pass it back to watch_all_from / watch_prefix_from.

Implementations

impl WatchCursor

pub fn none() -> Self

No cursor — forces a full watch on next connect.

pub fn is_none(&self) -> bool

Returns true if this cursor has no position (will trigger full watch).

pub fn from_version(token: VersionToken) -> Self

Create a cursor from a version token.

pub fn from_u64(rev: u64) -> Self

Create a cursor from a u64 revision (convenience for NATS).

pub fn as_u64(&self) -> Option<u64>

Try to extract as u64 revision.

Trait Implementations

impl Clone for WatchCursor

fn clone(&self) -> WatchCursor

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for WatchCursor

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for WatchCursor

fn default() -> WatchCursor

Returns the “default value” for a type.

impl Eq for WatchCursor

impl PartialEq for WatchCursor

fn eq(&self, other: &WatchCursor) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl StructuralPartialEq for WatchCursor