Struct FlowGraphObserver 

pub struct FlowGraphObserver { /* private fields */ }

Implementations

impl FlowGraphObserver

pub fn new(runtime: Arc<Mutex<GraphRuntime>>) -> Self

pub fn runtime(&self) -> Arc<Mutex<GraphRuntime>>

pub async fn last_error(&self) -> Option<String>

pub async fn health(&self) -> FlowGraphHealthSnapshot

pub async fn project( &self, envelope: FlowEventEnvelope, ) -> Result<ExternalProjectionOutcome, RuntimeError>

pub async fn catch_up( &self, history: Vec<FlowEventEnvelope>, ) -> Result<usize, RuntimeError>

Replay committed Flow history in sequence order, applying only events not already represented by the restored graph cursor.

Trait Implementations

impl Clone for FlowGraphObserver

fn clone(&self) -> FlowGraphObserver

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl FlowEventObserver for FlowGraphObserver

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

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