Struct SyncManager 

pub struct SyncManager { /* private fields */ }

Sync manager coordinates chain synchronization.

Implementations

impl SyncManager

pub fn new(config: SyncConfig) -> Self

Create a new sync manager.

pub fn config(&self) -> &SyncConfig

Get the configuration.

pub async fn status(&self) -> SyncStatus

Get the current sync status.

pub async fn needs_sync(&self, local_height: Option<u64>) -> bool

Check if we need to sync.

pub async fn update_peer_height(&self, peer: PeerId, height: u64)

Update a peer’s reported height.

pub async fn remove_peer(&self, peer: &PeerId)

Remove a peer (on disconnect).

pub async fn start_sync(&self, from_height: u64, to_height: u64)

Start syncing from a specific height.

pub async fn pause_sync(&self)

Pause syncing.

pub async fn resume_sync(&self)

Resume syncing.

pub async fn next_request( &self, available_peers: &[PeerInfo], ) -> Option<(PeerId, Message)>

Get the next sync request to send.

Returns (peer_id, message) if there’s work to do.

pub async fn handle_blocks( &self, response: BlocksMessage, ) -> Result<Vec<Block>, SyncError>

Handle a received blocks response.

pub async fn handle_headers( &self, response: HeadersMessage, ) -> Result<Vec<BlockHeader>, SyncError>

Handle a received headers response.

pub async fn handle_snapshot( &self, response: SnapshotMessage, ) -> Result<(), SyncError>

Handle a received snapshot response.

pub async fn get_ready_blocks(&self, current_height: u64) -> Vec<Block>

Get blocks ready to apply (in order).

pub async fn complete_range(&self, start: u64, end: u64)

Mark a range as complete.

pub async fn handle_timeout(&self, request_id: MessageId)

Handle a request timeout.

pub async fn get_timed_out_requests(&self) -> Vec<MessageId>

Get timed out requests.

pub fn create_snapshot_request( &self, height: Option<u64>, ) -> (MessageId, Message)

Request a snapshot from a peer.

pub fn create_blocks_request( &self, start: u64, count: u32, ) -> (MessageId, Message)

Request blocks from a peer.

pub fn create_headers_request( &self, start: u64, count: u32, ) -> (MessageId, Message)

Request headers from a peer.

pub async fn stats(&self) -> SyncStats

Get sync statistics.

Trait Implementations

impl Debug for SyncManager

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

Formats the value using the given formatter.