Struct tvix_store::pathinfoservice::grpc::GRPCPathInfoService

pub struct GRPCPathInfoService<T> {
    grpc_client: PathInfoServiceClient<T>,
}

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

Fields

grpc_client: PathInfoServiceClient<T>

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

Implementations

impl<T> GRPCPathInfoService<T>

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

construct a GRPCPathInfoService from a proto::path_info_service_client::PathInfoServiceClient. panics if called outside the context of a tokio runtime.

Trait Implementations

impl<T: Clone> Clone for GRPCPathInfoService<T>

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

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<T> NarCalculationService for GRPCPathInfoService<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 calculate_nar<'life0, 'life1, 'async_trait>( &'life0 self, root_node: &'life1 Node, ) -> Pin<Box<dyn Future<Output = Result<(u64, [u8; 32]), Error>> + Send + 'async_trait>>

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

Return the nar size and nar sha256 digest for a given root node. This can be used to calculate NAR-based output paths.

impl<T> PathInfoService for GRPCPathInfoService<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, 'async_trait>( &'life0 self, digest: [u8; 20], ) -> Pin<Box<dyn Future<Output = Result<Option<PathInfo>, Error>> + Send + 'async_trait>>

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

Retrieve a PathInfo message by the output digest.

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

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

Store a PathInfo message. Implementations MUST call validate and reject invalid messages.

fn list(&self) -> BoxStream<'static, Result<PathInfo, Error>>

Iterate over all PathInfo objects in the store. Implementations can decide to disallow listing.

fn nar_calculation_service(&self) -> Option<Box<dyn NarCalculationService>>

Returns a (more) suitable NarCalculationService. This can be used to offload NAR calculation to the remote side.