Struct MultipartTable 

pub struct MultipartTable {
    db: Arc<Database>,
}

Typed wrapper around the multipart_active redb table.

Clone-safe: the inner Arc<Database> is cheap to clone.

Fields

db: Arc<Database>

Implementations

impl MultipartTable

pub fn new(db: Arc<Database>) -> Result<Self, AppError>

Create a MultipartTable bound to an existing redb Database.

This opens (and, if necessary, creates) the multipart_active table inside the provided database. Reusing the same Database instance as CacheStore avoids holding two file handles on cache.redb.

fn make_key(profile: &ProfileId, bucket: &BucketId, key: &str) -> String

pub fn record(&self, rec: &MultipartRecord) -> Result<(), AppError>

Insert or overwrite a MultipartRecord.

Overwrites any existing record for the same (profile, bucket, key).

pub fn remove( &self, profile: &ProfileId, bucket: &BucketId, key: &str, ) -> Result<(), AppError>

Delete the record for (profile, bucket, key).

No-op when the entry does not exist.

pub fn list_all(&self) -> Result<Vec<MultipartRecord>, AppError>

Return all active multipart upload records.

pub fn list_for_profile( &self, profile: &ProfileId, ) -> Result<Vec<MultipartRecord>, AppError>

Return all active records for profile.

pub fn find_by_upload_id( &self, upload_id: &str, ) -> Result<Option<MultipartRecord>, AppError>

Linear scan to find a record by its upload_id.

Used by the cleanup scanner (task 38) to correlate uploads reported by S3 list_multipart_uploads with brows3r bookkeeping records.

Trait Implementations

impl Clone for MultipartTable

fn clone(&self) -> MultipartTable

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.