Module object_store 

Modules

aws 🔒 cloud

Custom AWS logic to configure the AWS object_store. Upstream doesn’t support the AWS credential chain.

Structs

ObjectStoreBlobService

Uses any object storage supported by the object_store crate to provide a snix-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.

Constants

CONCURRENT_CHUNK_UPLOADS 🔒

The number of chunks that will be uploaded in parallel, per blob.

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.