about summary refs log tree commit diff
path: root/tvix/castore/src/blobservice/mod.rs
diff options
context:
space:
mode:
authorFlorian Klink <flokli@flokli.de>2024-02-01T21·46+0200
committerclbot <clbot@tvl.fyi>2024-02-10T14·24+0000
commitd10c5309bcb483776c599a7576f57142dc7644b2 (patch)
tree60a8d3ac728851900b4331b27b0c75b5233200c3 /tvix/castore/src/blobservice/mod.rs
parent8699a2b945c4901165d7d7041b3ae639f752e392 (diff)
feat(tvix/castore/blobsvc): add Chunked{Blob,Reader} r/7494
These provide seekable access into a Blob for which we have more
granular chunking information.

There's no support for verified streaming in here yet, this simply
produces a stream of readers for each chunk, skipping irrelevant chunks
and data from the first chunk at the beginning.

A seek simply does produce a new reader using the same process.

Change-Id: I37f76b752adce027586770475435f3990a6dee0b
Reviewed-on: https://cl.tvl.fyi/c/depot/+/10731
Reviewed-by: Connor Brewster <cbrewster@hey.com>
Autosubmit: flokli <flokli@flokli.de>
Tested-by: BuildkiteCI
Diffstat (limited to 'tvix/castore/src/blobservice/mod.rs')
-rw-r--r--tvix/castore/src/blobservice/mod.rs2
1 files changed, 2 insertions, 0 deletions
diff --git a/tvix/castore/src/blobservice/mod.rs b/tvix/castore/src/blobservice/mod.rs
index fa6b87926ba1..eeb8b9649c1a 100644
--- a/tvix/castore/src/blobservice/mod.rs
+++ b/tvix/castore/src/blobservice/mod.rs
@@ -4,6 +4,7 @@ use tonic::async_trait;
 use crate::proto::stat_blob_response::ChunkMeta;
 use crate::B3Digest;
 
+mod chunked_reader;
 mod combinator;
 mod from_addr;
 mod grpc;
@@ -15,6 +16,7 @@ mod sled;
 #[cfg(test)]
 mod tests;
 
+pub use self::chunked_reader::ChunkedReader;
 pub use self::combinator::CombinedBlobService;
 pub use self::from_addr::from_addr;
 pub use self::grpc::GRPCBlobService;