Struct LibContext 

pub struct LibContext {
    pub db_pools: DbPools,
    pub persistence_ctx: Option<PersistenceContext>,
    pub flows: Mutex<BTreeMap<String, Arc<FlowContext>>>,
    pub app_namespace: String,
    pub ignore_target_drop_failures: bool,
    pub global_concurrency_controller: Arc<ConcurrencyController>,
}

Fields

db_pools: DbPools

persistence_ctx: Option<PersistenceContext>

flows: Mutex<BTreeMap<String, Arc<FlowContext>>>

app_namespace: String

ignore_target_drop_failures: bool

global_concurrency_controller: Arc<ConcurrencyController>

Implementations

impl LibContext

pub fn get_flow_context(&self, flow_name: &str) -> Result<Arc<FlowContext>>

pub fn remove_flow_context(&self, flow_name: &str)

pub fn require_persistence_ctx(&self) -> Result<&PersistenceContext>

pub fn require_builtin_db_pool(&self) -> Result<&PgPool>