execute

Function execute 

Source
pub async fn execute<L>(peer: &Peer<L>, job: SyncBucketJob) -> Result<()>
where L: BucketLogProvider + Clone + Send + Sync + 'static, L::Error: Error + Send + Sync + 'static,
Expand description

Execute a bucket sync job

This is the main entry point for syncing. It handles both cases:

  • Updating an existing bucket we already have
  • Cloning a new bucket we don’t have yet