examples/monitoring/src/main.rs

@@ -1,6 +1,6 @@
 use harmony::{
     inventory::Inventory, maestro::Maestro,
-    modules::monitoring::monitoring_alerting::MonitoringAlertingScore,
+    modules::monitoring::monitoring_alerting::{MonitoringAlertingScore, MonitoringSystem},
     topology::K8sAnywhereTopology,
 };
 
@@ -13,10 +13,11 @@ async fn main() {
     .await
     .unwrap();
 
-    let monitoring = MonitoringAlertingScore {
-        alert_channel_configs: None,
-    };
-
-    maestro.register_all(vec![Box::new(monitoring)]);
+    //let monitoring = MonitoringAlertingScore {
+    //    alert_receivers: vec![],       
+    //    alert_rules: vec![],
+    //    scrape_targets: vec![],
+    //};
+    //maestro.register_all(vec![Box::new(monitoring)]);
     harmony_cli::init(maestro, None).await.unwrap();
 }

harmony/src/modules/monitoring/alert_channel/discord_alert_channel.rs

@@ -1,3 +1,4 @@
+use log::debug;
 use serde::Serialize;
 
 use crate::{
@@ -14,16 +15,16 @@ pub struct DiscordWebhook {
 }
 
 impl AlertReceiver for DiscordWebhook {
-    type Sender = Prometheus;
+    type M = Prometheus;
 
-    fn install(&self, sender: &Self::Sender) -> Result<(), String> {
-        sender.configure_receiver(Box::new(self))
+    fn install(&self, sender: &Self::M) -> Result<(), String> {
+        sender.configure_receiver(Box::new(self))?;
+        debug!("DiscordWebhook installed for Prometheus");
+        Ok(())
     }
 
-    fn clone(&self) -> Self
-    where
-        Self: Sized {
-        <Self as Clone>::clone(self)
+    fn clone_box(&self) -> Box<dyn AlertReceiver<M = Self::M>> {
+        Box::new(self.clone())
     }
 }
 

harmony/src/modules/monitoring/alert_receiver.rs

@@ -9,27 +9,28 @@ use crate::{
     topology::Topology,
 };
 
-use super::prometheus::AlertSender;
+use super::monitoring_alerting::MonitoringSystem;
+
 
 pub trait AlertReceiver: Debug + Send + Sync {
-    type Sender: AlertSender;
+    type M: MonitoringSystem;
 
-    fn install(&self, sender: &Self::Sender) -> Result<(), String>;
-    fn clone_box(&self) -> Box<dyn AlertReceiver<Sender = Self::Sender>>;
+    fn install(&self, sender: &Self::M) -> Result<(), String>;
+    fn clone_box(&self) -> Box<dyn AlertReceiver<M = Self::M>>;
 }
 
-struct AlertReceiverConfig<S: AlertSender> {
+struct AlertReceiverConfig<M: MonitoringSystem> {
     config: String, // Or whatever
-    sender: S,
+    sender: M,
 }
 
 #[derive(Debug)]
-pub struct AlertReceiverInterpret<S: AlertSender> {
-    pub receiver: Box<dyn AlertReceiver<Sender = S>>,
+pub struct AlertReceiverInterpret<M: MonitoringSystem> {
+    pub receiver: Box<dyn AlertReceiver<M = M>>,
 }
 
 #[async_trait]
-impl<T: Topology, S: AlertSender> Interpret<T> for AlertReceiverInterpret<S> {
+impl<T: Topology, M: MonitoringSystem> Interpret<T> for AlertReceiverInterpret<M> {
     async fn execute(
         &self,
         _inventory: &Inventory,

harmony/src/modules/monitoring/alert_rule.rs

@@ -2,10 +2,12 @@ use std::fmt::Debug;
 
 use dyn_clone::DynClone;
 
-use super::prometheus::AlertSender;
+use super::monitoring_alerting::MonitoringSystem;
+
 
 pub trait AlertRule: Debug + Send + Sync + DynClone {
-    type Sender: AlertSender;
+    type M: MonitoringSystem;
 
-    fn install(&self, sender: &Self::Sender);
+    fn install(&self, sender: &Self::M);
+    fn clone_box(&self) -> Box<dyn AlertRule<M = Self::M>>;
 }

harmony/src/modules/monitoring/monitoring_alerting.rs

@@ -1,6 +1,7 @@
 use std::sync::Arc;
 
 use async_trait::async_trait;
+use log::debug;
 use serde::Serialize;
 
 use crate::{
@@ -11,37 +12,42 @@ use crate::{
     topology::Topology,
 };
 
-use super::{alert_receiver::AlertReceiver, prometheus::AlertSender};
+use super::{alert_receiver::AlertReceiver, prometheus::Installable};
 use super::alert_rule::AlertRule;
 use super::scrape_target::ScrapeTarget;
 
-pub trait MonitoringSystem: std::fmt::Debug + Clone + Serialize + 'static {}
+#[async_trait]
+pub trait MonitoringSystem: std::fmt::Debug + Clone + Serialize + 'static + Send + Sync {
+}
 
 #[derive(Debug, Clone)]
 pub struct MonitoringAlertingScore<M: MonitoringSystem> {
-    pub alert_receivers: Vec<Box<dyn AlertReceiver<Sender = M>>>,
-    pub alert_rules: Vec<Box<dyn AlertRule<Sender = M>>>,
-    pub scrape_targets: Vec<Box<dyn ScrapeTarget<Sender = M>>>,
+    pub alert_receivers: Vec<Box<dyn AlertReceiver<M = M>>>,
+    pub alert_rules: Vec<Box<dyn AlertRule<M = M>>>,
+    pub scrape_targets: Vec<Box<dyn ScrapeTarget<M = M>>>,
 }
 
+#[derive(Clone)]
+struct MonitoringConfig<M: MonitoringSystem> {
+    receivers: Vec<Box<dyn AlertReceiver<M = M>>>,
+}
 
-impl <M: MonitoringSystem + AlertSender> Clone for  Box<dyn AlertReceiver<Sender = M>>{
+impl<M: MonitoringSystem> Clone for Box<dyn AlertReceiver<M = M>> {
     fn clone(&self) -> Self {
         self.clone_box()
     }
 }
-impl <M: MonitoringSystem> Clone for    Box<dyn AlertRule<Sender = M>>{
+impl<M: MonitoringSystem> Clone for Box<dyn AlertRule<M = M>> {
     fn clone(&self) -> Self {
-        todo!()
+        self.clone_box()
     }
 }
-impl <M: MonitoringSystem> Clone for    Box<dyn ScrapeTarget<Sender = M>>{
+impl<M: MonitoringSystem> Clone for Box<dyn ScrapeTarget<M = M>> {
     fn clone(&self) -> Self {
-        todo!()
+        self.clone_box()
     }
 }
 
-
 impl<M: MonitoringSystem> Serialize for MonitoringAlertingScore<M> {
     fn serialize<S>(&self, serializer: S) -> Result<S::Ok, S::Error>
     where
@@ -51,7 +57,9 @@ impl<M: MonitoringSystem> Serialize for MonitoringAlertingScore<M> {
     }
 }
 
-impl<T: Topology, M: MonitoringSystem + Serialize> Score<T> for MonitoringAlertingScore<M> {
+impl<T: Topology, M: MonitoringSystem + Serialize + Installable> Score<T>
+    for MonitoringAlertingScore<M>
+{
     fn create_interpret(&self) -> Box<dyn Interpret<T>> {
         Box::new(MonitoringAlertingInterpret {
             score: Arc::new(self.clone()),
@@ -68,14 +76,19 @@ struct MonitoringAlertingInterpret<M: MonitoringSystem> {
     score: Arc<MonitoringAlertingScore<M>>,
 }
 
+
+
 #[async_trait]
-impl<M: MonitoringSystem, T: Topology> Interpret<T> for MonitoringAlertingInterpret<M> {
+impl<M: MonitoringSystem  + Installable, T: Topology> Interpret<T>
+    for MonitoringAlertingInterpret<M>
+{
     async fn execute(
         &self,
         inventory: &Inventory,
         topology: &T,
     ) -> Result<Outcome, InterpretError> {
-        todo!()
+        debug!("score {:#?}", self.score);
+        monitoring_system.install().await
     }
 
     fn get_name(&self) -> InterpretName {
@@ -94,3 +107,9 @@ impl<M: MonitoringSystem, T: Topology> Interpret<T> for MonitoringAlertingInterp
         todo!()
     }
 }
+
+impl<M: MonitoringSystem> MonitoringAlertingInterpret<M> {
+    fn build_config(&self) -> MonitoringConfig<M> {
+        todo!()
+    }
+}

harmony/src/modules/monitoring/prometheus.rs

@@ -6,22 +6,18 @@ use crate::{
     data::{Id, Version},
     interpret::{Interpret, InterpretError, InterpretName, InterpretStatus, Outcome},
     inventory::Inventory,
-    topology::Topology,
+    topology::{HelmCommand, K8sAnywhereTopology, Topology},
 };
 use std::fmt::Debug;
 
-use super::monitoring_alerting::MonitoringSystem;
-
-pub trait AlertSender: std::fmt::Debug {}
+use super::monitoring_alerting::{MonitoringSystem, MonitoringSystemInstaller};
 
 #[derive(Debug, Clone, Serialize)]
 pub struct Prometheus {}
 
 impl Prometheus {
-    pub fn configure_receiver(
-        &self,
-        _receiver: Box<&dyn PrometheusReceiver>,
-    ) -> Result<(), String> {
+    pub fn configure_receiver(&self, receiver: Box<&dyn PrometheusReceiver>) -> Result<(), String> {
+        let receiver_config = receiver.get_prometheus_config();
         todo!()
     }
     pub fn configure_rule(&self, _rule: Box<&dyn PrometheusRule>) {
@@ -40,8 +36,6 @@ pub trait PrometheusCapability {
     fn install_scrape_targets(&self, receivers: Vec<Box<dyn PrometheusScrapeTarget>>);
 }
 
-impl AlertSender for Prometheus {}
-
 pub trait PrometheusReceiver {
     fn get_prometheus_config(&self) -> PrometheusReceiverConfig;
 }
@@ -102,3 +96,17 @@ impl<T: Topology + PrometheusCapability> Interpret<T> for PrometheusMonitoringIn
         todo!()
     }
 }
+
+#[async_trait]
+pub trait Installable {
+    async fn install(&self) -> Result<Outcome, InterpretError>;
+    type Installer;
+}
+
+#[async_trait]
+impl Installable for Prometheus {
+    type Installer = K8sAnywhereTopology;
+    async fn install(&self) -> Result<Outcome, InterpretError> {
+        todo!()
+    }
+}

harmony/src/modules/monitoring/scrape_target.rs

@@ -2,11 +2,13 @@ use std::fmt::Debug;
 
 use dyn_clone::DynClone;
 
-use super::prometheus::AlertSender;
+use super::monitoring_alerting::MonitoringSystem;
+
 
 pub trait ScrapeTarget: Debug + Send + Sync + DynClone {
-    type Sender: AlertSender;
+    type M: MonitoringSystem;
 
-    fn install(&self, sender: &Self::Sender);
+    fn install(&self, sender: &Self::M);
+    fn clone_box(&self) -> Box<dyn ScrapeTarget<M = Self::M>>;
 }