Struct PostgresExplorer 

pub struct PostgresExplorer { /* private fields */ }

The bounded keyset read port of PostgresJobRepository.

Each page is one statement executed under the configured statement timeout and the adapter’s ordinary read committed isolation. No page takes a lock or participates in a chunk transaction, and cross-page snapshot isolation is not provided.

The unresolved-execution age bound compares the durable updated_at column against repository server time. It never consults the inspecting process’s wall clock and never updates a row.

Implementations

impl PostgresExplorer

pub const fn new(repository: PostgresJobRepository) -> Self

Binds one durable repository to the bounded read port.

Trait Implementations

impl Clone for PostgresExplorer

fn clone(&self) -> PostgresExplorer

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for PostgresExplorer

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

Formats the value using the given formatter.

impl ExplorerRepository for PostgresExplorer

fn identity_ceiling<'a>( &'a self, query: &'a ExplorerQuery, ) -> BoxFuture<'a, Result<u64, ExplorerError>>

Captures the exclusive identity ceiling for one traversal.

fn job_names<'a>( &'a self, window: &'a QueryWindow, ) -> BoxFuture<'a, Result<Vec<JobName>, ExplorerError>>

Reads registered job names in byte order.

fn instances<'a>( &'a self, job_name: &'a JobName, window: &'a QueryWindow, ) -> BoxFuture<'a, Result<Vec<JobInstanceProjection>, ExplorerError>>

Reads instances of one job name, newest identity first.

fn executions<'a>( &'a self, job_instance_id: JobInstanceId, window: &'a QueryWindow, ) -> BoxFuture<'a, Result<Vec<JobExecutionProjection>, ExplorerError>>

Reads executions of one instance, newest attempt first.

fn execution( &self, job_execution_id: JobExecutionId, ) -> BoxFuture<'_, Result<Option<JobExecutionProjection>, ExplorerError>>

Reads one execution projection.

fn step_executions<'a>( &'a self, job_execution_id: JobExecutionId, window: &'a QueryWindow, ) -> BoxFuture<'a, Result<Vec<StepExecutionProjection>, ExplorerError>>

Reads step executions of one job execution.

fn unresolved_executions<'a>( &'a self, minimum_age: Duration, window: &'a QueryWindow, ) -> BoxFuture<'a, Result<Vec<JobExecutionProjection>, ExplorerError>>

Reads non-terminal executions older than minimum_age.

fn recovery_decisions<'a>( &'a self, job_execution_id: JobExecutionId, window: &'a QueryWindow, ) -> BoxFuture<'a, Result<Vec<RecoveryDecision>, ExplorerError>>

Reads recovery decisions of one job execution.

fn flow_decisions<'a>( &'a self, job_execution_id: JobExecutionId, window: &'a QueryWindow, ) -> BoxFuture<'a, Result<Vec<FlowDecision>, ExplorerError>>

Reads flow decisions of one job execution in sequence order.

fn step_partitions<'a>( &'a self, step_execution_id: StepExecutionId, window: &'a QueryWindow, ) -> BoxFuture<'a, Result<Vec<StepPartitionProjection>, ExplorerError>>

Reads partitions of one partitioned step execution.

fn operator_requests<'a>( &'a self, job_execution_id: JobExecutionId, window: &'a QueryWindow, ) -> BoxFuture<'a, Result<Vec<OperatorRecord>, ExplorerError>>

Reads audited operator requests for one job execution.

impl RecoveryRepository for PostgresExplorer

fn recovery_snapshot<'a>( &'a self, execution_id: JobExecutionId, current_owner: &'a OwnerToken, ) -> BoxFuture<'a, Result<RecoverySnapshot, RepositoryError>>

Reads one value-redacted snapshot without changing durable state.