Commit 35596ca1 authored by Lluis Gifre Renom's avatar Lluis Gifre Renom
Browse files

Device component: 

- Updated detailed metrics for RPC methods (to be completed)
parent 56a1e4d4

src/device/service/DeviceServiceServicerImpl.py

+3 −3
Original line number Original line Diff line number Diff line
@@ -37,7 +37,7 @@ LOGGER = logging.getLogger(__name__) 




METRICS_POOL = MetricsPool('Device', 'RPC')

METRICS_POOL = MetricsPool('Device', 'RPC')





METRICS_POOL_DETAILS = MetricsPool('Device', 'exec_details', labels={

METRICS_POOL_DETAILS = MetricsPool('Device', 'execution', labels={

    'driver': '', 'operation': '', 'step': '',

    'driver': '', 'operation': '', 'step': '',

})

})
@@ -151,7 +151,7 @@ class DeviceServiceServicerImpl(DeviceServiceServicer): 
            metrics_labels = dict(driver=driver.name, operation='add_device')

            metrics_labels = dict(driver=driver.name, operation='add_device')





            histogram_duration : Histogram = METRICS_POOL_DETAILS.get_or_create(

            histogram_duration : Histogram = METRICS_POOL_DETAILS.get_or_create(

                'AddDevice', MetricTypeEnum.HISTOGRAM_DURATION)

                'details', MetricTypeEnum.HISTOGRAM_DURATION)

            histogram_duration.labels(step='total'              , **metrics_labels).observe(t14-t0)

            histogram_duration.labels(step='total'              , **metrics_labels).observe(t14-t0)

            histogram_duration.labels(step='execution'          , **metrics_labels).observe(t14-t3)

            histogram_duration.labels(step='execution'          , **metrics_labels).observe(t14-t3)

            histogram_duration.labels(step='endpoint_checks'    , **metrics_labels).observe(t1-t0)

            histogram_duration.labels(step='endpoint_checks'    , **metrics_labels).observe(t1-t0)
@@ -255,7 +255,7 @@ class DeviceServiceServicerImpl(DeviceServiceServicer): 
            metrics_labels = dict(driver=driver.name, operation='configure_device')

            metrics_labels = dict(driver=driver.name, operation='configure_device')





            histogram_duration : Histogram = METRICS_POOL_DETAILS.get_or_create(

            histogram_duration : Histogram = METRICS_POOL_DETAILS.get_or_create(

                'ConfigureDevice', MetricTypeEnum.HISTOGRAM_DURATION)

                'details', MetricTypeEnum.HISTOGRAM_DURATION)

            histogram_duration.labels(step='total'            , **metrics_labels).observe(t9-t0)

            histogram_duration.labels(step='total'            , **metrics_labels).observe(t9-t0)

            histogram_duration.labels(step='wait_queue'       , **metrics_labels).observe(t1-t0)

            histogram_duration.labels(step='wait_queue'       , **metrics_labels).observe(t1-t0)

            histogram_duration.labels(step='execution'        , **metrics_labels).observe(t9-t1)

            histogram_duration.labels(step='execution'        , **metrics_labels).observe(t9-t1)