From f62a1d8054f534ff60ffec3ad1a5189600c60f44 Mon Sep 17 00:00:00 2001 From: nnDarshan Date: Wed, 7 Jun 2017 18:19:37 +0530 Subject: [PATCH] Adding handlers for brick and volume status change alerts tendrl-bug-id: Tendrl/gluster-integration#286 Signed-off-by: nnDarshan --- .../handlers/cluster/brick_status_handler.py | 30 +++++++++++++++++++ .../handlers/cluster/volume_status_handler.py | 30 +++++++++++++++++++ 2 files changed, 60 insertions(+) create mode 100644 tendrl/alerting/handlers/cluster/brick_status_handler.py create mode 100644 tendrl/alerting/handlers/cluster/volume_status_handler.py diff --git a/tendrl/alerting/handlers/cluster/brick_status_handler.py b/tendrl/alerting/handlers/cluster/brick_status_handler.py new file mode 100644 index 0000000..e3e523e --- /dev/null +++ b/tendrl/alerting/handlers/cluster/brick_status_handler.py @@ -0,0 +1,30 @@ +from tendrl.alerting.handlers import AlertHandler +from tendrl.alerting.objects.cluster_alert import ClusterAlert + + +class BrickStatusHandler(AlertHandler): + handles = 'brick_status' + representive_name = 'brick_status_alert' + + def __init__(self): + AlertHandler.__init__(self) + + def format_alert_message(self): + return + + def classify_alert(self): + ClusterAlert( + alert_id=self.alert.alert_id, + node_id=self.alert.node_id, + time_stamp=self.alert.time_stamp, + resource=self.alert.resource, + current_value=self.alert.current_value, + tags=self.alert.tags, + alert_type=self.alert.alert_type, + severity=self.alert.severity, + significance=self.alert.significance, + ackedby=self.alert.ackedby, + acked=self.alert.acked, + pid=self.alert.pid, + source=self.alert.source, + ).save(update=False) diff --git a/tendrl/alerting/handlers/cluster/volume_status_handler.py b/tendrl/alerting/handlers/cluster/volume_status_handler.py new file mode 100644 index 0000000..340f221 --- /dev/null +++ b/tendrl/alerting/handlers/cluster/volume_status_handler.py @@ -0,0 +1,30 @@ +from tendrl.alerting.handlers import AlertHandler +from tendrl.alerting.objects.cluster_alert import ClusterAlert + + +class VolumeStatusHandler(AlertHandler): + handles = 'volume_status' + representive_name = 'volume_status_alert' + + def __init__(self): + AlertHandler.__init__(self) + + def format_alert_message(self): + return + + def classify_alert(self): + ClusterAlert( + alert_id=self.alert.alert_id, + node_id=self.alert.node_id, + time_stamp=self.alert.time_stamp, + resource=self.alert.resource, + current_value=self.alert.current_value, + tags=self.alert.tags, + alert_type=self.alert.alert_type, + severity=self.alert.severity, + significance=self.alert.significance, + ackedby=self.alert.ackedby, + acked=self.alert.acked, + pid=self.alert.pid, + source=self.alert.source, + ).save(update=False)