Struct LedgerHandler 

pub struct LedgerHandler<L: RunLedger> { /* private fields */ }

Implements oxidizedgraph’s EventHandler to persist graph lifecycle events into an AIVCS RunLedger.

The handler:

• Creates a run on on_start()
• Maps each Event to a RunEvent and appends it on handle()
• Completes or fails the run on on_stop() based on whether errors occurred

Implementations

impl<L: RunLedger> LedgerHandler<L>

pub fn new( ledger: Arc<L>, spec_digest: ContentDigest, metadata: RunMetadata, ) -> Self

Create a new handler that will persist events to the given ledger.

pub async fn run_id(&self) -> Option<RunId>

Get the run ID (available after on_start is called).

pub fn saw_error(&self) -> bool

Whether any error events have been observed.

pub fn seq(&self) -> u64

Current sequence number.

Trait Implementations

impl<L: RunLedger + 'static> EventHandler for LedgerHandler<L>

fn on_start<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

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

Called when the handler is started

fn handle<'life0, 'life1, 'async_trait>( &'life0 self, event: &'life1 Event, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

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

Handle an event

fn on_stop<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

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

Called when the handler is stopped