NationTech/harmony
6
0
Fork 1
Code Issues 35 Pull Requests 7 Actions Packages Projects Releases 1 Wiki Activity

feat: added the steps to install discord-webhook-receiver for k8s anywhere topology if not already installed #50

Closed
wjro wants to merge 6 commits from feat/discord-webhook-receiver into master
pull from: feat/discord-webhook-receiver
merge into: NationTech:master
Conversation 1 Commits 6 Files Changed 3 +15 -4
2 changed files with 15 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files
Showing only changes of commit b33650e9d5 - Show all commits

6
harmony/src/domain/topology/oberservability/monitoring.rs
View File

@ -30,7 +30,11 @@ pub trait Monitor<T: Topology>: Debug + Send + Sync {
#[async_trait] #[async_trait]
pub trait EnsureAlertReceiver<T: Topology>: Debug + DynClone + Send + Sync { pub trait EnsureAlertReceiver<T: Topology>: Debug + DynClone + Send + Sync {
async fn ensure_alert_receiver(&self, inventory: Inventory, topology: &T) -> Result<Outcome, InterpretError>; async fn ensure_alert_receiver(
&self,
inventory: Inventory,
topology: &T,
) -> Result<Outcome, InterpretError>;
} }
dyn_clone::clone_trait_object!(<T> EnsureAlertReceiver<T>); dyn_clone::clone_trait_object!(<T> EnsureAlertReceiver<T>);

13
harmony/src/modules/monitoring/discord_webhook_sender.rs
View File

@ -11,7 +11,8 @@ use crate::{
inventory::Inventory, inventory::Inventory,
score::Score, score::Score,
topology::{ topology::{
oberservability::monitoring::{AlertReceiver, EnsureAlertReceiver}, HelmCommand, K8sAnywhereTopology, Topology HelmCommand, K8sAnywhereTopology, Topology,
oberservability::monitoring::{AlertReceiver, EnsureAlertReceiver},
}, },
}; };
@ -24,8 +25,14 @@ pub struct DiscordWebhookConfig {
#[async_trait] #[async_trait]
impl<T: Topology + DiscordWebhookReceiver> EnsureAlertReceiver<T> for DiscordWebhookConfig { impl<T: Topology + DiscordWebhookReceiver> EnsureAlertReceiver<T> for DiscordWebhookConfig {
async fn ensure_alert_receiver(&self, inventory: Inventory, topology: &T) -> Result<Outcome, InterpretError> { async fn ensure_alert_receiver(
topology.ensure_discord_webhook_receiver(&inventory, self.clone()).await &self,
inventory: Inventory,
topology: &T,
) -> Result<Outcome, InterpretError> {
topology
.ensure_discord_webhook_receiver(&inventory, self.clone())
.await
} }
} }