Struct ProtocolStateSynchronizer 

pub struct ProtocolStateSynchronizer<R: RPCClient, D: DeltasClient> { /* private fields */ }

Implementations

impl<R, D> ProtocolStateSynchronizer<R, D>

where R: RPCClient + Clone + Send + Sync + 'static, D: DeltasClient + Clone + Send + Sync + 'static,

pub fn new( extractor_id: ExtractorIdentity, retrieve_balances: bool, component_filter: ComponentFilter, max_retries: u64, retry_cooldown: Duration, include_snapshots: bool, include_tvl: bool, compression: bool, rpc_client: R, deltas_client: D, timeout: u64, ) -> Self

Creates a new state synchronizer.

Trait Implementations

impl<R, D> StateSynchronizer for ProtocolStateSynchronizer<R, D>

where R: RPCClient + Clone + Send + Sync + 'static, D: DeltasClient + Clone + Send + Sync + 'static,

fn initialize<'life0, 'async_trait>( &'life0 mut self, ) -> Pin<Box<dyn Future<Output = SyncResult<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn start<'async_trait>( self, ) -> Pin<Box<dyn Future<Output = (SynchronizerTaskHandle, Receiver<SyncResult<StateSyncMessage<BlockHeader>>>)> + Send + 'async_trait>>

where Self: 'async_trait,

Starts the state synchronization, consuming the synchronizer. Returns a handle for controlling the running task and a receiver for messages.