Struct LifecycleService 

pub struct LifecycleService { /* private fields */ }

Implementations

impl LifecycleService

pub fn new(ctx: ServiceContext) -> Self

impl LifecycleService

pub async fn list_flows( &self, req: ListFlowsRequest, ) -> Result<LifecycleFlowsList>

pub async fn get_flow(&self, flow_id: &str) -> Result<LifecycleFlowSummary>

pub async fn list_flows_by_tx( &self, req: ListFlowsByTxRequest, ) -> Result<LifecycleFlowsList>

pub async fn get_flow_by_tx( &self, req: ListFlowsByTxRequest, ) -> Result<LifecycleFlowSummary>

pub async fn subscribe_open_flows( &self, account_id: Option<&str>, ) -> Result<TypedSubscription<LifecycleFlowSummary>>

Subscribe to open lifecycle flow summaries.

When account_id is Some, uses the private account channel; otherwise the public open-flows channel (Go SubscribeOpenFlows parity).

pub async fn subscribe_flow_detail( &self, flow_id: &str, ) -> Result<TypedSubscription<LifecycleFlowSummary>>

Subscribe to a single flow’s detail updates (requires realtime feature).

Trait Implementations

impl Clone for LifecycleService

fn clone(&self) -> LifecycleService

Returns a duplicate of the value.

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

Performs copy-assignment from source.