Reverse context and device from monitoring-service merge (62f027b9) · Commits · TFS / controller

src/common/message_broker/Factory.py

+2 −2

Original line number	Diff line number	Diff line
		@@ -3,13 +3,13 @@ from typing import Optional, Union
		from .backend._Backend import _Backend
		from .backend.BackendEnum import BackendEnum
		from .backend.inmemory.InMemoryBackend import InMemoryBackend
		# from .backend.redis.RedisBackend import RedisBackend
		from .backend.redis.RedisBackend import RedisBackend

		LOGGER = logging.getLogger(__name__)

		BACKENDS = {
		BackendEnum.INMEMORY.value: InMemoryBackend,
		# BackendEnum.REDIS.value: RedisBackend,
		BackendEnum.REDIS.value: RedisBackend,
		#BackendEnum.KAFKA.value: KafkaBackend,
		#BackendEnum.RABBITMQ.value: RabbitMQBackend,
		#BackendEnum.ZEROMQ.value: ZeroMQBackend,

src/common/orm/Factory.py

+2 −2

Original line number	Diff line number	Diff line
		@@ -3,13 +3,13 @@ from typing import Optional, Union
		from .backend._Backend import _Backend
		from .backend.BackendEnum import BackendEnum
		from .backend.inmemory.InMemoryBackend import InMemoryBackend
		# from .backend.redis.RedisBackend import RedisBackend
		from .backend.redis.RedisBackend import RedisBackend

		LOGGER = logging.getLogger(__name__)

		BACKENDS = {
		BackendEnum.INMEMORY.value: InMemoryBackend,
		# BackendEnum.REDIS.value: RedisBackend,
		BackendEnum.REDIS.value: RedisBackend,
		#BackendEnum.MONGODB.value: MongoDBBackend,
		#BackendEnum.RETHINKDB.value: RethinkDBBackend,
		#BackendEnum.ETCD.value: EtcdBackend,

src/context/proto/context_pb2.py

+98 −108

File changed.

Preview size limit exceeded, changes collapsed.

src/context/proto/context_pb2_grpc.py

+9 −3

Original line number	Diff line number	Diff line
		@@ -6,7 +6,9 @@ from . import context_pb2 as context__pb2


		class ContextServiceStub(object):
		"""Missing associated documentation comment in .proto file."""
		"""import "kpi_sample_types.proto";

		"""

		def __init__(self, channel):
		"""Constructor.
		@@ -167,7 +169,9 @@ class ContextServiceStub(object):


		class ContextServiceServicer(object):
		"""Missing associated documentation comment in .proto file."""
		"""import "kpi_sample_types.proto";

		"""

		def ListContextIds(self, request, context):
		"""Missing associated documentation comment in .proto file."""
		@@ -510,7 +514,9 @@ def add_ContextServiceServicer_to_server(servicer, server):

		# This class is part of an EXPERIMENTAL API.
		class ContextService(object):
		"""Missing associated documentation comment in .proto file."""
		"""import "kpi_sample_types.proto";

		"""

		@staticmethod
		def ListContextIds(request,

src/context/proto/kpi_sample_types_pb2.py

+2 −50

Original line number	Diff line number	Diff line
		@@ -2,7 +2,6 @@
		# Generated by the protocol buffer compiler. DO NOT EDIT!
		# source: kpi_sample_types.proto
		"""Generated protocol buffer code."""
		from google.protobuf.internal import enum_type_wrapper
		from google.protobuf import descriptor as _descriptor
		from google.protobuf import message as _message
		from google.protobuf import reflection as _reflection
		@@ -16,62 +15,15 @@ _sym_db = _symbol_database.Default()

		DESCRIPTOR = _descriptor.FileDescriptor(
		name='kpi_sample_types.proto',
		package='kpi_sample_types',
		package='',
		syntax='proto3',
		serialized_options=None,
		create_key=_descriptor._internal_create_key,
		serialized_pb=b'\n\x16kpi_sample_types.proto\x12\x10kpi_sample_types*x\n\rKpiSampleType\x12\x0b\n\x07UNKNOWN\x10\x00\x12\x17\n\x13PACKETS_TRANSMITTED\x10\x65\x12\x14\n\x10PACKETS_RECEIVED\x10\x66\x12\x16\n\x11\x42YTES_TRANSMITTED\x10\xc9\x01\x12\x13\n\x0e\x42YTES_RECEIVED\x10\xca\x01\x62\x06proto3'
		serialized_pb=b'\n\x16kpi_sample_types.protob\x06proto3'
		)

		_KPISAMPLETYPE = _descriptor.EnumDescriptor(
		name='KpiSampleType',
		full_name='kpi_sample_types.KpiSampleType',
		filename=None,
		file=DESCRIPTOR,
		create_key=_descriptor._internal_create_key,
		values=[
		_descriptor.EnumValueDescriptor(
		name='UNKNOWN', index=0, number=0,
		serialized_options=None,
		type=None,
		create_key=_descriptor._internal_create_key),
		_descriptor.EnumValueDescriptor(
		name='PACKETS_TRANSMITTED', index=1, number=101,
		serialized_options=None,
		type=None,
		create_key=_descriptor._internal_create_key),
		_descriptor.EnumValueDescriptor(
		name='PACKETS_RECEIVED', index=2, number=102,
		serialized_options=None,
		type=None,
		create_key=_descriptor._internal_create_key),
		_descriptor.EnumValueDescriptor(
		name='BYTES_TRANSMITTED', index=3, number=201,
		serialized_options=None,
		type=None,
		create_key=_descriptor._internal_create_key),
		_descriptor.EnumValueDescriptor(
		name='BYTES_RECEIVED', index=4, number=202,
		serialized_options=None,
		type=None,
		create_key=_descriptor._internal_create_key),
		],
		containing_type=None,
		serialized_options=None,
		serialized_start=44,
		serialized_end=164,
		)
		_sym_db.RegisterEnumDescriptor(_KPISAMPLETYPE)

		KpiSampleType = enum_type_wrapper.EnumTypeWrapper(_KPISAMPLETYPE)
		UNKNOWN = 0
		PACKETS_TRANSMITTED = 101
		PACKETS_RECEIVED = 102
		BYTES_TRANSMITTED = 201
		BYTES_RECEIVED = 202


		DESCRIPTOR.enum_types_by_name['KpiSampleType'] = _KPISAMPLETYPE
		_sym_db.RegisterFileDescriptor(DESCRIPTOR)