Struct MemoryRunLedger 

pub struct MemoryRunLedger { /* private fields */ }

In-memory run ledger backed by a HashMap<RunId, RunState>.

Implementations

impl MemoryRunLedger

pub fn new() -> Self

Trait Implementations

impl Debug for MemoryRunLedger

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

Formats the value using the given formatter.

impl Default for MemoryRunLedger

fn default() -> MemoryRunLedger

Returns the “default value” for a type.

impl RunLedger for MemoryRunLedger

fn create_run<'life0, 'life1, 'async_trait>( &'life0 self, spec_digest: &'life1 ContentDigest, metadata: RunMetadata, ) -> Pin<Box<dyn Future<Output = StorageResult<RunId>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Create a new run, returning its unique ID.

fn append_event<'life0, 'life1, 'async_trait>( &'life0 self, run_id: &'life1 RunId, event: RunEvent, ) -> Pin<Box<dyn Future<Output = StorageResult<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Append an event to an active run. Fails if the run is completed/failed.

fn complete_run<'life0, 'life1, 'async_trait>( &'life0 self, run_id: &'life1 RunId, summary: RunSummary, ) -> Pin<Box<dyn Future<Output = StorageResult<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Mark a run as completed with a summary.

fn fail_run<'life0, 'life1, 'async_trait>( &'life0 self, run_id: &'life1 RunId, summary: RunSummary, ) -> Pin<Box<dyn Future<Output = StorageResult<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Mark a run as failed with a summary.

fn cancel_run<'life0, 'life1, 'async_trait>( &'life0 self, run_id: &'life1 RunId, summary: RunSummary, ) -> Pin<Box<dyn Future<Output = StorageResult<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Mark a run as cancelled.

fn get_run<'life0, 'life1, 'async_trait>( &'life0 self, run_id: &'life1 RunId, ) -> Pin<Box<dyn Future<Output = StorageResult<RunRecord>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Retrieve a run record by ID.

fn get_events<'life0, 'life1, 'async_trait>( &'life0 self, run_id: &'life1 RunId, ) -> Pin<Box<dyn Future<Output = StorageResult<Vec<RunEvent>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Retrieve all events for a run, ordered by seq.

fn list_runs<'life0, 'life1, 'async_trait>( &'life0 self, spec_digest: Option<&'life1 ContentDigest>, ) -> Pin<Box<dyn Future<Output = StorageResult<Vec<RunRecord>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

List runs, optionally filtered by spec digest.