Struct BlobSyncClient 

pub struct BlobSyncClient { /* private fields */ }

Blob sync client.

Implementations

impl BlobSyncClient

pub fn new(config: BlobSyncConfig) -> (Self, Receiver<BlobUpdate>)

Create a new blob sync client.

pub async fn sync<F, W, D>( &self, _on_read: F, on_write: W, _on_delete: D, ) -> Result<()>

where F: Fn(&str) -> Pin<Box<dyn Future<Output = Result<Option<Vec<u8>>>> + Send>> + Send + Sync, W: Fn(&str, Vec<u8>) -> Pin<Box<dyn Future<Output = Result<()>> + Send>> + Send + Sync, D: Fn(&str) -> Pin<Box<dyn Future<Output = Result<()>> + Send>> + Send + Sync,

Start syncing with the remote blob server.

pub async fn put( &self, key: &str, data: Vec<u8>, version: Option<Vec<String>>, ) -> Result<Vec<String>>

pub async fn delete(&self, key: &str) -> Result<()>