Struct Observability 

pub struct Observability {
    pub config: ObservabilityConfig,
    pub cost_tracker: Option<Arc<CostTracker>>,
    pub security_monitor: Option<Arc<SecurityMonitor>>,
    pub rate_limits: Arc<RwLock<HashMap<String, ProviderRateLimit>>>,
}

Main observability service

Fields

config: ObservabilityConfig

cost_tracker: Option<Arc<CostTracker>>

security_monitor: Option<Arc<SecurityMonitor>>

rate_limits: Arc<RwLock<HashMap<String, ProviderRateLimit>>>

Implementations

impl Observability

pub fn new( config: ObservabilityConfig, db: Option<Arc<dyn IDatabaseAdapter + Send + Sync>>, ) -> Self

pub async fn initialize(&self) -> Result<(), ZoeyError>

Initialize observability (called on startup)

impl Observability

pub fn set_rate_limit(&self, provider: &str, rl: ProviderRateLimit)

pub fn get_rate_limit_remaining(&self, provider: &str) -> Option<u32>