Struct PostgresBackend 

pub struct PostgresBackend { /* private fields */ }

Server backend that keeps file metadata in Postgres and object bytes in the selected store.

Implementations

impl PostgresBackend

pub async fn new( root: PathBuf, public_base_url: String, chunk_size: NonZeroUsize, index_postgres_url: &str, ) -> Result<Self, ServerError>

Creates a Postgres-backed metadata backend.

Errors

Returns ServerError when the local chunk store cannot initialize or the Postgres pool configuration is invalid.

pub fn public_base_url(&self) -> &str

Returns the public base URL used in generated download links.

impl PostgresBackend

pub async fn ready(&self) -> Result<(), ServerError>

Verifies that the local object store and required Postgres metadata tables are reachable.

Errors

Returns ServerError when local chunk storage is unreadable, the Postgres pool cannot execute queries, or required metadata tables are missing.

pub async fn reconstruction( &self, file_id: &str, content_hash: Option<&str>, requested_range: Option<ByteRange>, repository_scope: Option<&RepositoryScope>, ) -> Result<FileReconstructionResponse, ServerError>

Loads reconstruction metadata for a file.

Errors

Returns ServerError when the file identifier is invalid or the record is missing or unreadable.

pub async fn file_total_bytes( &self, file_id: &str, content_hash: Option<&str>, repository_scope: Option<&RepositoryScope>, ) -> Result<u64, ServerError>

Loads the logical byte length for a file version.

Errors

Returns ServerError when the file identifier is invalid or the record is missing or unreadable.

pub async fn download_file( &self, file_id: &str, content_hash: Option<&str>, repository_scope: Option<&RepositoryScope>, ) -> Result<Vec<u8>, ServerError>

Reconstructs a file into a contiguous byte vector.

Errors

Returns ServerError when metadata or chunk bytes cannot be read.

pub async fn read_chunk(&self, hash_hex: &str) -> Result<Vec<u8>, ServerError>

Reads a stored chunk by hash.

Errors

Returns ServerError when the hash is invalid or the chunk is missing.

pub async fn chunk_length(&self, hash_hex: &str) -> Result<u64, ServerError>

Loads the stored byte length for a chunk object.

Errors

Returns ServerError when the hash is invalid or the chunk is missing.

pub async fn read_chunk_for_file_version( &self, hash_hex: &str, file_id: &str, content_hash: &str, repository_scope: Option<&RepositoryScope>, ) -> Result<Vec<u8>, ServerError>

Reads a stored chunk only when it is reachable from a concrete file version.

Errors

Returns ServerError when the hash, file identifier, or content hash are invalid, when the file version is missing, or when the chunk is not referenced by that version.

pub async fn xorb_length(&self, hash_hex: &str) -> Result<u64, ServerError>

Loads the stored byte length for a serialized xorb object.

Errors

Returns ServerError when the hash is invalid or the xorb is missing.

impl PostgresBackend

pub async fn stats(&self) -> Result<ServerStatsResponse, ServerError>

Returns backend storage stats.

Errors

Returns ServerError when metadata inventory cannot be loaded.

impl PostgresBackend

pub async fn upload_file( &self, file_id: &str, body: Bytes, repository_scope: Option<&RepositoryScope>, ) -> Result<UploadFileResponse, ServerError>

Stores a file version as deduplicated content chunks.

Errors

Returns ServerError when file identifier validation, chunk persistence, or metadata persistence fails.

pub async fn upload_xorb( &self, expected_hash: &str, body: Bytes, ) -> Result<XorbUploadResponse, ServerError>

Stores a raw xorb body under its content hash.

Errors

Returns ServerError when the supplied hash is invalid, the body hash does not match, or persistence fails.

Trait Implementations

impl Clone for PostgresBackend

fn clone(&self) -> PostgresBackend

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for PostgresBackend

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.