openstack/aodh
Code Issues Proposed changes

property refactoring

Browse Source 
Change-Id: Ie5680f08e7715c0f2d0b02fa67b58cf3234f79fc
This commit is contained in:
Alexey Weyl 2017-01-10 14:45:36 +00:00
parent 57e79667d9
commit 3c8e029116
1 changed files with 10 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
aodh/evaluator/__init__.py
View File

@ -78,6 +78,14 @@ class Evaluator(object):
self.storage_conn = storage.get_connection_from_config(self.conf) self.storage_conn = storage.get_connection_from_config(self.conf)
return self.storage_conn return self.storage_conn
@property
def alarm_change_notifier(self):
if not self._alarm_change_notifier:
transport = messaging.get_transport(self.conf)
self._alarm_change_notifier = messaging.get_notifier(
transport, publisher_id="aodh.evaluator")
return self._alarm_change_notifier
def _record_change(self, alarm, reason): def _record_change(self, alarm, reason):
if not self.conf.record_history: if not self.conf.record_history:
return return
@ -100,13 +108,9 @@ class Evaluator(object):
self._storage_conn.record_alarm_change(payload) self._storage_conn.record_alarm_change(payload)
except aodh.NotImplementedError: except aodh.NotImplementedError:
pass pass
if not self._alarm_change_notifier:
transport = messaging.get_transport(self.conf)
self._alarm_change_notifier = messaging.get_notifier(
transport, publisher_id="aodh.evaluator")
notification = "alarm.state_transition" notification = "alarm.state_transition"
self._alarm_change_notifier.info({}, self.alarm_change_notifier.info({},
notification, payload) notification, payload)
def _refresh(self, alarm, state, reason, reason_data, always_record=False): def _refresh(self, alarm, state, reason, reason_data, always_record=False):
"""Refresh alarm state.""" """Refresh alarm state."""