Struct SyncCursor 

pub struct SyncCursor {
    pub peer_pubkey: PublicKey,
    pub tree_id: ID,
    pub last_synced_entry: Option<ID>,
    pub last_sync_time: String,
    pub last_sync_count: u64,
    pub total_synced_count: u64,
}

Tracks the synchronization position for a specific peer-tree relationship.

A sync cursor represents how far synchronization has progressed between this database and a specific peer for a specific tree.

Fields

peer_pubkey: PublicKey

The peer’s public key

tree_id: ID

The tree ID this cursor applies to

last_synced_entry: Option<ID>

The last entry ID that was successfully synchronized

last_sync_time: String

Timestamp of the last successful sync

last_sync_count: u64

Number of entries synchronized in the last session

total_synced_count: u64

Total number of entries synchronized with this peer for this tree

Implementations

impl SyncCursor

pub fn new(peer_pubkey: PublicKey, tree_id: ID, clock: &dyn Clock) -> Self

Create a new sync cursor for a peer-tree relationship.

Arguments

• peer_pubkey - The peer’s public key
• tree_id - The tree ID this cursor applies to
• clock - The time provider for timestamps

pub fn update_sync(&mut self, last_entry: ID, count: u64, clock: &dyn Clock)

Update the cursor with a successful sync operation.

Arguments

• last_entry - The ID of the last synced entry
• count - Number of entries synced in this operation
• clock - The time provider for timestamps

pub fn has_sync_history(&self) -> bool

Check if this cursor has any sync history.

Trait Implementations

impl Clone for SyncCursor

fn clone(&self) -> SyncCursor

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for SyncCursor

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for SyncCursor

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl PartialEq for SyncCursor

fn eq(&self, other: &SyncCursor) -> 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 Serialize for SyncCursor

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl StructuralPartialEq for SyncCursor