Struct GrpcBlobStore 

pub struct GrpcBlobStore<T> {
    instance_name: String,
    client: BlobStoreServiceClient<T>,
}

Connects to a (remote) snix-castore BlobStoreService over gRPC.

Fields

instance_name: String

client: BlobStoreServiceClient<T>

The internal reference to a gRPC client. Cloning it is cheap, and it internally handles concurrent requests.

Implementations

impl<T> GrpcBlobStore<T>

pub fn from_client( instance_name: String, client: BlobStoreServiceClient<T>, ) -> Self

construct a GrpcBlobStore from a proto::blob_store_service_client::BlobStoreServiceClient.

Trait Implementations

impl<T> BlobStore for GrpcBlobStore<T>

where T: GrpcService<Body> + Send + Sync + Clone + 'static, T::ResponseBody: Body<Data = Bytes> + Send + 'static, <T::ResponseBody as Body>::Error: Into<StdError> + Send, T::Future: Send,

fn get<'life0, 'life1, 'async_trait>( &'life0 self, digest: &'life1 B3Digest, ) -> Pin<Box<dyn Future<Output = Result<Option<BlobMeta>, Error>> + Send + 'async_trait>>

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

Retrieves a BlobMeta for a given blob digest.

fn has<'life0, 'life1, 'async_trait>( &'life0 self, digest: &'life1 B3Digest, ) -> Pin<Box<dyn Future<Output = Result<bool, Error>> + Send + 'async_trait>>

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

Checks if a BlobMeta for a given blob exists.

fn put<'life0, 'life1, 'async_trait>( &'life0 self, digest: &'life1 B3Digest, blob_meta: BlobMeta, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>

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

Persists a BlobMeta for the given blob digest.

impl<T: Clone> Clone for GrpcBlobStore<T>

fn clone(&self) -> GrpcBlobStore<T>

Returns a duplicate of the value.

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

Performs copy-assignment from source.