Trait tvix_castore::blobservice::BlobWriter

pub trait BlobWriter:
    AsyncWrite
    + Send
    + Unpin {
    // Required method
    fn close<'life0, 'async_trait>(
        &'life0 mut self,
    ) -> Pin<Box<dyn Future<Output = Result<B3Digest>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
}

A tokio::io::AsyncWrite that the user needs to close() afterwards for persist. On success, it returns the digest of the written blob.

Required Methods

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

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

Signal there’s no more data to be written, and return the digest of the contents written.

Closing a already-closed BlobWriter is a no-op.

Implementors

impl BlobWriter for MemoryBlobWriter

impl<W, Fut> BlobWriter for ObjectStoreBlobWriter<W, Fut>

where W: AsyncWrite + Send + Unpin, Fut: Future<Output = Result<B3Digest>> + Send + Unpin,

impl<W: AsyncWrite + Send + Sync + Unpin + 'static> BlobWriter for GRPCBlobWriter<W>