Struct AvpPolicyEvaluator 

pub struct AvpPolicyEvaluator { /* private fields */ }

AVP-based policy evaluator implementing the PolicyEvaluator trait.

This wraps AvpClient and provides the standard PolicyEvaluator interface for use with ValidationPipeline and #[derive(CodeMode)].

Example

use pmcp_code_mode::{AvpClient, AvpConfig, AvpPolicyEvaluator, NoopPolicyEvaluator};
use std::sync::Arc;

// Runtime selection based on environment
let evaluator: Arc<dyn PolicyEvaluator> = match std::env::var("POLICY_STORE_ID") {
    Ok(store_id) => Arc::new(AvpPolicyEvaluator::new(
        AvpClient::new(AvpConfig { policy_store_id: store_id, region: None }).await?
    )),
    Err(_) => Arc::new(NoopPolicyEvaluator::new()),
};

Implementations

impl AvpPolicyEvaluator

pub fn new(client: AvpClient) -> Self

Create a new AVP policy evaluator.

Trait Implementations

impl PolicyEvaluator for AvpPolicyEvaluator

fn evaluate_operation<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, operation: &'life1 OperationEntity, server_config: &'life2 ServerConfigEntity, ) -> Pin<Box<dyn Future<Output = Result<AuthorizationDecision, PolicyEvaluationError>> + Send + 'async_trait>>

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

Evaluate a GraphQL operation against policies.

fn evaluate_script<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, script: &'life1 ScriptEntity, server: &'life2 OpenAPIServerEntity, ) -> Pin<Box<dyn Future<Output = Result<AuthorizationDecision, PolicyEvaluationError>> + Send + 'async_trait>>

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

Evaluate a JavaScript script against policies (OpenAPI Code Mode). Default: denies all scripts (override for OpenAPI support).

fn name(&self) -> &str

Human-readable name for logging.

fn batch_evaluate<'life0, 'async_trait>( &'life0 self, requests: Vec<(OperationEntity, ServerConfigEntity)>, ) -> Pin<Box<dyn Future<Output = Result<Vec<AuthorizationDecision>, PolicyEvaluationError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Batch evaluation (default: sequential).

fn is_configured(&self) -> bool

Whether this evaluator is configured and ready.