Commit 36b02000 authored by ldemarcosm's avatar ldemarcosm
Browse files

Simplified distributed service

parent f96ed153

src/l3_attackmitigator/genproto.sh

+0 −10
Original line number Diff line number Diff line
@@ -23,17 +23,7 @@ rm -rf proto/*.py 
rm -rf proto/__pycache__

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 service.proto

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

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



rm proto/context_pb2_grpc.py

rm proto/service_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/service_pb2.py

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

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

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

src/l3_attackmitigator/proto/context_pb2.py

deleted100644 → 0
+0 −880

File deleted.

Preview size limit exceeded, changes collapsed.

src/l3_attackmitigator/proto/monitoring_pb2.py

deleted100644 → 0
+0 −350
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





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\"|\n\x03Kpi\x12!\n\x06kpi_id\x18\x01 \x01(\x0b\x32\x11.monitoring.KpiId\x12\x11\n\ttimestamp\x18\x02 \x01(\t\x12\x16\n\x0ekpiDescription\x18\x03 \x01(\t\x12\'\n\tkpi_value\x18\x04 \x01(\x0b\x32\x14.monitoring.KpiValue\"&\n\x05KpiId\x12\x1d\n\x06kpi_id\x18\x01 \x01(\x0b\x32\r.context.Uuid\"T\n\tKpiDevice\x12!\n\x06kpi_id\x18\x01 \x01(\x0b\x32\x11.monitoring.KpiId\x12$\n\tdevice_id\x18\x02 \x01(\x0b\x32\x11.context.DeviceId\"+\n\x07KpiList\x12 \n\x07kpiList\x18\x01 \x03(\x0b\x32\x0f.monitoring.Kpi\"M\n\x08KpiValue\x12\x10\n\x06intVal\x18\x01 \x01(\rH\x00\x12\x13\n\tstringVal\x18\x02 \x01(\tH\x00\x12\x11\n\x07\x62oolVal\x18\x03 \x01(\x08H\x00\x42\x07\n\x05value2\xeb\x01\n\x11MonitoringService\x12/\n\nIncludeKpi\x12\x0f.monitoring.Kpi\x1a\x0e.context.Empty\"\x00\x12\x35\n\nMonitorKpi\x12\x15.monitoring.KpiDevice\x1a\x0e.context.Empty\"\x00\x12\x37\n\rGetStream_kpi\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 = _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='kpiDescription', full_name='monitoring.Kpi.kpiDescription', 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='kpi_value', full_name='monitoring.Kpi.kpi_value', 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),

  ],

  extensions=[

  ],

  nested_types=[],

  enum_types=[

  ],

  serialized_options=None,

  is_extendable=False,

  syntax='proto3',

  extension_ranges=[],

  oneofs=[

  ],

  serialized_start=47,

  serialized_end=171,

)





_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=173,

  serialized_end=211,

)





_KPIDEVICE = _descriptor.Descriptor(

  name='KpiDevice',

  full_name='monitoring.KpiDevice',

  filename=None,

  file=DESCRIPTOR,

  containing_type=None,

  create_key=_descriptor._internal_create_key,

  fields=[

    _descriptor.FieldDescriptor(

      name='kpi_id', full_name='monitoring.KpiDevice.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='device_id', full_name='monitoring.KpiDevice.device_id', index=1,

      number=2, 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=213,

  serialized_end=297,

)





_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='kpiList', full_name='monitoring.KpiList.kpiList', 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=299,

  serialized_end=342,

)





_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='stringVal', full_name='monitoring.KpiValue.stringVal', 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='boolVal', full_name='monitoring.KpiValue.boolVal', index=2,

      number=3, 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=344,

  serialized_end=421,

)



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

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

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

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

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

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

_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['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']

DESCRIPTOR.message_types_by_name['Kpi'] = _KPI

DESCRIPTOR.message_types_by_name['KpiId'] = _KPIID

DESCRIPTOR.message_types_by_name['KpiDevice'] = _KPIDEVICE

DESCRIPTOR.message_types_by_name['KpiList'] = _KPILIST

DESCRIPTOR.message_types_by_name['KpiValue'] = _KPIVALUE

_sym_db.RegisterFileDescriptor(DESCRIPTOR)



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

  'DESCRIPTOR' : _KPI,

  '__module__' : 'monitoring_pb2'

  # @@protoc_insertion_point(class_scope:monitoring.Kpi)

  })

_sym_db.RegisterMessage(Kpi)



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

  'DESCRIPTOR' : _KPIID,

  '__module__' : 'monitoring_pb2'

  # @@protoc_insertion_point(class_scope:monitoring.KpiId)

  })

_sym_db.RegisterMessage(KpiId)



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

  'DESCRIPTOR' : _KPIDEVICE,

  '__module__' : 'monitoring_pb2'

  # @@protoc_insertion_point(class_scope:monitoring.KpiDevice)

  })

_sym_db.RegisterMessage(KpiDevice)



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

  'DESCRIPTOR' : _KPILIST,

  '__module__' : 'monitoring_pb2'

  # @@protoc_insertion_point(class_scope:monitoring.KpiList)

  })

_sym_db.RegisterMessage(KpiList)



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

  'DESCRIPTOR' : _KPIVALUE,

  '__module__' : 'monitoring_pb2'

  # @@protoc_insertion_point(class_scope:monitoring.KpiValue)

  })

_sym_db.RegisterMessage(KpiValue)







_MONITORINGSERVICE = _descriptor.ServiceDescriptor(

  name='MonitoringService',

  full_name='monitoring.MonitoringService',

  file=DESCRIPTOR,

  index=0,

  serialized_options=None,

  create_key=_descriptor._internal_create_key,

  serialized_start=424,

  serialized_end=659,

  methods=[

  _descriptor.MethodDescriptor(

    name='IncludeKpi',

    full_name='monitoring.MonitoringService.IncludeKpi',

    index=0,

    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=1,

    containing_service=None,

    input_type=_KPIDEVICE,

    output_type=context__pb2._EMPTY,

    serialized_options=None,

    create_key=_descriptor._internal_create_key,

  ),

  _descriptor.MethodDescriptor(

    name='GetStream_kpi',

    full_name='monitoring.MonitoringService.GetStream_kpi',

    index=2,

    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=3,

    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/l3_attackmitigator/proto/monitoring_pb2_grpc.py

deleted100644 → 0
+0 −166
Original line number Diff line number Diff line 
# Generated by the gRPC Python protocol compiler plugin. DO NOT EDIT!

"""Client and server classes corresponding to protobuf-defined services."""

import grpc



from . import context_pb2 as context__pb2

from . import monitoring_pb2 as monitoring__pb2





class MonitoringServiceStub(object):

    """Missing associated documentation comment in .proto file."""



    def __init__(self, channel):

        """Constructor.



        Args:

            channel: A grpc.Channel.

        """

        self.IncludeKpi = channel.unary_unary(

                '/monitoring.MonitoringService/IncludeKpi',

                request_serializer=monitoring__pb2.Kpi.SerializeToString,

                response_deserializer=context__pb2.Empty.FromString,

                )

        self.MonitorKpi = channel.unary_unary(

                '/monitoring.MonitoringService/MonitorKpi',

                request_serializer=monitoring__pb2.KpiDevice.SerializeToString,

                response_deserializer=context__pb2.Empty.FromString,

                )

        self.GetStream_kpi = channel.unary_stream(

                '/monitoring.MonitoringService/GetStream_kpi',

                request_serializer=monitoring__pb2.KpiId.SerializeToString,

                response_deserializer=monitoring__pb2.Kpi.FromString,

                )

        self.GetInstantKpi = channel.unary_unary(

                '/monitoring.MonitoringService/GetInstantKpi',

                request_serializer=monitoring__pb2.KpiId.SerializeToString,

                response_deserializer=monitoring__pb2.Kpi.FromString,

                )





class MonitoringServiceServicer(object):

    """Missing associated documentation comment in .proto file."""



    def IncludeKpi(self, request, context):

        """Missing associated documentation comment in .proto file."""

        context.set_code(grpc.StatusCode.UNIMPLEMENTED)

        context.set_details('Method not implemented!')

        raise NotImplementedError('Method not implemented!')



    def MonitorKpi(self, request, context):

        """Missing associated documentation comment in .proto file."""

        context.set_code(grpc.StatusCode.UNIMPLEMENTED)

        context.set_details('Method not implemented!')

        raise NotImplementedError('Method not implemented!')



    def GetStream_kpi(self, request, context):

        """Missing associated documentation comment in .proto file."""

        context.set_code(grpc.StatusCode.UNIMPLEMENTED)

        context.set_details('Method not implemented!')

        raise NotImplementedError('Method not implemented!')



    def GetInstantKpi(self, request, context):

        """Missing associated documentation comment in .proto file."""

        context.set_code(grpc.StatusCode.UNIMPLEMENTED)

        context.set_details('Method not implemented!')

        raise NotImplementedError('Method not implemented!')





def add_MonitoringServiceServicer_to_server(servicer, server):

    rpc_method_handlers = {

            'IncludeKpi': grpc.unary_unary_rpc_method_handler(

                    servicer.IncludeKpi,

                    request_deserializer=monitoring__pb2.Kpi.FromString,

                    response_serializer=context__pb2.Empty.SerializeToString,

            ),

            'MonitorKpi': grpc.unary_unary_rpc_method_handler(

                    servicer.MonitorKpi,

                    request_deserializer=monitoring__pb2.KpiDevice.FromString,

                    response_serializer=context__pb2.Empty.SerializeToString,

            ),

            'GetStream_kpi': grpc.unary_stream_rpc_method_handler(

                    servicer.GetStream_kpi,

                    request_deserializer=monitoring__pb2.KpiId.FromString,

                    response_serializer=monitoring__pb2.Kpi.SerializeToString,

            ),

            'GetInstantKpi': grpc.unary_unary_rpc_method_handler(

                    servicer.GetInstantKpi,

                    request_deserializer=monitoring__pb2.KpiId.FromString,

                    response_serializer=monitoring__pb2.Kpi.SerializeToString,

            ),

    }

    generic_handler = grpc.method_handlers_generic_handler(

            'monitoring.MonitoringService', rpc_method_handlers)

    server.add_generic_rpc_handlers((generic_handler,))





 # This class is part of an EXPERIMENTAL API.

class MonitoringService(object):

    """Missing associated documentation comment in .proto file."""



    @staticmethod

    def IncludeKpi(request,

            target,

            options=(),

            channel_credentials=None,

            call_credentials=None,

            insecure=False,

            compression=None,

            wait_for_ready=None,

            timeout=None,

            metadata=None):

        return grpc.experimental.unary_unary(request, target, '/monitoring.MonitoringService/IncludeKpi',

            monitoring__pb2.Kpi.SerializeToString,

            context__pb2.Empty.FromString,

            options, channel_credentials,

            insecure, call_credentials, compression, wait_for_ready, timeout, metadata)



    @staticmethod

    def MonitorKpi(request,

            target,

            options=(),

            channel_credentials=None,

            call_credentials=None,

            insecure=False,

            compression=None,

            wait_for_ready=None,

            timeout=None,

            metadata=None):

        return grpc.experimental.unary_unary(request, target, '/monitoring.MonitoringService/MonitorKpi',

            monitoring__pb2.KpiDevice.SerializeToString,

            context__pb2.Empty.FromString,

            options, channel_credentials,

            insecure, call_credentials, compression, wait_for_ready, timeout, metadata)



    @staticmethod

    def GetStream_kpi(request,

            target,

            options=(),

            channel_credentials=None,

            call_credentials=None,

            insecure=False,

            compression=None,

            wait_for_ready=None,

            timeout=None,

            metadata=None):

        return grpc.experimental.unary_stream(request, target, '/monitoring.MonitoringService/GetStream_kpi',

            monitoring__pb2.KpiId.SerializeToString,

            monitoring__pb2.Kpi.FromString,

            options, channel_credentials,

            insecure, call_credentials, compression, wait_for_ready, timeout, metadata)



    @staticmethod

    def GetInstantKpi(request,

            target,

            options=(),

            channel_credentials=None,

            call_credentials=None,

            insecure=False,

            compression=None,

            wait_for_ready=None,

            timeout=None,

            metadata=None):

        return grpc.experimental.unary_unary(request, target, '/monitoring.MonitoringService/GetInstantKpi',

            monitoring__pb2.KpiId.SerializeToString,

            monitoring__pb2.Kpi.FromString,

            options, channel_credentials,

            insecure, call_credentials, compression, wait_for_ready, timeout, metadata)

src/l3_attackmitigator/proto/service_pb2.py

deleted100644 → 0
+0 −617

File deleted.

Preview size limit exceeded, changes collapsed.