Upcoming maintenance: Thursday 21 August @ 12:00-14:00 CEST.

Skip to content
Snippets Groups Projects
Commit 3ca856bb authored by Javier Moreno's avatar Javier Moreno
Browse files

Updated last commit

parent 0148f285
No related branches found
No related tags found
1 merge request!5Feat/monitoring subscriptions
...@@ -64,6 +64,11 @@ def include_kpi_request(kpi_id): ...@@ -64,6 +64,11 @@ def include_kpi_request(kpi_id):
_include_kpi_request.kpi_value.int32Val = 500 # pylint: disable=maybe-no-member _include_kpi_request.kpi_value.int32Val = 500 # pylint: disable=maybe-no-member
return _include_kpi_request return _include_kpi_request
def kpi_descriptor_list():
_kpi_descriptor_list = monitoring_pb2.KpiDescriptorList()
return _kpi_descriptor_list
def kpi_query(): def kpi_query():
_kpi_query = monitoring_pb2.KpiQuery() _kpi_query = monitoring_pb2.KpiQuery()
......
...@@ -28,7 +28,7 @@ from common.message_broker.Factory import get_messagebroker_backend, BackendEnum ...@@ -28,7 +28,7 @@ from common.message_broker.Factory import get_messagebroker_backend, BackendEnum
from common.message_broker.MessageBroker import MessageBroker from common.message_broker.MessageBroker import MessageBroker
from common.proto import monitoring_pb2 from common.proto import monitoring_pb2
from common.proto.monitoring_pb2 import KpiId, KpiDescriptor, KpiList, SubsDescriptor, SubsIDList, AlarmID, \ from common.proto.monitoring_pb2 import KpiId, KpiDescriptor, KpiList, SubsDescriptor, SubsIDList, AlarmID, \
AlarmDescriptor, AlarmIDList, Kpi AlarmDescriptor, AlarmIDList, Kpi, KpiDescriptorList
from context.client.ContextClient import ContextClient from context.client.ContextClient import ContextClient
from context.service.grpc_server.ContextService import ContextService from context.service.grpc_server.ContextService import ContextService
...@@ -46,7 +46,8 @@ from monitoring.service import SqliteTools, MetricsDBTools ...@@ -46,7 +46,8 @@ from monitoring.service import SqliteTools, MetricsDBTools
from monitoring.service.MonitoringService import MonitoringService from monitoring.service.MonitoringService import MonitoringService
from monitoring.service.EventTools import EventsDeviceCollector from monitoring.service.EventTools import EventsDeviceCollector
from monitoring.tests.Messages import create_kpi_request, include_kpi_request, monitor_kpi_request, \ from monitoring.tests.Messages import create_kpi_request, include_kpi_request, monitor_kpi_request, \
create_kpi_request_b, create_kpi_request_c, kpi_query, subs_descriptor, subs_id, alarm_descriptor, alarm_id, kpi_id create_kpi_request_b, create_kpi_request_c, kpi_query, subs_descriptor, subs_id, alarm_descriptor, alarm_id, kpi_id, \
kpi_descriptor_list
from monitoring.tests.Objects import DEVICE_DEV1, DEVICE_DEV1_CONNECT_RULES, DEVICE_DEV1_UUID from monitoring.tests.Objects import DEVICE_DEV1, DEVICE_DEV1_CONNECT_RULES, DEVICE_DEV1_UUID
from monitoring.service.MonitoringServiceServicerImpl import LOGGER from monitoring.service.MonitoringServiceServicerImpl import LOGGER
...@@ -189,7 +190,7 @@ def test_delete_kpi(monitoring_client): # pylint: disable=redefined-outer-name ...@@ -189,7 +190,7 @@ def test_delete_kpi(monitoring_client): # pylint: disable=redefined-outer-name
LOGGER.debug(str(response)) LOGGER.debug(str(response))
assert isinstance(response, Empty) assert isinstance(response, Empty)
# Test case that makes use of client fixture to test server's GetInstantKpi method # Test case that makes use of client fixture to test server's GetKpiDescriptor method
def test_get_kpidescritor(monitoring_client): # pylint: disable=redefined-outer-name def test_get_kpidescritor(monitoring_client): # pylint: disable=redefined-outer-name
LOGGER.warning('test_getkpidescritor_kpi begin') LOGGER.warning('test_getkpidescritor_kpi begin')
response = monitoring_client.SetKpi(create_kpi_request_c()) response = monitoring_client.SetKpi(create_kpi_request_c())
...@@ -198,6 +199,13 @@ def test_get_kpidescritor(monitoring_client): # pylint: disable=redefined-outer- ...@@ -198,6 +199,13 @@ def test_get_kpidescritor(monitoring_client): # pylint: disable=redefined-outer-
# LOGGER.debug(str(response)) # LOGGER.debug(str(response))
assert isinstance(response, KpiDescriptor) assert isinstance(response, KpiDescriptor)
# Test case that makes use of client fixture to test server's GetKpiDescriptor method
def test_get_kpi_descriptor_list(monitoring_client): # pylint: disable=redefined-outer-name
LOGGER.warning('test_getkpidescritor_kpi begin')
response = monitoring_client.GetKpiDescriptorList(kpi_descriptor_list())
# LOGGER.debug(str(response))
assert isinstance(response, KpiDescriptorList)
# Test case that makes use of client fixture to test server's IncludeKpi method # Test case that makes use of client fixture to test server's IncludeKpi method
def test_include_kpi(monitoring_client): # pylint: disable=redefined-outer-name def test_include_kpi(monitoring_client): # pylint: disable=redefined-outer-name
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment