X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=o2app%2Fservice%2Fhandlers.py;h=9b4f49dd2ed17ddce8bbdcabdb6cae3d1df4b1fa;hb=608220f90bc14230598167da62c3db643a53cef5;hp=ad75098159849b9dc81c661f768e80b084e9a081;hpb=e0f9e545f020276f022ead2f00e36457e6bfc36c;p=pti%2Fo2.git diff --git a/o2app/service/handlers.py b/o2app/service/handlers.py index ad75098..9b4f49d 100644 --- a/o2app/service/handlers.py +++ b/o2app/service/handlers.py @@ -27,11 +27,12 @@ from o2ims.service.auditor import ocloud_handler, dms_handler, \ resourcepool_handler, pserver_handler, pserver_cpu_handler, \ pserver_mem_handler, pserver_port_handler, pserver_if_handler,\ pserver_eth_handler, pserver_acc_handler, alarm_handler, \ - pserver_dev_handler + pserver_dev_handler, agg_compute_handler, agg_network_handler,\ + agg_storage_handler, agg_undefined_handler from o2ims.service.command import notify_handler, registration_handler,\ notify_alarm_handler from o2ims.service.event import ocloud_event, resource_event, \ - resource_pool_event, alarm_event + resource_pool_event, alarm_event, dms_event, resource_type_event # if TYPE_CHECKING: # from . import unit_of_work @@ -54,6 +55,9 @@ EVENT_HANDLERS = { # o2dms_events.NfDeploymentUninstalled: [ # nfdeployment_handler.publish_nfdeployment_uninstalled] events.OcloudChanged: [ocloud_event.notify_ocloud_update], + events.ResourceTypeChanged: [resource_type_event.\ + notify_resourcetype_change], + events.DmsChanged: [dms_event.notify_dms_change], events.ResourceChanged: [resource_event.notify_resource_change], events.ResourcePoolChanged: [resource_pool_event.\ notify_resourcepool_change], @@ -67,6 +71,11 @@ COMMAND_HANDLERS = { commands.UpdateDms: dms_handler.update_dms, commands.UpdateAlarm: alarm_handler.update_alarm, commands.UpdateResourcePool: resourcepool_handler.update_resourcepool, + commands.UpdateComputeAgg: agg_compute_handler.update_compute_aggregate, + commands.UpdateNetworkAgg: agg_network_handler.update_network_aggregate, + commands.UpdateStorageAgg: agg_storage_handler.update_storage_aggregate, + commands.UpdateUndefinedAgg: + agg_undefined_handler.update_undefined_aggregate, commands.UpdatePserver: pserver_handler.update_pserver, commands.UpdatePserverCpu: pserver_cpu_handler.update_pserver_cpu, commands.UpdatePserverMem: pserver_mem_handler.update_pserver_mem,