pub fn sync(
        &self,
        from_height: u32,
        chunk_size: u32,
        indexed_height: prometheus::IntGauge,
    ) -> Instrumented<JoinHandle<Result<()>>> {
        let span = info_span!("ReplicaContractSync", self = %self);

        let sync = ContractSync::new(
            self.db.clone(),
            String::from_str(self.replica.name()).expect("!string"),
            self.indexer.clone(),
            from_height,
            chunk_size,
            indexed_height,
        );

        tokio::spawn(async move {
            let _ = sync.sync_updates().await?;
            Ok(())
        })
        .instrument(span)
    }
/// Spawn a task that syncs the CachingReplica's db with the on-chain event
/// data
Spawn a task that syncs the CachingReplica's db with the on-chain event
data
Spawn a task that syncs the CachingReplica ' s db with the on - chain event data
pub fn sync(
        &self,
        from_height: u32,
        chunk_size: u32,
        indexed_height: prometheus::IntGauge,
    ) -> Instrumented<JoinHandle<Result<()>>> {
        let span = info_span!("ReplicaContractSync", self = %self);
        let sync = ContractSync::new(
            self.db.clone(),
            String::from_str(self.replica.name()).expect("!string"),
            self.indexer.clone(),
            from_height,
            chunk_size,
            indexed_height,
        );
        tokio::spawn(async move {
            let _ = sync.sync_updates().await?;
            Ok(())
        })
        .instrument(span)
    }
pub fn sync ( & self , from_height : u32 , chunk_size : u32 , indexed_height : prometheus :: IntGauge , ) -> Instrumented < JoinHandle < Result < ( ) > > > { let span = info_span ! ( " " self self ) ; let sync = ContractSync :: new ( self . db . clone ( ) , String :: from_str ( self . replica . name ( ) ) . expect ( " " ) , self . indexer . clone ( ) , from_height , chunk_size , indexed_height , ) ; tokio :: spawn ( async move { let _ = sync . sync_updates ( ) . await ? ; Ok ( ( ) ) } ) . instrument ( span ) }
Spawn a task that syncs the CachingReplica's db with the on-chain event
data
Spawn a task that syncs the CachingReplica ' s db with the on - chain event data
&self
from_height
u32
chunk_size
u32
indexed_height
prometheus::IntGauge
&self
from_height
u32
chunk_size
u32
indexed_height
prometheus::IntGauge