add method for sending upgrade-scheduled notification
@@ -13,6 +13,7 @@ notifierPluginTriggerEvents = {
'clusterThroughputSpike': 'ClusterThroughputSuspiciousSpike',
# TODO: Implement clusterLatencyTooHigh event triggering
'clusterLatencyTooHigh': 'ClusterLatencyTooHigh',
+ 'nodeUpgradeScheduled': 'NodeUpgradeScheduled',
'nodeUpgradeComplete': 'NodeUpgradeComplete',
'nodeUpgradeFail': 'NodeUpgradeFail',
'poolUpgradeStart': 'PoolUpgradeStart',
@@ -34,6 +35,9 @@ class PluginManager:
self.topics = notifierPluginTriggerEvents
self.importPlugins()
+ def sendMessageUponNodeUpgradeScheduled(self, message='Node uprgade has been scheduled'):
+ return self._sendMessage(self.topics['nodeUpgradeScheduled'], message)
+
def sendMessageUponNodeUpgradeComplete(self, message='Node has successfully upgraded.'):
return self._sendMessage(self.topics['nodeUpgradeComplete'], message)
