Struct tvix_castore::directoryservice::GRPCDirectoryService

pub struct GRPCDirectoryService<T> {
    instance_name: String,
    grpc_client: DirectoryServiceClient<T>,
}

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

Fields

instance_name: String

grpc_client: DirectoryServiceClient<T>

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

Implementations

impl<T> GRPCDirectoryService<T>

pub fn from_client( instance_name: String, grpc_client: DirectoryServiceClient<T>, ) -> Self

construct a GRPCDirectoryService from a proto::directory_service_client::DirectoryServiceClient. panics if called outside the context of a tokio runtime.

Trait Implementations

impl<T: Clone> Clone for GRPCDirectoryService<T>

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

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<T> DirectoryService for GRPCDirectoryService<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 get<'life0, 'life1, 'async_trait>( &'life0 self, digest: &'life1 B3Digest, ) -> Pin<Box<dyn Future<Output = Result<Option<Directory>, Error>> + Send + 'async_trait>>

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

Looks up a single Directory message by its digest. The returned Directory message must be valid. In case the directory is not found, Ok(None) is returned.

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

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

Uploads a single Directory message, and returns the calculated digest, or an error. An error must also be returned if the message is not valid.

fn get_recursive( &self, root_directory_digest: &B3Digest, ) -> BoxStream<'static, Result<Directory, Error>>

Looks up a closure of Directory. Ideally this would be a impl Stream<Item = Result<Directory, Error>>, and we’d be able to add a default implementation for it here, but we can’t have that yet.

fn put_multiple_start(&self) -> Box<dyn DirectoryPutter + 'static>

where Self: Clone,

Allows persisting a closure of Directory, which is a graph of connected Directory messages.