Struct MonitorRepository

pub struct MonitorRepository<N: NetworkRepositoryTrait + Send + 'static, T: TriggerRepositoryTrait + Send + 'static> {
    pub monitors: HashMap<String, Monitor>,
    /* private fields */
}

Repository for storing and retrieving monitor configurations

Fields

monitors: HashMap<String, Monitor>

Map of monitor names to their configurations

Implementations

impl<N: NetworkRepositoryTrait + Send + Sync + 'static, T: TriggerRepositoryTrait + Send + Sync + 'static> MonitorRepository<N, T>

pub async fn new( path: Option<&Path>, network_service: Option<NetworkService<N>>, trigger_service: Option<TriggerService<T>>, ) -> Result<Self, RepositoryError>

Create a new monitor repository from the given path

Loads all monitor configurations from JSON files in the specified directory (or default config directory if None is provided).

pub fn new_with_monitors(monitors: HashMap<String, Monitor>) -> Self

Create a new monitor repository from a list of monitors

pub fn validate_monitor_references( monitors: &HashMap<String, Monitor>, triggers: &HashMap<String, Trigger>, networks: &HashMap<String, Network>, ) -> Result<(), RepositoryError>

Returns an error if any monitor references a non-existent network or trigger.

Trait Implementations

impl<N: Clone + NetworkRepositoryTrait + Send + 'static, T: Clone + TriggerRepositoryTrait + Send + 'static> Clone for MonitorRepository<N, T>

fn clone(&self) -> MonitorRepository<N, T>

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<N: NetworkRepositoryTrait + Send + Sync + 'static, T: TriggerRepositoryTrait + Send + Sync + 'static> MonitorRepositoryTrait<N, T> for MonitorRepository<N, T>

fn load_from_path<'life0, 'life1, 'async_trait>( &'life0 self, path: Option<&'life1 Path>, network_service: Option<NetworkService<N>>, trigger_service: Option<TriggerService<T>>, ) -> Pin<Box<dyn Future<Output = Result<Monitor, RepositoryError>> + Send + 'async_trait>>

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

Load a monitor from a specific path

Loads a monitor configuration from a specific path and validates all network and trigger references.

fn new<'life0, 'async_trait>( path: Option<&'life0 Path>, network_service: Option<NetworkService<N>>, trigger_service: Option<TriggerService<T>>, ) -> Pin<Box<dyn Future<Output = Result<Self, RepositoryError>> + Send + 'async_trait>>

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

Create a new monitor repository from the given path

fn load_all<'life0, 'async_trait>( path: Option<&'life0 Path>, network_service: Option<NetworkService<N>>, trigger_service: Option<TriggerService<T>>, ) -> Pin<Box<dyn Future<Output = Result<HashMap<String, Monitor>, RepositoryError>> + Send + 'async_trait>>

where 'life0: 'async_trait,

Load all monitor configurations from the given path

fn get(&self, monitor_id: &str) -> Option<Monitor>

Get a specific monitor by ID

fn get_all(&self) -> HashMap<String, Monitor>

Get all monitors