Struct StorageMetadataRepo 

pub struct StorageMetadataRepo { /* private fields */ }

Storage metadata repository backed by PostgreSQL.

Implementations

impl StorageMetadataRepo

pub const fn new(pool: PgPool) -> Self

Create a new repository wrapping the given connection pool.

pub async fn insert(&self, row: &NewStorageObject) -> Result<i64, FraiseQLError>

Insert a new object metadata row, returning the generated primary key.

Errors

Returns FraiseQLError::File if the database query fails (e.g. duplicate (bucket, key) pair).

pub async fn get( &self, bucket: &str, key: &str, ) -> Result<Option<StorageMetadataRow>, FraiseQLError>

Look up an object by bucket and key.

Errors

Returns FraiseQLError::File if the database query fails.

pub async fn delete( &self, bucket: &str, key: &str, ) -> Result<bool, FraiseQLError>

Delete an object metadata row by bucket and key.

Returns true if a row was actually deleted, false if no matching row existed.

Errors

Returns FraiseQLError::File if the database query fails.

pub async fn list( &self, bucket: &str, prefix: Option<&str>, limit: u32, offset: u32, ) -> Result<Vec<StorageMetadataRow>, FraiseQLError>

List objects in a bucket, optionally filtered by key prefix.

Results are ordered by key ascending. Use limit and offset for pagination.

Errors

Returns FraiseQLError::File if the database query fails.

pub async fn upsert(&self, row: &NewStorageObject) -> Result<i64, FraiseQLError>

Insert or update an object metadata row (upsert on (bucket, key)).

On conflict, updates content_type, size_bytes, etag, and updated_at.

Errors

Returns FraiseQLError::File if the database query fails.