Commit dfa0d98d authored by Lluis Gifre Renom's avatar Lluis Gifre Renom
Browse files

Several changes: 

- added missing proto files in genproto.sh
- created .gitignore files to prevent sharing device credentials and data
- improved MonitoringLoops class with one thread per driver for data collection, a unique aggregation queue and one single thread for data export to monitoring
- added GetResource method to Driver API
- improved DriverFactory to select the driver that better fits with filter fields in terms of number of correspondences in filter fields. Drivers with some mismatch filter are discarded.
- implemented proper initialization and connection of drivers to real devices
- started to implement OpenConfig driver with support for Infinera Packet Routers
parent 2980429b

data/.gitignore

0 → 100644
+1 −0
Original line number Diff line number Diff line 
drx30-01.xml

src/device/genproto.sh

+4 −0
Original line number Diff line number Diff line
@@ -26,10 +26,14 @@ touch proto/__init__.py 
python -m grpc_tools.protoc -I../../proto --python_out=proto --grpc_python_out=proto context.proto

python -m grpc_tools.protoc -I../../proto --python_out=proto --grpc_python_out=proto device.proto

python -m grpc_tools.protoc -I../../proto --python_out=proto --grpc_python_out=proto kpi_sample_types.proto

python -m grpc_tools.protoc -I../../proto --python_out=proto --grpc_python_out=proto monitoring.proto



rm proto/context_pb2_grpc.py

rm proto/kpi_sample_types_pb2_grpc.py

rm proto/monitoring_pb2_grpc.py



sed -i -E 's/(import\ .*)_pb2/from . \1_pb2/g' proto/context_pb2.py

sed -i -E 's/(import\ .*)_pb2/from . \1_pb2/g' proto/device_pb2.py

sed -i -E 's/(import\ .*)_pb2/from . \1_pb2/g' proto/device_pb2_grpc.py

sed -i -E 's/(import\ .*)_pb2/from . \1_pb2/g' proto/kpi_sample_types_pb2.py

sed -i -E 's/(import\ .*)_pb2/from . \1_pb2/g' proto/monitoring_pb2.py

src/device/proto/context_pb2.py

+13 −104
Original line number Diff line number Diff line
@@ -716,31 +716,6 @@ _TOPOLOGYEVENT = _descriptor.Descriptor( 
      message_type=None, enum_type=None, containing_type=None,

      is_extension=False, extension_scope=None,

      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),

  ],

  extensions=[

  ],

  nested_types=[],

  enum_types=[

  ],

  serialized_options=None,

  is_extendable=False,

  syntax='proto3',

  extension_ranges=[],

  oneofs=[

  ],

  serialized_start=780,

  serialized_end=839,

)





