Struct FlowContext 

pub struct FlowContext {
    pub flow: Arc<AnalyzedFlow>,
    pub query_handlers: RwLock<HashMap<String, QueryHandlerContext>>,
    /* private fields */
}

Fields

flow: Arc<AnalyzedFlow>

query_handlers: RwLock<HashMap<String, QueryHandlerContext>>

Implementations

impl FlowContext

pub fn flow_name(&self) -> &str

pub async fn new( flow: Arc<AnalyzedFlow>, existing_flow_ss: Option<&FlowSetupState<ExistingMode>>, ) -> Result<Self>

pub async fn use_execution_ctx( &self, ) -> Result<RwLockReadGuard<'_, FlowExecutionContext>>

pub async fn use_owned_execution_ctx( &self, ) -> Result<OwnedRwLockReadGuard<FlowExecutionContext>>

pub fn get_execution_ctx_for_setup(&self) -> &RwLock<FlowExecutionContext>