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

feat: added webhook receiver to alertchannels #68

Merged
wjro merged 2 commits from feat/webhook_receiver into master 2025-06-26 16:43:34 +00:00
Conversation 0 Commits 2 Files Changed 2 +9 -4
1 changed files with 9 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files
Showing only changes of commit 7ec89cdac5 - Show all commits

13
harmony/src/modules/monitoring/alert_channel/webhook_receiver.rs
View File

@ -2,8 +2,14 @@ use async_trait::async_trait;
use serde::Serialize; use serde::Serialize;
use serde_yaml::{Mapping, Value}; use serde_yaml::{Mapping, Value};
use crate::{interpret::{InterpretError, Outcome}, modules::monitoring::kube_prometheus::{prometheus::{Prometheus, PrometheusReceiver}, types::{AlertChannelConfig, AlertManagerChannelConfig}}, topology::{oberservability::monitoring::AlertReceiver, Url}}; use crate::{
interpret::{InterpretError, Outcome},
modules::monitoring::kube_prometheus::{
prometheus::{Prometheus, PrometheusReceiver},
types::{AlertChannelConfig, AlertManagerChannelConfig},
},
topology::{Url, oberservability::monitoring::AlertReceiver},
};
#[derive(Debug, Clone, Serialize)] #[derive(Debug, Clone, Serialize)]
pub struct WebhookReceiver { pub struct WebhookReceiver {
@ -12,7 +18,7 @@ pub struct WebhookReceiver {
} }
#[async_trait] #[async_trait]
impl AlertReceiver<Prometheus> for WebhookReceiver{ impl AlertReceiver<Prometheus> for WebhookReceiver {
async fn install(&self, sender: &Prometheus) -> Result<Outcome, InterpretError> { async fn install(&self, sender: &Prometheus) -> Result<Outcome, InterpretError> {
sender.install_receiver(self).await sender.install_receiver(self).await
} }
@ -31,7 +37,6 @@ impl PrometheusReceiver for WebhookReceiver {
} }
} }
#[async_trait] #[async_trait]
impl AlertChannelConfig for WebhookReceiver { impl AlertChannelConfig for WebhookReceiver {
async fn get_config(&self) -> AlertManagerChannelConfig { async fn get_config(&self) -> AlertManagerChannelConfig {