Struct S3Storage 

pub struct S3Storage { /* private fields */ }

S3-compatible object storage backend.

Implementations

impl S3Storage

pub fn new( bucket: String, region: String, endpoint: Option<String>, ) -> Result<S3Storage, StoreError>

Create a new S3 storage backend.

Uses AWS default credential chain (IRSA, env vars, instance profile). Set endpoint for non-AWS S3-compatible services (MinIO, RustFS, R2).

pub fn bucket(&self) -> &str

Return the bucket name.

pub fn region(&self) -> &str

Return the region.

pub fn endpoint(&self) -> Option<&str>

Return the custom endpoint, if any.

Trait Implementations

impl NarRefIndex for S3Storage

The reverse index as one zero-byte object per edge, under nar-refs/.

A LIST bounded by the edge prefix is the referrer set. Recording is a blind PUT of a key that names its own content, so it is idempotent and two concurrent pushes cannot lose an edge — which a read-modify-write of a set-valued object could, and S3 gives no compare-and-swap to prevent it with.

fn record<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, nar_path: &'life1 str, hash: &'life2 str, ) -> Pin<Box<dyn Future<Output = Result<(), StoreError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, S3Storage: 'async_trait,

Record “hash’s narinfo advertises nar_path”. Idempotent.

fn forget<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, nar_path: &'life1 str, hash: &'life2 str, ) -> Pin<Box<dyn Future<Output = Result<(), StoreError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, S3Storage: 'async_trait,

Forget that edge. Idempotent — forgetting an absent edge is Ok(()).

fn referrers<'life0, 'life1, 'async_trait>( &'life0 self, nar_path: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Vec<String>, StoreError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, S3Storage: 'async_trait,

Every store-path hash whose narinfo advertises nar_path, sorted and deduplicated.

impl StorageBackend for S3Storage

fn nar_residency(&self) -> NarResidency

O(constant). Reads come off the object stream; writes go up as bounded multipart parts with at most [S3_MAX_INFLIGHT_PARTS] in flight.

fn put_nar_stream<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, nar_path: &'life1 str, src: &'life2 dyn NarSource, ) -> Pin<Box<dyn Future<Output = Result<(), StoreError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, S3Storage: 'async_trait,

Upload as a bounded multipart, aborting on any fault.

The abort matters for the same reason the local tier renames: a half-finished multipart is not a truncated object (S3 only publishes on complete), but it is billable storage that lingers until a lifecycle rule reaps it. Aborting turns a failed push into nothing at all.

fn get_narinfo<'life0, 'life1, 'async_trait>( &'life0 self, hash: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Option<String>, StoreError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, S3Storage: 'async_trait,

Retrieve narinfo text by store path hash.

fn put_narinfo_record<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, hash: &'life1 str, content: &'life2 str, ) -> Pin<Box<dyn Future<Output = Result<(), StoreError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, S3Storage: 'async_trait,

Store narinfo text keyed by store path hash — the record verb: one key, no index maintenance.

fn delete_narinfo_record<'life0, 'life1, 'async_trait>( &'life0 self, hash: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<(), StoreError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, S3Storage: 'async_trait,

Remove a narinfo record by store path hash. Idempotent; removing an absent narinfo is Ok(()).

fn delete_nar_record<'life0, 'life1, 'async_trait>( &'life0 self, nar_path: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<(), StoreError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, S3Storage: 'async_trait,

Remove one NAR blob by its relative path. Idempotent.

fn nar_ref_index(&self) -> &dyn NarRefIndex

This backend’s narhash → store-hash reverse index.

fn get_nar<'life0, 'life1, 'async_trait>( &'life0 self, nar_path: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Option<Vec<u8>>, StoreError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, S3Storage: 'async_trait,

Retrieve a NAR blob by its relative path.

fn put_nar<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, nar_path: &'life1 str, data: &'life2 [u8], ) -> Pin<Box<dyn Future<Output = Result<(), StoreError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, S3Storage: 'async_trait,

Store a NAR blob at the given relative path.

fn get_nar_stream<'life0, 'life1, 'async_trait>( &'life0 self, nar_path: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Option<Pin<Box<dyn Stream<Item = Result<Bytes, StoreError>> + Send>>>, StoreError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, S3Storage: 'async_trait,

Retrieve a NAR blob as a bounded-chunk stream.

fn list_narinfos<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Vec<String>, StoreError>> + Send + 'async_trait>>

where 'life0: 'async_trait, S3Storage: 'async_trait,

List all stored narinfo hashes.

fn put_narinfo<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, hash: &'life1 str, content: &'life2 str, ) -> Pin<Box<dyn Future<Output = Result<(), StoreError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, Self: 'async_trait,

Store narinfo text and record the reverse edge it creates.

fn advertised_nar<'life0, 'life1, 'async_trait>( &'life0 self, hash: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Option<String>, StoreError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, Self: 'async_trait,

The NAR path this store path’s narinfo advertises — resolved, never guessed.

fn delete<'life0, 'life1, 'async_trait>( &'life0 self, hash: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<(), StoreError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, Self: 'async_trait,

Delete a store path’s narinfo, and its NAR only if nothing else advertises that NAR.

fn reindex_nar_refs<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<usize, StoreError>> + Send + 'async_trait>>

where 'life0: 'async_trait, Self: 'async_trait,

Rebuild every reverse edge from the narinfos this backend holds, and return the number of edges recorded.

fn wipe_all<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<usize, StoreError>> + Send + 'async_trait>>

where 'life0: 'async_trait, Self: 'async_trait,

Clear EVERY narinfo and NAR blob from this backend. Returns the number of narinfos removed.