Struct ChainSyncStatus 

pub struct ChainSyncStatus {
    pub chains: HashMap<String, u64>,
    /* private fields */
}

Cross-chain synchronization tracker.

Stores the current head block for each chain so callers can ask questions like “have all chains passed block N?” or “are all chains within K blocks of their respective tips?”

Fields

chains: HashMap<String, u64>

Maps chain id → latest known head block.

Implementations

impl ChainSyncStatus

pub fn new() -> Self

Create an empty sync status tracker.

pub fn update(&mut self, chain: &str, head: u64)

Update the head block for a chain.

pub fn update_with_timestamp(&mut self, chain: &str, head: u64, timestamp: i64)

Update both the head block and its timestamp for a chain.

pub fn update_tip(&mut self, chain: &str, tip: u64)

Update the known chain tip (latest block on the network) for a chain.

pub fn min_timestamp(&self) -> Option<i64>

Returns the earliest (minimum) timestamp across all chains with a recorded timestamp. Returns None if no timestamps are recorded.

pub fn max_timestamp(&self) -> Option<i64>

Returns the latest (maximum) timestamp across all chains.

pub fn all_past_block(&self, _chain: &str, block: u64) -> bool

Returns true if every registered chain has processed past block.

Returns false if there are no chains registered.

pub fn all_caught_up(&self, threshold_blocks: u64) -> bool

Returns true if all chains are within threshold_blocks of their recorded tips.

Returns false when no chains have tip information recorded.

pub fn head_of(&self, chain: &str) -> Option<u64>

Returns the head block for a specific chain.

pub fn lag_of(&self, chain: &str) -> Option<u64>

Returns the lag (tip - head) for a specific chain. None if the chain or its tip is not recorded.

pub fn len(&self) -> usize

Returns the number of chains being tracked.

pub fn is_empty(&self) -> bool

Returns true when no chains are tracked.

pub async fn from_coordinator(coordinator: &Arc<MultiChainCoordinator>) -> Self

Build a ChainSyncStatus snapshot from a MultiChainCoordinator.

Trait Implementations

impl Clone for ChainSyncStatus

fn clone(&self) -> ChainSyncStatus

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ChainSyncStatus

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

Formats the value using the given formatter.

impl Default for ChainSyncStatus

fn default() -> ChainSyncStatus

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for ChainSyncStatus

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for ChainSyncStatus

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

where __S: Serializer,

Serialize this value into the given Serde serializer.