Struct SyncProtocol 

pub struct SyncProtocol { /* private fields */ }

Sync protocol for batched coherency operations

Implementations

impl SyncProtocol

pub fn new() -> Self

Create with default write policy

pub fn with_policy(policy: WritePolicy) -> Self

Create with specific write policy

pub fn epoch(&self) -> u64

Get current epoch

pub fn advance_epoch(&self) -> u64

Advance epoch (called after barrier sync)

pub fn policy(&self) -> WritePolicy

Get write policy

pub fn queue_sync(&self, block_id: u64, from: Tier, to: Tier)

Queue a sync operation

pub fn drain_pending(&self) -> Vec<(u64, Tier, Tier)>

Get and clear pending syncs

pub fn has_pending(&self) -> bool

Check if any syncs are pending

pub fn pending_count(&self) -> usize

Count pending syncs

Trait Implementations

impl Debug for SyncProtocol

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

Formats the value using the given formatter.

impl Default for SyncProtocol

fn default() -> SyncProtocol

Returns the “default value” for a type.