_TOPOLOGYLIST = _descriptor.Descriptor(

  name='TopologyList',

  full_name='context.TopologyList',

  filename=None,

  file=DESCRIPTOR,

  containing_type=None,

  create_key=_descriptor._internal_create_key,

  fields=[

    _descriptor.FieldDescriptor(

      name='topology_id', full_name='context.TopologyEvent.topology_id', index=1,

      number=2, type=11, cpp_type=10, label=1,
@@ -999,9 +974,9 @@ _DEVICEEVENT = _descriptor.Descriptor( 
)





_DEVICE = _descriptor.Descriptor(

  name='Device',

  full_name='context.Device',

_LINKID = _descriptor.Descriptor(

  name='LinkId',

  full_name='context.LinkId',

  filename=None,

  file=DESCRIPTOR,

  containing_type=None,
@@ -1014,41 +989,6 @@ _DEVICE = _descriptor.Descriptor( 
      message_type=None, enum_type=None, containing_type=None,

      is_extension=False, extension_scope=None,

      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),

    _descriptor.FieldDescriptor(

      name='device_type', full_name='context.Device.device_type', index=1,

      number=2, type=9, cpp_type=9, label=1,

      has_default_value=False, default_value=b"".decode('utf-8'),

      message_type=None, enum_type=None, containing_type=None,

      is_extension=False, extension_scope=None,

      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),

    _descriptor.FieldDescriptor(

      name='device_config', full_name='context.Device.device_config', index=2,

      number=3, type=11, cpp_type=10, label=1,

      has_default_value=False, default_value=None,

      message_type=None, enum_type=None, containing_type=None,

      is_extension=False, extension_scope=None,

      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),

    _descriptor.FieldDescriptor(

      name='device_operational_status', full_name='context.Device.device_operational_status', index=3,

      number=4, type=14, cpp_type=8, label=1,

      has_default_value=False, default_value=0,

      message_type=None, enum_type=None, containing_type=None,

      is_extension=False, extension_scope=None,

      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),

    _descriptor.FieldDescriptor(

      name='device_drivers', full_name='context.Device.device_drivers', index=4,

      number=5, type=14, cpp_type=8, label=3,

      has_default_value=False, default_value=[],

      message_type=None, enum_type=None, containing_type=None,

      is_extension=False, extension_scope=None,

      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),

    _descriptor.FieldDescriptor(

      name='device_endpoints', full_name='context.Device.device_endpoints', index=5,

      number=6, type=11, cpp_type=10, label=3,

      has_default_value=False, default_value=[],

      message_type=None, enum_type=None, containing_type=None,

      is_extension=False, extension_scope=None,

      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),

  ],

  extensions=[

  ],
@@ -2138,43 +2078,12 @@ LinkId = _reflection.GeneratedProtocolMessageType('LinkId', (_message.Message,), 
  })

_sym_db.RegisterMessage(LinkId)



_LINK = _descriptor.Descriptor(

  name='Link',

  full_name='context.Link',

  filename=None,

  file=DESCRIPTOR,

  containing_type=None,

  create_key=_descriptor._internal_create_key,

  fields=[

    _descriptor.FieldDescriptor(

      name='link_id', full_name='context.Link.link_id', index=0,

      number=1, type=11, cpp_type=10, label=1,

      has_default_value=False, default_value=None,

      message_type=None, enum_type=None, containing_type=None,

      is_extension=False, extension_scope=None,

      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),

    _descriptor.FieldDescriptor(

      name='link_endpoint_ids', full_name='context.Link.link_endpoint_ids', index=1,

      number=2, type=11, cpp_type=10, label=3,

      has_default_value=False, default_value=[],

      message_type=None, enum_type=None, containing_type=None,

      is_extension=False, extension_scope=None,

      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),

  ],

  extensions=[

  ],

  nested_types=[],

  enum_types=[

  ],

  serialized_options=None,

  is_extendable=False,

  syntax='proto3',

  extension_ranges=[],

  oneofs=[

  ],

  serialized_start=1609,

  serialized_end=1697,

)

Link = _reflection.GeneratedProtocolMessageType('Link', (_message.Message,), {

  'DESCRIPTOR' : _LINK,

  '__module__' : 'context_pb2'

  # @@protoc_insertion_point(class_scope:context.Link)

  })

_sym_db.RegisterMessage(Link)



LinkIdList = _reflection.GeneratedProtocolMessageType('LinkIdList', (_message.Message,), {

  'DESCRIPTOR' : _LINKIDLIST,
@@ -2246,12 +2155,12 @@ ServiceEvent = _reflection.GeneratedProtocolMessageType('ServiceEvent', (_messag 
  })

_sym_db.RegisterMessage(ServiceEvent)



DeviceList = _reflection.GeneratedProtocolMessageType('DeviceList', (_message.Message,), {

  'DESCRIPTOR' : _DEVICELIST,

EndPointId = _reflection.GeneratedProtocolMessageType('EndPointId', (_message.Message,), {

  'DESCRIPTOR' : _ENDPOINTID,

  '__module__' : 'context_pb2'

  # @@protoc_insertion_point(class_scope:context.DeviceList)

  # @@protoc_insertion_point(class_scope:context.EndPointId)

  })

_sym_db.RegisterMessage(DeviceList)

_sym_db.RegisterMessage(EndPointId)



EndPoint = _reflection.GeneratedProtocolMessageType('EndPoint', (_message.Message,), {

  'DESCRIPTOR' : _ENDPOINT,

src/device/proto/monitoring_pb2.py

0 → 100644
+452 −0
Original line number Diff line number Diff line 
# -*- coding: utf-8 -*-

# Generated by the protocol buffer compiler.  DO NOT EDIT!

# source: monitoring.proto

"""Generated protocol buffer code."""

from google.protobuf import descriptor as _descriptor

from google.protobuf import message as _message

from google.protobuf import reflection as _reflection

from google.protobuf import symbol_database as _symbol_database

# @@protoc_insertion_point(imports)



_sym_db = _symbol_database.Default()





from . import context_pb2 as context__pb2

from . import kpi_sample_types_pb2 as kpi__sample__types__pb2





DESCRIPTOR = _descriptor.FileDescriptor(

  name='monitoring.proto',

  package='monitoring',

  syntax='proto3',

  serialized_options=None,

  create_key=_descriptor._internal_create_key,

  serialized_pb=b'\n\x10monitoring.proto\x12\nmonitoring\x1a\rcontext.proto\x1a\x16kpi_sample_types.proto\"\xda\x01\n\rKpiDescriptor\x12\x17\n\x0fkpi_description\x18\x01 \x01(\t\x12\x38\n\x0fkpi_sample_type\x18\x02 \x01(\x0e\x32\x1f.kpi_sample_types.KpiSampleType\x12$\n\tdevice_id\x18\x03 \x01(\x0b\x32\x11.context.DeviceId\x12(\n\x0b\x65ndpoint_id\x18\x04 \x01(\x0b\x32\x13.context.EndPointId\x12&\n\nservice_id\x18\x05 \x01(\x0b\x32\x12.context.ServiceId\"p\n\x11MonitorKpiRequest\x12!\n\x06kpi_id\x18\x01 \x01(\x0b\x32\x11.monitoring.KpiId\x12\x1b\n\x13sampling_duration_s\x18\x02 \x01(\x02\x12\x1b\n\x13sampling_interval_s\x18\x03 \x01(\x02\"&\n\x05KpiId\x12\x1d\n\x06kpi_id\x18\x01 \x01(\x0b\x32\r.context.Uuid\"d\n\x03Kpi\x12!\n\x06kpi_id\x18\x01 \x01(\x0b\x32\x11.monitoring.KpiId\x12\x11\n\ttimestamp\x18\x02 \x01(\t\x12\'\n\tkpi_value\x18\x04 \x01(\x0b\x32\x14.monitoring.KpiValue\"a\n\x08KpiValue\x12\x10\n\x06intVal\x18\x01 \x01(\rH\x00\x12\x12\n\x08\x66loatVal\x18\x02 \x01(\x02H\x00\x12\x13\n\tstringVal\x18\x03 \x01(\tH\x00\x12\x11\n\x07\x62oolVal\x18\x04 \x01(\x08H\x00\x42\x07\n\x05value\",\n\x07KpiList\x12!\n\x08kpi_list\x18\x01 \x03(\x0b\x32\x0f.monitoring.Kpi2\xf3\x02\n\x11MonitoringService\x12;\n\tCreateKpi\x12\x19.monitoring.KpiDescriptor\x1a\x11.monitoring.KpiId\"\x00\x12\x42\n\x10GetKpiDescriptor\x12\x11.monitoring.KpiId\x1a\x19.monitoring.KpiDescriptor\"\x00\x12/\n\nIncludeKpi\x12\x0f.monitoring.Kpi\x1a\x0e.context.Empty\"\x00\x12=\n\nMonitorKpi\x12\x1d.monitoring.MonitorKpiRequest\x1a\x0e.context.Empty\"\x00\x12\x36\n\x0cGetStreamKpi\x12\x11.monitoring.KpiId\x1a\x0f.monitoring.Kpi\"\x00\x30\x01\x12\x35\n\rGetInstantKpi\x12\x11.monitoring.KpiId\x1a\x0f.monitoring.Kpi\"\x00\x62\x06proto3'

  ,

  dependencies=[context__pb2.DESCRIPTOR,kpi__sample__types__pb2.DESCRIPTOR,])









_KPIDESCRIPTOR = _descriptor.Descriptor(

  name='KpiDescriptor',

  full_name='monitoring.KpiDescriptor',

  filename=None,

  file=DESCRIPTOR,

  containing_type=None,

  create_key=_descriptor._internal_create_key,

  fields=[

    _descriptor.FieldDescriptor(

      name='kpi_description', full_name='monitoring.KpiDescriptor.kpi_description', index=0,

      number=1, type=9, cpp_type=9, label=1,

      has_default_value=False, default_value=b"".decode('utf-8'),

      message_type=None, enum_type=None, containing_type=None,

      is_extension=False, extension_scope=None,

      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),

    _descriptor.FieldDescriptor(

      name='kpi_sample_type', full_name='monitoring.KpiDescriptor.kpi_sample_type', index=1,

      number=2, type=14, cpp_type=8, label=1,

      has_default_value=False, default_value=0,

      message_type=None, enum_type=None, containing_type=None,

      is_extension=False, extension_scope=None,

      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),

    _descriptor.FieldDescriptor(

      name='device_id', full_name='monitoring.KpiDescriptor.device_id', index=2,

      number=3, type=11, cpp_type=10, label=1,

      has_default_value=False, default_value=None,

      message_type=None, enum_type=None, containing_type=None,

      is_extension=False, extension_scope=None,

      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),

    _descriptor.FieldDescriptor(

      name='endpoint_id', full_name='monitoring.KpiDescriptor.endpoint_id', index=3,

      number=4, type=11, cpp_type=10, label=1,

      has_default_value=False, default_value=None,

      message_type=None, enum_type=None, containing_type=None,

      is_extension=False, extension_scope=None,

      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),

    _descriptor.FieldDescriptor(

      name='service_id', full_name='monitoring.KpiDescriptor.service_id', index=4,

      number=5, type=11, cpp_type=10, label=1,

      has_default_value=False, default_value=None,

      message_type=None, enum_type=None, containing_type=None,

      is_extension=False, extension_scope=None,

      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),

  ],

  extensions=[

  ],

  nested_types=[],

  enum_types=[

  ],

  serialized_options=None,

  is_extendable=False,

  syntax='proto3',

  extension_ranges=[],

  oneofs=[

  ],

  serialized_start=72,

  serialized_end=290,

)





_MONITORKPIREQUEST = _descriptor.Descriptor(

  name='MonitorKpiRequest',

  full_name='monitoring.MonitorKpiRequest',

  filename=None,

  file=DESCRIPTOR,

  containing_type=None,

  create_key=_descriptor._internal_create_key,

  fields=[

    _descriptor.FieldDescriptor(

      name='kpi_id', full_name='monitoring.MonitorKpiRequest.kpi_id', index=0,

      number=1, type=11, cpp_type=10, label=1,

      has_default_value=False, default_value=None,

      message_type=None, enum_type=None, containing_type=None,

      is_extension=False, extension_scope=None,

      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),

    _descriptor.FieldDescriptor(

      name='sampling_duration_s', full_name='monitoring.MonitorKpiRequest.sampling_duration_s', index=1,

      number=2, type=2, cpp_type=6, label=1,

      has_default_value=False, default_value=float(0),

      message_type=None, enum_type=None, containing_type=None,

      is_extension=False, extension_scope=None,

      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),

    _descriptor.FieldDescriptor(

      name='sampling_interval_s', full_name='monitoring.MonitorKpiRequest.sampling_interval_s', index=2,

      number=3, type=2, cpp_type=6, label=1,

      has_default_value=False, default_value=float(0),

      message_type=None, enum_type=None, containing_type=None,

      is_extension=False, extension_scope=None,

      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),

  ],

  extensions=[

  ],

  nested_types=[],

  enum_types=[

  ],

  serialized_options=None,

  is_extendable=False,

  syntax='proto3',

  extension_ranges=[],

  oneofs=[

  ],

  serialized_start=292,

  serialized_end=404,

)





_KPIID = _descriptor.Descriptor(

  name='KpiId',

  full_name='monitoring.KpiId',

  filename=None,

  file=DESCRIPTOR,

  containing_type=None,

  create_key=_descriptor._internal_create_key,

  fields=[

    _descriptor.FieldDescriptor(

      name='kpi_id', full_name='monitoring.KpiId.kpi_id', index=0,

      number=1, type=11, cpp_type=10, label=1,

      has_default_value=False, default_value=None,

      message_type=None, enum_type=None, containing_type=None,

      is_extension=False, extension_scope=None,

      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),

  ],

  extensions=[

  ],

  nested_types=[],

  enum_types=[

  ],

  serialized_options=None,

  is_extendable=False,

  syntax='proto3',

  extension_ranges=[],

  oneofs=[

  ],

  serialized_start=406,

  serialized_end=444,

)





_KPI = _descriptor.Descriptor(

  name='Kpi',

  full_name='monitoring.Kpi',

  filename=None,

  file=DESCRIPTOR,

  containing_type=None,

  create_key=_descriptor._internal_create_key,

  fields=[

    _descriptor.FieldDescriptor(

      name='kpi_id', full_name='monitoring.Kpi.kpi_id', index=0,

      number=1, type=11, cpp_type=10, label=1,

      has_default_value=False, default_value=None,

      message_type=None, enum_type=None, containing_type=None,

      is_extension=False, extension_scope=None,

      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),

    _descriptor.FieldDescriptor(

      name='timestamp', full_name='monitoring.Kpi.timestamp', index=1,

      number=2, type=9, cpp_type=9, label=1,

      has_default_value=False, default_value=b"".decode('utf-8'),

      message_type=None, enum_type=None, containing_type=None,

      is_extension=False, extension_scope=None,

      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),

    _descriptor.FieldDescriptor(

      name='kpi_value', full_name='monitoring.Kpi.kpi_value', index=2,

      number=4, type=11, cpp_type=10, label=1,

      has_default_value=False, default_value=None,

      message_type=None, enum_type=None, containing_type=None,

      is_extension=False, extension_scope=None,

      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),

  ],

  extensions=[

  ],

  nested_types=[],

  enum_types=[

  ],

  serialized_options=None,

  is_extendable=False,

  syntax='proto3',

  extension_ranges=[],

  oneofs=[

  ],

  serialized_start=446,

  serialized_end=546,

)





_KPIVALUE = _descriptor.Descriptor(

  name='KpiValue',

  full_name='monitoring.KpiValue',

  filename=None,

  file=DESCRIPTOR,

  containing_type=None,

  create_key=_descriptor._internal_create_key,

  fields=[

    _descriptor.FieldDescriptor(

      name='intVal', full_name='monitoring.KpiValue.intVal', index=0,

      number=1, type=13, cpp_type=3, label=1,

      has_default_value=False, default_value=0,

      message_type=None, enum_type=None, containing_type=None,

      is_extension=False, extension_scope=None,

      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),

    _descriptor.FieldDescriptor(

      name='floatVal', full_name='monitoring.KpiValue.floatVal', index=1,

      number=2, type=2, cpp_type=6, label=1,

      has_default_value=False, default_value=float(0),

      message_type=None, enum_type=None, containing_type=None,

      is_extension=False, extension_scope=None,

      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),

    _descriptor.FieldDescriptor(

      name='stringVal', full_name='monitoring.KpiValue.stringVal', index=2,

      number=3, type=9, cpp_type=9, label=1,

      has_default_value=False, default_value=b"".decode('utf-8'),

      message_type=None, enum_type=None, containing_type=None,

      is_extension=False, extension_scope=None,

      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),

    _descriptor.FieldDescriptor(

      name='boolVal', full_name='monitoring.KpiValue.boolVal', index=3,

      number=4, type=8, cpp_type=7, label=1,

      has_default_value=False, default_value=False,

      message_type=None, enum_type=None, containing_type=None,

      is_extension=False, extension_scope=None,

      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),

  ],

  extensions=[

  ],

  nested_types=[],

  enum_types=[

  ],

  serialized_options=None,

  is_extendable=False,

  syntax='proto3',

  extension_ranges=[],

  oneofs=[

    _descriptor.OneofDescriptor(

      name='value', full_name='monitoring.KpiValue.value',

      index=0, containing_type=None,

      create_key=_descriptor._internal_create_key,

    fields=[]),

  ],

  serialized_start=548,

  serialized_end=645,

)





_KPILIST = _descriptor.Descriptor(

  name='KpiList',

  full_name='monitoring.KpiList',

  filename=None,

  file=DESCRIPTOR,

  containing_type=None,

  create_key=_descriptor._internal_create_key,

  fields=[

    _descriptor.FieldDescriptor(

      name='kpi_list', full_name='monitoring.KpiList.kpi_list', index=0,

      number=1, type=11, cpp_type=10, label=3,

      has_default_value=False, default_value=[],

      message_type=None, enum_type=None, containing_type=None,

      is_extension=False, extension_scope=None,

      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),

  ],

  extensions=[

  ],

  nested_types=[],

  enum_types=[

  ],

  serialized_options=None,

  is_extendable=False,

  syntax='proto3',

  extension_ranges=[],

  oneofs=[

  ],

  serialized_start=647,

  serialized_end=691,

)



_KPIDESCRIPTOR.fields_by_name['kpi_sample_type'].enum_type = kpi__sample__types__pb2._KPISAMPLETYPE

_KPIDESCRIPTOR.fields_by_name['device_id'].message_type = context__pb2._DEVICEID

_KPIDESCRIPTOR.fields_by_name['endpoint_id'].message_type = context__pb2._ENDPOINTID

_KPIDESCRIPTOR.fields_by_name['service_id'].message_type = context__pb2._SERVICEID

_MONITORKPIREQUEST.fields_by_name['kpi_id'].message_type = _KPIID

_KPIID.fields_by_name['kpi_id'].message_type = context__pb2._UUID

_KPI.fields_by_name['kpi_id'].message_type = _KPIID

_KPI.fields_by_name['kpi_value'].message_type = _KPIVALUE

_KPIVALUE.oneofs_by_name['value'].fields.append(

  _KPIVALUE.fields_by_name['intVal'])

_KPIVALUE.fields_by_name['intVal'].containing_oneof = _KPIVALUE.oneofs_by_name['value']

_KPIVALUE.oneofs_by_name['value'].fields.append(

  _KPIVALUE.fields_by_name['floatVal'])

_KPIVALUE.fields_by_name['floatVal'].containing_oneof = _KPIVALUE.oneofs_by_name['value']

_KPIVALUE.oneofs_by_name['value'].fields.append(

  _KPIVALUE.fields_by_name['stringVal'])

_KPIVALUE.fields_by_name['stringVal'].containing_oneof = _KPIVALUE.oneofs_by_name['value']

_KPIVALUE.oneofs_by_name['value'].fields.append(

  _KPIVALUE.fields_by_name['boolVal'])

_KPIVALUE.fields_by_name['boolVal'].containing_oneof = _KPIVALUE.oneofs_by_name['value']

_KPILIST.fields_by_name['kpi_list'].message_type = _KPI

DESCRIPTOR.message_types_by_name['KpiDescriptor'] = _KPIDESCRIPTOR

DESCRIPTOR.message_types_by_name['MonitorKpiRequest'] = _MONITORKPIREQUEST

DESCRIPTOR.message_types_by_name['KpiId'] = _KPIID

DESCRIPTOR.message_types_by_name['Kpi'] = _KPI

DESCRIPTOR.message_types_by_name['KpiValue'] = _KPIVALUE

DESCRIPTOR.message_types_by_name['KpiList'] = _KPILIST

_sym_db.RegisterFileDescriptor(DESCRIPTOR)



KpiDescriptor = _reflection.GeneratedProtocolMessageType('KpiDescriptor', (_message.Message,), {

  'DESCRIPTOR' : _KPIDESCRIPTOR,

  '__module__' : 'monitoring_pb2'

  # @@protoc_insertion_point(class_scope:monitoring.KpiDescriptor)

  })

_sym_db.RegisterMessage(KpiDescriptor)



MonitorKpiRequest = _reflection.GeneratedProtocolMessageType('MonitorKpiRequest', (_message.Message,), {

  'DESCRIPTOR' : _MONITORKPIREQUEST,

  '__module__' : 'monitoring_pb2'

  # @@protoc_insertion_point(class_scope:monitoring.MonitorKpiRequest)

  })

_sym_db.RegisterMessage(MonitorKpiRequest)



KpiId = _reflection.GeneratedProtocolMessageType('KpiId', (_message.Message,), {

  'DESCRIPTOR' : _KPIID,

  '__module__' : 'monitoring_pb2'

  # @@protoc_insertion_point(class_scope:monitoring.KpiId)

  })

_sym_db.RegisterMessage(KpiId)



Kpi = _reflection.GeneratedProtocolMessageType('Kpi', (_message.Message,), {

  'DESCRIPTOR' : _KPI,

  '__module__' : 'monitoring_pb2'

  # @@protoc_insertion_point(class_scope:monitoring.Kpi)

  })

_sym_db.RegisterMessage(Kpi)



KpiValue = _reflection.GeneratedProtocolMessageType('KpiValue', (_message.Message,), {

  'DESCRIPTOR' : _KPIVALUE,

  '__module__' : 'monitoring_pb2'

  # @@protoc_insertion_point(class_scope:monitoring.KpiValue)

  })

_sym_db.RegisterMessage(KpiValue)



KpiList = _reflection.GeneratedProtocolMessageType('KpiList', (_message.Message,), {

  'DESCRIPTOR' : _KPILIST,

  '__module__' : 'monitoring_pb2'

  # @@protoc_insertion_point(class_scope:monitoring.KpiList)

  })

_sym_db.RegisterMessage(KpiList)







_MONITORINGSERVICE = _descriptor.ServiceDescriptor(

  name='MonitoringService',

  full_name='monitoring.MonitoringService',

  file=DESCRIPTOR,

  index=0,

  serialized_options=None,

  create_key=_descriptor._internal_create_key,

  serialized_start=694,

  serialized_end=1065,

  methods=[

  _descriptor.MethodDescriptor(

    name='CreateKpi',

    full_name='monitoring.MonitoringService.CreateKpi',

    index=0,

    containing_service=None,

    input_type=_KPIDESCRIPTOR,

    output_type=_KPIID,

    serialized_options=None,

    create_key=_descriptor._internal_create_key,

  ),

  _descriptor.MethodDescriptor(

    name='GetKpiDescriptor',

    full_name='monitoring.MonitoringService.GetKpiDescriptor',

    index=1,

    containing_service=None,

    input_type=_KPIID,

    output_type=_KPIDESCRIPTOR,

    serialized_options=None,

    create_key=_descriptor._internal_create_key,

  ),

  _descriptor.MethodDescriptor(

    name='IncludeKpi',

    full_name='monitoring.MonitoringService.IncludeKpi',

    index=2,

    containing_service=None,

    input_type=_KPI,

    output_type=context__pb2._EMPTY,

    serialized_options=None,

    create_key=_descriptor._internal_create_key,

  ),

  _descriptor.MethodDescriptor(

    name='MonitorKpi',

    full_name='monitoring.MonitoringService.MonitorKpi',

    index=3,

    containing_service=None,

    input_type=_MONITORKPIREQUEST,

    output_type=context__pb2._EMPTY,

    serialized_options=None,

    create_key=_descriptor._internal_create_key,

  ),

  _descriptor.MethodDescriptor(

    name='GetStreamKpi',

    full_name='monitoring.MonitoringService.GetStreamKpi',

    index=4,

    containing_service=None,

    input_type=_KPIID,

    output_type=_KPI,

    serialized_options=None,

    create_key=_descriptor._internal_create_key,

  ),

  _descriptor.MethodDescriptor(

    name='GetInstantKpi',

    full_name='monitoring.MonitoringService.GetInstantKpi',

    index=5,

    containing_service=None,

    input_type=_KPIID,

    output_type=_KPI,

    serialized_options=None,

    create_key=_descriptor._internal_create_key,

  ),

])

_sym_db.RegisterServiceDescriptor(_MONITORINGSERVICE)



DESCRIPTOR.services_by_name['MonitoringService'] = _MONITORINGSERVICE



# @@protoc_insertion_point(module_scope)

src/device/service/DeviceServiceServicerImpl.py

+27 −11

File changed.

Preview size limit exceeded, changes collapsed.