Struct TenantRuntime 

pub struct TenantRuntime { /* private fields */ }

Runtime bundle for a tenant pack.

Implementations

impl TenantRuntime

pub async fn load( pack_path: &Path, config: Arc<HostConfig>, mocks: Option<Arc<MockLayer>>, archive_source: Option<&Path>, digest: Option<String>, wasi_policy: Arc<RunnerWasiPolicy>, session_host: Arc<dyn SessionHost>, session_store: Arc<dyn SessionStore>, state_store: Arc<dyn StateStore>, state_host: Arc<dyn StateHost>, secrets_manager: Arc<dyn SecretsManager>, ) -> Result<Arc<TenantRuntime>, Error>

pub async fn from_packs( config: Arc<HostConfig>, packs: Vec<(Arc<PackRuntime>, Option<String>)>, mocks: Option<Arc<MockLayer>>, session_host: Arc<dyn SessionHost>, session_store: Arc<dyn SessionStore>, _state_store: Arc<dyn StateStore>, state_host: Arc<dyn StateHost>, secrets_manager: Arc<dyn SecretsManager>, ) -> Result<Arc<TenantRuntime>, Error>

pub fn tenant(&self) -> &str

pub fn config(&self) -> &Arc<HostConfig>

pub fn main_pack(&self) -> &Arc<PackRuntime>

pub fn pack(&self) -> Arc<PackRuntime>

pub fn overlays(&self) -> Vec<Arc<PackRuntime>>

pub fn engine(&self) -> &Arc<FlowEngine>

pub fn state_machine(&self) -> &Arc<StateMachineRuntime>

pub fn http_client(&self) -> &Client

pub fn digest(&self) -> Option<&str>

pub fn overlay_digests(&self) -> Vec<Option<String>>

pub fn required_secrets(&self) -> Vec<SecretRequirement>

pub fn missing_secrets(&self) -> Vec<SecretRequirement>

pub fn telegram_cache(&self) -> &Mutex<RawMutex, LruCache<i64, StatusCode>>

pub fn webhook_cache(&self) -> &Mutex<RawMutex, LruCache<String, Value>>

pub fn messaging_rate(&self) -> &Mutex<RawMutex, RateLimiter>

pub fn mocks(&self) -> Option<&Arc<MockLayer>>

pub fn register_timers(&self, handles: Vec<JoinHandle<()>>)

pub fn get_secret(&self, key: &str) -> Result<String, Error>

Trait Implementations

impl Drop for TenantRuntime

fn drop(&mut self)

Executes the destructor for this type.