Struct tvix_castore::blobservice::GRPCBlobService

pub struct GRPCBlobService<T> {
    grpc_client: BlobServiceClient<T>,
}

Connects to a (remote) tvix-store BlobService over gRPC.

Fields

grpc_client: BlobServiceClient<T>

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

Implementations

impl<T> GRPCBlobService<T>

pub fn from_client(grpc_client: BlobServiceClient<T>) -> Self

construct a GRPCBlobService from a proto::blob_service_client::BlobServiceClient.

Trait Implementations

impl<T> BlobService for GRPCBlobService<T>

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

fn open_write<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Box<dyn BlobWriter>> + Send + 'async_trait>>

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

Returns a BlobWriter, that’ll internally wrap each write in a proto::BlobChunk, which is send to the gRPC server.

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

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

Check if the service has the blob, by its content hash. On implementations returning chunks, this must also work for chunks.

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

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

Request a blob from the store, by its content hash. On implementations returning chunks, this must also work for chunks.

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

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

Return a list of chunks for a given blob. There’s a distinction between returning Ok(None) and Ok(Some(vec![])). The former return value is sent in case the blob is not present at all, while the second one is sent in case there’s no more granular chunks (or the backend does not support chunking). A default implementation checking for existence and then returning it does not have more granular chunks available is provided.

impl<T: Clone> Clone for GRPCBlobService<T>

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

Returns a copy of the value.

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

Performs copy-assignment from source.