Struct tvix_castore::blobservice::chunked_reader::ChunkedReader

pub struct ChunkedReader<BS> {
    chunked_blob: ChunkedBlob<BS>,
    r: Box<dyn AsyncRead + Unpin + Send>,
    pos: u64,
}

ChunkedReader provides a chunk-aware BlobReader, so allows reading and seeking into a blob. It internally holds a ChunkedBlob, which is storing chunk information able to emit a reader seeked to a specific position whenever we need to seek.

Fields

chunked_blob: ChunkedBlob<BS>

r: Box<dyn AsyncRead + Unpin + Send>

pos: u64

Implementations

impl<BS> ChunkedReader<BS>

where BS: AsRef<dyn BlobService> + Clone + 'static + Send,

pub fn from_chunks( chunks_it: impl Iterator<Item = (B3Digest, u64)>, blob_service: BS, ) -> Self

Construct a new ChunkedReader, by retrieving a list of chunks (their blake3 digests and chunk sizes)

Trait Implementations

impl<BS> AsyncRead for ChunkedReader<BS>

where BS: AsRef<dyn BlobService> + Clone + 'static,

fn poll_read( self: Pin<&mut Self>, cx: &mut Context<'_>, buf: &mut ReadBuf<'_>, ) -> Poll<Result<()>>

Attempts to read from the AsyncRead into buf.

impl<BS> AsyncSeek for ChunkedReader<BS>

where BS: AsRef<dyn BlobService> + Clone + Send + 'static,

fn start_seek(self: Pin<&mut Self>, position: SeekFrom) -> Result<()>

Attempts to seek to an offset, in bytes, in a stream.

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

Waits for a seek operation to complete.

impl<BS> BlobReader for ChunkedReader<BS>

where BS: Send + Clone + 'static + AsRef<dyn BlobService>,

ChunkedReader implements BlobReader.

impl<'__pin, BS> Unpin for ChunkedReader<BS>

where __Origin<'__pin, BS>: Unpin,