Struct InMemoryExplorer 

pub struct InMemoryExplorer { /* private fields */ }

The bounded keyset read port of InMemoryJobRepository.

The reference explorer reads a consistent snapshot of process-local state. It records no job/step execution context or checkpoint, so those projection fields are absent rather than guessed. Partition plans retain their bounded contexts and expose only redacted descriptors. Its unresolved-execution age bound uses the injected facade clock, because a process-local repository has no separate server time.

Implementations

impl InMemoryExplorer

pub fn new(repository: &InMemoryJobRepository) -> Self

Binds one in-memory repository’s state to the explorer port.

Trait Implementations

impl Clone for InMemoryExplorer

fn clone(&self) -> InMemoryExplorer

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for InMemoryExplorer

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

Formats the value using the given formatter.

impl ExplorerRepository for InMemoryExplorer

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 InMemoryExplorer

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.