Struct wasmcloud_host::policy::Manager

pub struct Manager {
    pub policy_changes: AbortHandle,
    /* private fields */
}

Encapsulates making requests for policy decisions, and receiving updated decisions

Fields

policy_changes: AbortHandle

An abort handle for the policy changes subscription

Implementations

impl Manager

pub async fn new( nats: Client, host_info: HostInfo, policy_topic: Option<String>, policy_timeout: Option<Duration>, policy_changes_topic: Option<String>, ) -> Result<Arc<Self>>

Construct a new policy manager. Can fail if policy_changes_topic is set but we fail to subscribe to it

pub async fn evaluate_start_component( &self, component_id: impl AsRef<str>, image_ref: impl AsRef<str>, max_instances: u32, annotations: &BTreeMap<String, String>, claims: Option<&Claims<Component>>, ) -> Result<Response>

Use the policy manager to evaluate whether a component may be started

pub async fn evaluate_start_provider( &self, provider_id: impl AsRef<str>, provider_ref: impl AsRef<str>, annotations: &BTreeMap<String, String>, claims: Option<&Claims<CapabilityProvider>>, ) -> Result<Response>

Use the policy manager to evaluate whether a provider may be started

pub async fn evaluate_perform_invocation( &self, component_id: impl AsRef<str>, image_ref: impl AsRef<str>, annotations: &BTreeMap<String, String>, claims: Option<&Claims<Component>>, interface: String, function: String, ) -> Result<Response>

Use the policy manager to evaluate whether a component may be invoked

pub async fn evaluate_action(&self, request: RequestBody) -> Result<Response>

Sends a policy request to the policy server and caches the response

Trait Implementations

impl Debug for Manager

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.