Struct PackRuntime 

pub struct PackRuntime { /* private fields */ }

Implementations

impl PackRuntime

pub async fn load( path: impl AsRef<Path>, config: Arc<HostConfig>, mocks: Option<Arc<MockLayer>>, archive_source: Option<&Path>, session_store: Option<Arc<dyn SessionStore>>, state_store: Option<Arc<dyn StateStore>>, wasi_policy: Arc<RunnerWasiPolicy>, secrets: Arc<dyn SecretsManager>, oauth_config: Option<OAuthBrokerConfig>, verify_archive: bool, component_resolution: ComponentResolution, ) -> Result<PackRuntime, Error>

pub async fn list_flows(&self) -> Result<Vec<FlowDescriptor>, Error>

pub async fn run_flow( &self, flow_id: &str, input: Value, ) -> Result<Value, Error>

pub async fn invoke_component( &self, component_ref: &str, ctx: ExecCtx, operation: &str, _config_json: Option<String>, input_json: String, ) -> Result<Value, Error>

pub fn resolve_provider( &self, provider_id: Option<&str>, provider_type: Option<&str>, ) -> Result<ProviderBinding, Error>

pub async fn invoke_provider( &self, binding: &ProviderBinding, ctx: ExecCtx, op: &str, input_json: Vec<u8>, ) -> Result<Value, Error>

pub fn load_flow(&self, flow_id: &str) -> Result<Flow, Error>

pub fn metadata(&self) -> &PackMetadata

pub fn required_secrets(&self) -> &[SecretRequirement]

pub fn missing_secrets(&self, tenant_ctx: &TenantCtx) -> Vec<SecretRequirement>

pub fn for_component_test( components: Vec<(String, PathBuf)>, flows: HashMap<String, FlowIR>, pack_id: &str, config: Arc<HostConfig>, ) -> Result<PackRuntime, Error>