Struct tvix_castore::blobservice::object_store::ObjectStoreBlobWriter

pub struct ObjectStoreBlobWriter<W, Fut>
where
    W: AsyncWrite,
    Fut: Future,
{
    writer: Option<W>,
    fut: Option<Fut>,
    fut_output: Option<Result<B3Digest>>,
}

Takes care of blob uploads. All writes are relayed to self.writer, and we continuously poll the future (which will internally read from the other side of the pipe and upload chunks). Our BlobWriter::close() needs to drop self.writer, so the other side will read EOF and can finalize the blob. The future should then resolve and return the blob digest.

Fields

writer: Option<W>

fut: Option<Fut>

fut_output: Option<Result<B3Digest>>

Trait Implementations

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

where W: AsyncWrite + Send + Unpin, Fut: Future,

fn poll_write( self: Pin<&mut Self>, cx: &mut Context<'_>, buf: &[u8], ) -> Poll<Result<usize, Error>>

Attempt to write bytes from buf into the object.

fn poll_flush( self: Pin<&mut Self>, cx: &mut Context<'_>, ) -> Poll<Result<(), Error>>

Attempts to flush the object, ensuring that any buffered data reach their destination.

fn poll_shutdown( self: Pin<&mut Self>, _cx: &mut Context<'_>, ) -> Poll<Result<(), Error>>

Initiates or attempts to shut down this writer, returning success when the I/O connection has completely shut down.

fn poll_write_vectored( self: Pin<&mut Self>, cx: &mut Context<'_>, bufs: &[IoSlice<'_>], ) -> Poll<Result<usize, Error>>

Like poll_write, except that it writes from a slice of buffers.

fn is_write_vectored(&self) -> bool

Determines if this writer has an efficient poll_write_vectored implementation.

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

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

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.

impl<'__pin, W, Fut> Unpin for ObjectStoreBlobWriter<W, Fut>

where __Origin<'__pin, W, Fut>: Unpin, W: AsyncWrite, Fut: Future,