Struct PostgresJobRepository 

pub struct PostgresJobRepository { /* private fields */ }

Durable PostgreSQL implementation of JobRepository.

PostgreSQL identity columns issue instance and execution identifiers, so allocations remain collision-free across process restarts.

Implementations

impl PostgresJobRepository

pub async fn connect( config: PostgresConfig, clock: Arc<dyn Clock>, ) -> Result<Self, RepositoryError>

Opens and verifies a repository-owned PostgreSQL pool.

Errors

Returns a redacted unavailable or schema-version failure. Call PostgresMigrator::migrate separately with a migrator identity.

pub async fn close(&self) -> Result<(), RepositoryError>

Closes the repository pool within the configured deadline.

Errors

Returns unavailable when active borrowers do not release the pool before the deadline.

Trait Implementations

impl Clone for PostgresJobRepository

fn clone(&self) -> PostgresJobRepository

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for PostgresJobRepository

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

Formats the value using the given formatter.

impl JobRepository for PostgresJobRepository

fn descriptor(&self) -> RepositoryDescriptor

Schema 3 provides every capability this milestone defines. The pool size above is a throughput setting and is deliberately absent here: capabilities describe what the deployment can do, not how fast.

fn connection_capacity(&self) -> u32

Returns the finite connection budget available to one execution tree.

fn begin<'a>( &'a self, ) -> BoxFuture<'a, Result<Box<dyn RepositoryUnitOfWork + 'a>, RepositoryError>>

Begins a repository-owned unit of work.