Struct CloudWatchLogger 

pub struct CloudWatchLogger { /* private fields */ }

AWS CloudWatch Logs implementation of CloudLogger.

This implementation provides:

• Batched log export for efficiency
• Structured logging support
• Automatic log stream creation
• Log group configuration

Example

use llm_shield_cloud_aws::CloudWatchLogger;
use llm_shield_cloud::{CloudLogger, LogLevel};

#[tokio::main]
async fn main() -> Result<(), Box<dyn std::error::Error>> {
    let logger = CloudWatchLogger::new(
        "/llm-shield/api",
        "production-instance-1"
    ).await?;

    logger.log("Application started", LogLevel::Info).await?;
    Ok(())
}

Implementations

impl CloudWatchLogger

pub async fn new( log_group: impl Into<String>, log_stream: impl Into<String>, ) -> Result<Self>

Creates a new CloudWatch Logs client with default configuration.

Arguments

• log_group - CloudWatch Logs log group name (e.g., “/llm-shield/api”)
• log_stream - Log stream name (e.g., “instance-1”)

Errors

Returns error if AWS configuration cannot be loaded or log stream creation fails.

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

Creates a new CloudWatch Logs client with specific configuration.

Arguments

• log_group - CloudWatch Logs log group name
• log_stream - Log stream name
• region - AWS region
• batch_size - Number of log entries to batch before sending

Errors

Returns error if AWS configuration cannot be loaded.

pub fn log_group(&self) -> &str

Gets the log group this client is configured for.

pub fn log_stream(&self) -> &str

Gets the log stream 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 log entries to CloudWatch Logs.

Trait Implementations

impl CloudLogger for CloudWatchLogger

fn log<'life0, 'life1, 'async_trait>( &'life0 self, message: &'life1 str, level: LogLevel, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

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

Writes a simple log message.

fn log_structured<'life0, 'life1, 'async_trait>( &'life0 self, entry: &'life1 LogEntry, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

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

Writes a structured log entry.

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

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

Writes a batch of log entries.