Struct JobExplorer 

pub struct JobExplorer<S> { /* private fields */ }

The portable bounded inspection service.

The service owns page bounds, cursor identity, traversal ceilings, and the encoded response bound. The adapter owns one statement per page.

Implementations

impl<S: ExplorerRepository> JobExplorer<S>

pub const fn new(source: S) -> Self

Wraps one bounded read port.

pub fn with_event_sink(self, sink: Arc<dyn TelemetryEventSink>) -> Self

Attaches a non-authoritative, panic-isolated telemetry sink.

pub const fn source(&self) -> &S

Borrows the underlying read port.

pub async fn list_job_names( &self, request: &PageRequest, ) -> Result<Page<JobName>, ExplorerError>

Lists registered job names in byte order.

Errors

Returns a typed cursor, bound, timeout, or repository failure.

pub async fn list_instances( &self, job_name: &JobName, request: &PageRequest, ) -> Result<Page<JobInstanceProjection>, ExplorerError>

Lists instances of one job name, newest identity first.

Errors

Returns a typed cursor, bound, timeout, or repository failure.

pub async fn list_executions( &self, job_instance_id: JobInstanceId, request: &PageRequest, ) -> Result<Page<JobExecutionProjection>, ExplorerError>

Lists executions of one instance, newest attempt first.

Errors

Returns a typed cursor, bound, timeout, or repository failure.

pub async fn get_execution( &self, job_execution_id: JobExecutionId, ) -> Result<Option<JobExecutionProjection>, ExplorerError>

Reads one execution projection.

Errors

Returns a typed timeout or repository failure.

pub async fn list_step_executions( &self, job_execution_id: JobExecutionId, request: &PageRequest, ) -> Result<Page<StepExecutionProjection>, ExplorerError>

Lists step executions of one job execution.

Errors

Returns a typed cursor, bound, timeout, or repository failure.

pub async fn list_unresolved_executions( &self, minimum_age: Duration, request: &PageRequest, ) -> Result<Page<JobExecutionProjection>, ExplorerError>

Lists non-terminal executions older than an explicit age bound.

Errors

Returns ExplorerError::AgeBoundTooSmall below MIN_UNRESOLVED_AGE, or a typed cursor, bound, timeout, or repository failure.

pub async fn list_recovery_decisions( &self, job_execution_id: JobExecutionId, request: &PageRequest, ) -> Result<Page<RecoveryDecision>, ExplorerError>

Lists recovery decisions of one job execution.

Errors

Returns a typed cursor, bound, timeout, or repository failure.

pub async fn list_flow_decisions( &self, job_execution_id: JobExecutionId, request: &PageRequest, ) -> Result<Page<FlowDecision>, ExplorerError>

Lists flow decisions of one job execution in sequence order.

Errors

Returns a typed cursor, bound, timeout, or repository failure.

pub async fn list_step_partitions( &self, step_execution_id: StepExecutionId, request: &PageRequest, ) -> Result<Page<StepPartitionProjection>, ExplorerError>

Lists partitions of one partitioned step execution.

Errors

Returns a typed cursor, bound, timeout, or repository failure.

pub async fn list_operator_requests( &self, job_execution_id: JobExecutionId, request: &PageRequest, ) -> Result<Page<OperatorRecord>, ExplorerError>

Lists audited operator requests for one job execution.

Errors

Returns a typed cursor, bound, timeout, or repository failure.

Trait Implementations

impl<S: Clone> Clone for JobExplorer<S>

fn clone(&self) -> JobExplorer<S>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<S: Debug> Debug for JobExplorer<S>

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

Formats the value using the given formatter.