Struct BinarySyncManager 

pub struct BinarySyncManager { /* private fields */ }

Binary sync manager for multiple URLs.

Implementations

impl BinarySyncManager

pub fn new( rate_limiter: Arc<ReconnectRateLimiter>, blob_store: Arc<BlobStore>, ) -> Result<Self>

Create a new binary sync manager.

pub async fn init_binary_sync(&self, url: &str, fullpath: &Path) -> Result<()>

Initialize a binary sync for a URL.

pub async fn signal_file_needs_reading( &self, url: &str, fullpath: &Path, ) -> Result<()>

Signal that a file needs reading and potentially uploading.

pub async fn disconnect(&self, url: &str)

Disconnect a sync.

pub async fn reconnect(&self, url: &str, fullpath: &Path) -> Result<()>

Reconnect a sync.

pub fn blob_store(&self) -> Arc<BlobStore>

Trait Implementations

impl Debug for BinarySyncManager

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

Formats the value using the given formatter.