Module tvix_castore::blobservice::object_store

Structs

• ObjectStoreBlobService
  Uses any object storage supported by the object_store crate to provide a tvix-castore BlobService.
• ObjectStoreBlobServiceConfig
• ObjectStoreBlobWriter
  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.

Functions

• chunk_and_upload 🔒
  Reads blob contents from a AsyncRead, chunks and uploads them. On success, returns a StatBlobResponse pointing to the individual chunks.
• default_avg_chunk_size 🔒
• derive_blob_path 🔒
• derive_chunk_path 🔒
• upload_chunk 🔒
  upload chunk if it doesn’t exist yet.