Struct tvix_castore::directoryservice::grpc::GRPCPutter

pub struct GRPCPutter {
    rq: Option<(JoinHandle<Result<PutDirectoryResponse, Status>>, UnboundedSender<Directory>)>,
}

Allows uploading multiple Directory messages in the same gRPC stream.

Fields

rq: Option<(JoinHandle<Result<PutDirectoryResponse, Status>>, UnboundedSender<Directory>)>

Data about the current request - a handle to the task, and the tx part of the channel. The tx part of the pipe is used to send proto::Directory to the ongoing request. The task will yield a proto::PutDirectoryResponse once the stream is closed.

Trait Implementations

impl DirectoryPutter for GRPCPutter

fn close<'life0, 'async_trait>( &'life0 mut self ) -> Pin<Box<dyn Future<Output = Result<B3Digest, Error>> + Send + 'async_trait>>

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

Closes the stream for sending, and returns the value.

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

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

Put a individual Directory into the store. Error semantics and behaviour is up to the specific implementation of this trait. Due to bursting, the returned error might refer to an object previously sent via put.