from o2ims.service.watcher.ocloud_watcher import OcloudWatcher
from o2ims.service.watcher.ocloud_watcher import DmsWatcher
from o2ims.service.watcher.resourcepool_watcher import ResourcePoolWatcher
+from o2ims.service.watcher.alarm_watcher import AlarmWatcher
+
from o2ims.adapter.clients.ocloud_client import StxDmsClient
from o2ims.adapter.clients.ocloud_client import StxOcloudClient
from o2ims.adapter.clients.ocloud_client import StxResourcePoolClient
+from o2ims.adapter.clients.fault_client import StxAlarmClient
from o2ims.service.watcher.pserver_watcher import PServerWatcher
from o2ims.adapter.clients.ocloud_client import StxPserverClient
from o2ims.service.watcher.pserver_if_watcher import PServerIfWatcher
from o2ims.adapter.clients.ocloud_client import StxIfClient
-from o2ims.service.watcher.pserver_port_watcher import PServerIfPortWatcher
-from o2ims.adapter.clients.ocloud_client import StxIfPortClient
+# from o2ims.service.watcher.pserver_port_watcher import PServerIfPortWatcher
+# from o2ims.adapter.clients.ocloud_client import StxIfPortClient
from o2ims.service.watcher.pserver_eth_watcher import PServerEthWatcher
from o2ims.adapter.clients.ocloud_client import StxEthClient
+# from o2ims.service.watcher.pserver_dev_watcher import PServerDevWatcher
+# from o2ims.adapter.clients.ocloud_client import StxDevClient
+from o2ims.service.watcher.pserver_acc_watcher import PServerAccWatcher
+from o2ims.adapter.clients.ocloud_client import StxAccClient
+
+from o2ims.adapter.clients.alarm_dict_client import load_alarm_definition,\
+ load_alarm_dictionary_from_conf_file
+from o2ims.service.watcher.agg_compute_watcher import ComputeAggWatcher
+from o2ims.service.watcher.agg_network_watcher import NetworkAggWatcher
+from o2ims.service.watcher.agg_storage_watcher import StorageAggWatcher
+from o2ims.service.watcher.agg_undefined_watcher import UndefinedAggWatcher
+from o2ims.adapter.clients.aggregate_client import ComputeAggClient, \
+ NetworkAggClient, StorageAggClient, UndefinedAggClient
+
from o2common.helper import o2logging
logger = o2logging.get_logger(__name__)
self.args = args
self.bus = bootstrap.bootstrap()
self.worker = PollWorker(bus=self.bus)
+ load_alarm_definition(self.bus.uow)
+ load_alarm_dictionary_from_conf_file(self.bus.uow)
def run(self):
try:
StxOcloudClient(), self.bus))
root.addchild(
DmsWatcher(StxDmsClient(), self.bus))
+ # root.addchild(
+ # AlarmWatcher(StxFaultClient(), self.bus))
child_respool = root.addchild(
ResourcePoolWatcher(StxResourcePoolClient(),
self.bus))
+
+ # Add Aggregate watch
+ child_respool.addchild(
+ ComputeAggWatcher(ComputeAggClient(), self.bus))
+ child_respool.addchild(
+ NetworkAggWatcher(NetworkAggClient(), self.bus))
+ child_respool.addchild(
+ StorageAggWatcher(StorageAggClient(), self.bus))
+ child_respool.addchild(
+ UndefinedAggWatcher(UndefinedAggClient(), self.bus))
+
+ # Add Resource watch
child_pserver = child_respool.addchild(
PServerWatcher(StxPserverClient(), self.bus))
child_pserver.addchild(
PServerMemWatcher(StxMemClient(), self.bus))
child_pserver.addchild(
PServerEthWatcher(StxEthClient(), self.bus))
- child_if = child_pserver.addchild(
+ child_pserver.addchild(
PServerIfWatcher(StxIfClient(), self.bus))
# child_if.addchild(
# PServerIfPortWatcher(StxIfPortClient(), self.bus))
+ # child_pserver.addchild(
+ # PServerDevWatcher(StxDevClient(), self.bus))
+ child_pserver.addchild(
+ PServerAccWatcher(StxAccClient(), self.bus))
+
+ # Add Alarm watch
+ child_respool.addchild(
+ AlarmWatcher(StxAlarmClient(self.bus.uow), self.bus))
self.worker.add_watcher(root)