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, include_snapshots: bool, include_tvl: bool, rpc_client: R, deltas_client: D, timeout: u64, ) -> Self

Creates a new state synchronizer.

Trait Implementations

impl<R: Clone + RPCClient, D: Clone + DeltasClient> Clone for ProtocolStateSynchronizer<R, D>

fn clone(&self) -> ProtocolStateSynchronizer<R, D>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

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 self, ) -> Pin<Box<dyn Future<Output = SyncResult<()>> + Send + 'async_trait>>

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

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

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

Starts the state synchronization.

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

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

Ends the synchronization loop.