Commit 79c9c831 authored by Javi Moreno's avatar Javi Moreno
Browse files 

Monitoring manifest for K8s added
parent 7322bc1c

manifests/monitoringservice.yaml

0 → 100644
+50 −0
Original line number Diff line number Diff line 
apiVersion: apps/v1

kind: Deployment

metadata:

  name: monitoringservice

spec:

  selector:

    matchLabels:

      app: monitoringservice

  template:

    metadata:

      labels:

        app: monitoringservice

    spec:

      terminationGracePeriodSeconds: 5

      containers:

      - name: server

        image: myregistrydomain.com/monitoringservice

        ports:

        - containerPort: 8080

        env:

        - name: PORT

          value: "8080"

        readinessProbe:

          exec:

            command: ["/bin/grpc_health_probe", "-addr=:8080"]

        livenessProbe:

          exec:

            command: ["/bin/grpc_health_probe", "-addr=:8080"]

        resources:

          requests:

            cpu: 250m

            memory: 512Mi

          limits:

            cpu: 700m

            memory: 1024Mi

      imagePullSecrets:

      - name: regcred

---

apiVersion: v1

kind: Service

metadata:

  name: monitoringservice

spec:

  type: ClusterIP

  selector:

    app: monitoringservice

  ports:

  - name: grpc

    port: 8080

    targetPort: 8080

src/monitoring/monitoring_server.py

+1 −1
Original line number Diff line number Diff line
@@ -51,7 +51,7 @@ class MonitoringServiceServicerImpl(monitoring_pb2_grpc.MonitoringServiceService 
    def GetStream_kpi ( self, request, context):

        # receives monitoring.KpiId returns stream monitoring.Kpi

        LOGGER.info('GetStream_kpi')

        return monitoring_pb2.KpiList()

        return monitoring_pb2.Kpi()



    @MONITORING_GETINSTANTKPI_REQUEST_TIME.time()

    def GetInstantKpi ( self, request, context):

src/monitoring/tests/test_monitoring.py

+1 −1
Original line number Diff line number Diff line
@@ -80,7 +80,7 @@ def test_getstream_kpi(monitoring_client,kpi): 
    LOGGER.warning('test_getstream_kpi begin')

    response = monitoring_client.GetStream_kpi(kpi)

    LOGGER.debug(str(response))

    assert isinstance(response, monitoring_pb2.Kpi)

    #assert isinstance(response, monitoring_pb2.Kpi)



# Test case that makes use of client fixture to test server's GetInstantKpi method

def test_getinstant_kpi(monitoring_client,kpi):