Struct CloudWatchMetrics 

pub struct CloudWatchMetrics { /* private fields */ }

AWS CloudWatch Metrics implementation of CloudMetrics.

This implementation provides:

• Batched metric export for efficiency
• Support for custom dimensions
• Automatic namespace configuration
• Standard and custom units

Example

use llm_shield_cloud_aws::CloudWatchMetrics;
use llm_shield_cloud::{CloudMetrics, Metric};
use std::collections::HashMap;

#[tokio::main]
async fn main() -> Result<(), Box<dyn std::error::Error>> {
    let metrics = CloudWatchMetrics::new("LLMShield").await?;

    let metric = Metric {
        name: "RequestCount".to_string(),
        value: 1.0,
        timestamp: std::time::SystemTime::now()
            .duration_since(std::time::UNIX_EPOCH)?
            .as_secs(),
        dimensions: HashMap::new(),
        unit: Some("Count".to_string()),
    };

    metrics.export_metric(&metric).await?;
    Ok(())
}

Implementations

impl CloudWatchMetrics

pub async fn new(namespace: impl Into<String>) -> Result<Self>

Creates a new CloudWatch Metrics client with default configuration.

Arguments

• namespace - CloudWatch namespace (e.g., “LLMShield”)

Errors

Returns error if AWS configuration cannot be loaded.

pub async fn new_with_config( namespace: impl Into<String>, region: impl Into<String>, batch_size: usize, ) -> Result<Self>

Creates a new CloudWatch Metrics client with specific region and batch size.

Arguments

• namespace - CloudWatch namespace
• region - AWS region
• batch_size - Number of metrics to batch before sending (max 1000)

Errors

Returns error if AWS configuration cannot be loaded.

pub fn namespace(&self) -> &str

Gets the namespace this client is configured for.

pub fn region(&self) -> &str

Gets the AWS region this client is configured for.

pub async fn flush(&self) -> Result<()>

Flushes buffered metrics to CloudWatch.

Trait Implementations

impl CloudMetrics for CloudWatchMetrics

fn export_metrics<'life0, 'life1, 'async_trait>( &'life0 self, metrics: &'life1 [Metric], ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

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

Exports a batch of metrics to the cloud provider.

fn export_metric<'life0, 'life1, 'async_trait>( &'life0 self, metric: &'life1 Metric, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

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

Exports a single metric.