diff options
| author | Florian Klink <flokli@flokli.de> | 2024-02-01T21·46+0200 |
|---|---|---|
| committer | clbot <clbot@tvl.fyi> | 2024-02-10T14·24+0000 |
| commit | d10c5309bcb483776c599a7576f57142dc7644b2 (patch) | |
| tree | 60a8d3ac728851900b4331b27b0c75b5233200c3 /tvix/castore/src/blobservice/mod.rs | |
| parent | 8699a2b945c4901165d7d7041b3ae639f752e392 (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.rs | 2 |
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; |