Struct NatsPolicyManager 

pub struct NatsPolicyManager {
    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 NatsPolicyManager

pub async fn new( nats: Client, host_info: HostInfo, policy_topic: Option<String>, policy_timeout: Option<Duration>, policy_changes_topic: Option<String>, ) -> Result<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_action(&self, request: RequestBody) -> Result<Response>

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

Trait Implementations

impl Clone for NatsPolicyManager

fn clone(&self) -> NatsPolicyManager

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for NatsPolicyManager

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

Formats the value using the given formatter.

impl PolicyManager for NatsPolicyManager

fn evaluate_start_component<'life0, 'life1, 'life2, 'life3, 'life4, 'async_trait>( &'life0 self, component_id: &'life1 str, image_ref: &'life2 str, max_instances: u32, annotations: &'life3 BTreeMap<String, String>, claims: Option<&'life4 Claims<Component>>, ) -> Pin<Box<dyn Future<Output = Result<Response>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait, 'life4: 'async_trait,

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

fn evaluate_start_provider<'life0, 'life1, 'life2, 'life3, 'life4, 'async_trait>( &'life0 self, provider_id: &'life1 str, provider_ref: &'life2 str, annotations: &'life3 BTreeMap<String, String>, claims: Option<&'life4 Claims<CapabilityProvider>>, ) -> Pin<Box<dyn Future<Output = Result<Response>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait, 'life4: 'async_trait,

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

fn evaluate_perform_invocation<'life0, 'life1, 'life2, 'life3, 'life4, 'async_trait>( &'life0 self, component_id: &'life1 str, image_ref: &'life2 str, annotations: &'life3 BTreeMap<String, String>, claims: Option<&'life4 Claims<Component>>, interface: String, function: String, ) -> Pin<Box<dyn Future<Output = Result<Response>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait, 'life4: 'async_trait,

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