Struct InMemoryRuntime 

pub struct InMemoryRuntime {
    pub job_store: InMemoryJobStore,
    pub recurring_store: InMemoryRecurringStore,
    pub outbox_store: InMemoryOutboxStore,
    pub job_attempt_store: InMemoryJobAttemptStore,
    /* private fields */
}

Fields

job_store: InMemoryJobStore

recurring_store: InMemoryRecurringStore

outbox_store: InMemoryOutboxStore

job_attempt_store: InMemoryJobAttemptStore

Implementations

impl InMemoryRuntime

pub fn new() -> Self

pub fn with_dependencies( clock: Arc<dyn Clock>, id_generator: Arc<dyn IdGenerator>, ) -> Self

pub fn with_dependencies_and_metrics( clock: Arc<dyn Clock>, id_generator: Arc<dyn IdGenerator>, metrics: Arc<dyn RuntimeMetrics>, ) -> Self

pub fn with_dependencies_and_telemetry( clock: Arc<dyn Clock>, id_generator: Arc<dyn IdGenerator>, metrics: Arc<dyn RuntimeMetrics>, tracing: Arc<dyn RuntimeTracing>, ) -> Self

pub fn replace_telemetry( &mut self, metrics: Arc<dyn RuntimeMetrics>, tracing: Arc<dyn RuntimeTracing>, )

pub fn tracing(&self) -> Arc<dyn RuntimeTracing>

pub fn configure_retention_policy(&self, policy: RetentionPolicy) -> Result<()>

pub fn register_handler<H: JobHandler + 'static>( &self, handler: H, ) -> Result<()>

pub fn register_event_publisher<P: EventPublisher + 'static>( &self, publisher: P, ) -> Result<()>

pub fn configure_outbox_publish_policy( &self, policy: OutboxPublishPolicy, ) -> Result<()>

pub async fn enqueue(&self, job: NewJob) -> Result<()>

pub async fn register_recurring( &self, definition: RecurringDefinition, ) -> Result<()>

pub async fn list_job_attempts(&self, job_id: &str) -> Result<Vec<JobAttempt>>

pub async fn list_attempts_by_guardrail_code( &self, guardrail_code: &str, ) -> Result<Vec<JobAttempt>>

pub async fn list_attempts_by_execution_id( &self, execution_id: &str, ) -> Result<Vec<JobAttempt>>

pub async fn list_lineage_events( &self, job_id: &str, ) -> Result<Vec<OutboxEvent>>

pub async fn list_lineage_events_by_execution_id( &self, execution_id: &str, ) -> Result<Vec<OutboxEvent>>

pub async fn list_lineage_events_by_thread_id( &self, thread_id: &str, ) -> Result<Vec<OutboxEvent>>

pub async fn investigate_lineage( &self, query: RuntimeLineageQuery, ) -> Result<RuntimeLineageReport>

pub async fn get_replay_report(&self, job_id: &str) -> Result<ReplayReport>

pub async fn process_once_now( &self, queue: &str, worker_id: &str, ) -> Result<Option<String>>

pub async fn replay_dead_letter_now(&self, job_id: &str) -> Result<bool>

pub async fn publish_pending_events_now(&self, limit: usize) -> Result<usize>

pub async fn materialize_recurring_now( &self, scheduler_id: &str, ) -> Result<usize>

pub async fn prune_terminal_records( &self, cutoff: DateTime<Utc>, ) -> Result<RetentionPruneReport>

pub async fn enforce_retention( &self, now: DateTime<Utc>, ) -> Result<RetentionPruneReport>

pub async fn enforce_retention_now(&self) -> Result<RetentionPruneReport>

pub async fn materialize_recurring( &self, now: DateTime<Utc>, scheduler_id: &str, ) -> Result<usize>

pub async fn process_once( &self, queue: &str, worker_id: &str, now: DateTime<Utc>, ) -> Result<Option<String>>

pub async fn replay_dead_letter( &self, job_id: &str, now: DateTime<Utc>, ) -> Result<bool>

pub async fn publish_pending_events( &self, limit: usize, now: DateTime<Utc>, ) -> Result<usize>

Trait Implementations

impl Clone for InMemoryRuntime

fn clone(&self) -> InMemoryRuntime

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Default for InMemoryRuntime

fn default() -> Self

Returns the “default value” for a type.