Struct tvix_store::proto::GRPCPathInfoServiceWrapper

pub struct GRPCPathInfoServiceWrapper<PS, NS> {
    path_info_service: PS,
    nar_calculation_service: NS,
}

Fields

path_info_service: PS

nar_calculation_service: NS

Implementations

impl<PS, NS> GRPCPathInfoServiceWrapper<PS, NS>

pub fn new(path_info_service: PS, nar_calculation_service: NS) -> Self

Trait Implementations

impl<PS, NS> PathInfoService for GRPCPathInfoServiceWrapper<PS, NS>

where PS: Deref<Target = dyn PathInfoService> + Send + Sync + 'static, NS: NarCalculationService + Send + Sync + 'static,

type ListStream = Pin<Box<dyn Stream<Item = Result<PathInfo, Status>> + Send>>

Server streaming response type for the List method.

fn get<'life0, 'async_trait>( &'life0 self, request: Request<GetPathInfoRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<PathInfo>>> + Send + 'async_trait>>

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

Return a PathInfo message matching the criteria specified in the GetPathInfoRequest message.

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

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

Upload a PathInfo object to the remote end. It MUST not return until the PathInfo object has been written on the the remote end.

fn calculate_nar<'life0, 'async_trait>( &'life0 self, request: Request<Node>, ) -> Pin<Box<dyn Future<Output = Result<Response<CalculateNarResponse>>> + Send + 'async_trait>>

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

Calculate the NAR representation of the contents specified by the root_node. The calculation SHOULD be cached server-side for subsequent requests.

fn list<'life0, 'async_trait>( &'life0 self, _request: Request<ListPathInfoRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<Self::ListStream>, Status>> + Send + 'async_trait>>

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

Return a stream of PathInfo messages matching the criteria specified in ListPathInfoRequest.