Struct DAGSyncer 

pub struct DAGSyncer<S: DAGStore> {
    store: S,
    config: SyncConfig,
}

DAG synchronizer for gap-repair and reconciliation.

The syncer uses a pull-based approach:

1. Compare heads with a peer
2. Identify missing nodes
3. Fetch missing nodes recursively until reaching common ancestors

Fields

store: S

The local DAG store.

config: SyncConfig

Configuration.

Implementations

impl<S: DAGStore> DAGSyncer<S>

pub fn new(store: S) -> Self

Create a new syncer with a store.

pub fn with_config(store: S, config: SyncConfig) -> Self

Create a syncer with custom configuration.

pub fn store(&self) -> &S

Get a reference to the store.

pub fn store_mut(&mut self) -> &mut S

Get a mutable reference to the store.

pub fn heads(&self) -> Vec<Hash>

Get our current heads.

pub fn need(&self, cids: &[Hash]) -> Vec<Hash>

Determine which of the given CIDs we need (don’t have locally).

pub fn create_request(&self, peer_heads: &[Hash]) -> SyncRequest

Create a sync request for reconciliation with a peer.

pub fn handle_request(&self, request: &SyncRequest) -> SyncResponse

Handle an incoming sync request from a peer.

pub fn apply_response( &mut self, response: SyncResponse, ) -> Result<Vec<Hash>, SyncError>

Apply a sync response, storing received nodes.

Returns the CIDs of successfully stored nodes.

pub fn apply_nodes_unchecked( &mut self, nodes: Vec<MerkleNode>, ) -> Result<Vec<Hash>, SyncError>

Apply nodes without strict parent checking.

Used when nodes may arrive out of order.

fn collect_known(&self, heads: &[Hash]) -> HashSet<Hash>

Collect all CIDs reachable from the given heads (including the heads).

pub fn find_missing_ancestors(&self, cids: &[Hash]) -> Vec<Hash>

Find the missing ancestors of the given CIDs.

This performs gap detection by traversing backwards from the given CIDs and identifying nodes that aren’t in our store.

pub fn is_synced_with(&self, peer_heads: &[Hash]) -> bool

Check if we’re synchronized with a peer (have all their nodes).

pub fn sync_status(&self) -> SyncStatus

Get statistics about sync status.