Merge branch 'develop' of https://labs.etsi.org/rep/tfs/controller into monitoring_fix (dcedce7f) · Commits · TFS / controller

deploy/crdb.sh

+5 −0

Original line number	Diff line number	Diff line
		@@ -167,6 +167,11 @@ function crdb_drop_database_single() {
		}

		function crdb_deploy_cluster() {
		echo "CockroachDB Operator Namespace"
		echo ">>> Create CockroachDB Operator Namespace (if missing)"
		kubectl apply -f "${CRDB_MANIFESTS_PATH}/pre_operator.yaml"
		echo

		echo "Cockroach Operator CRDs"
		echo ">>> Apply Cockroach Operator CRDs (if they are missing)"
		cp "${CRDB_MANIFESTS_PATH}/crds.yaml" "${TMP_MANIFESTS_FOLDER}/crdb_crds.yaml"

manifests/cockroachdb/pre_operator.yaml

0 → 100644

+19 −0

Original line number	Diff line number	Diff line
		# Copyright 2022 The Cockroach Authors
		#
		# Licensed under the Apache License, Version 2.0 (the "License");
		# you may not use this file except in compliance with the License.
		# You may obtain a copy of the License at
		#
		# https://www.apache.org/licenses/LICENSE-2.0
		#
		# Unless required by applicable law or agreed to in writing, software
		# distributed under the License is distributed on an "AS IS" BASIS,
		# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
		# See the License for the specific language governing permissions and
		# limitations under the License.
		apiVersion: v1
		kind: Namespace
		metadata:
		labels:
		control-plane: cockroach-operator
		name: cockroach-operator-system

manifests/contextservice.yaml

+6 −4

Original line number	Diff line number	Diff line
		@@ -23,6 +23,8 @@ spec:
		#replicas: 1
		template:
		metadata:
		annotations:
		config.linkerd.io/skip-outbound-ports: "4222"
		labels:
		app: contextservice
		spec:
		@@ -52,11 +54,11 @@ spec:
		command: ["/bin/grpc_health_probe", "-addr=:1010"]
		resources:
		requests:
		cpu: 75m
		memory: 64Mi
		limits:
		cpu: 100m
		cpu: 250m
		memory: 128Mi
		limits:
		cpu: 1000m
		memory: 1024Mi
		---
		apiVersion: v1
		kind: Service

src/common/message_broker/backend/nats/NatsBackendThread.py

+8 −1

Original line number	Diff line number	Diff line
		@@ -12,10 +12,12 @@
		# See the License for the specific language governing permissions and
		# limitations under the License.

		import asyncio, nats, nats.errors, queue, threading
		import asyncio, logging, nats, nats.errors, queue, threading
		from typing import List
		from common.message_broker.Message import Message

		LOGGER = logging.getLogger(__name__)

		class NatsBackendThread(threading.Thread):
		def __init__(self, nats_uri : str) -> None:
		self._nats_uri = nats_uri
		@@ -32,7 +34,9 @@ class NatsBackendThread(threading.Thread):
		self._tasks_terminated.set()

		async def _run_publisher(self) -> None:
		LOGGER.info('[_run_publisher] NATS URI: {:s}'.format(str(self._nats_uri)))
		client = await nats.connect(servers=[self._nats_uri])
		LOGGER.info('[_run_publisher] Connected!')
		while not self._terminate.is_set():
		try:
		message : Message = await self._publish_queue.get()
		@@ -47,8 +51,11 @@ class NatsBackendThread(threading.Thread):
		async def _run_subscriber(
		self, topic_name : str, timeout : float, out_queue : queue.Queue[Message], unsubscribe : threading.Event
		) -> None:
		LOGGER.info('[_run_subscriber] NATS URI: {:s}'.format(str(self._nats_uri)))
		client = await nats.connect(servers=[self._nats_uri])
		LOGGER.info('[_run_subscriber] Connected!')
		subscription = await client.subscribe(topic_name)
		LOGGER.info('[_run_subscriber] Subscribed!')
		while not self._terminate.is_set() and not unsubscribe.is_set():
		try:
		message = await subscription.next_msg(timeout)

src/tests/ofc22/descriptors_emulated.json

+29 −0

Original line number	Diff line number	Diff line
		@@ -97,6 +97,35 @@
		{"device_id": {"device_uuid": {"uuid": "R4-EMU"}}, "endpoint_uuid": {"uuid": "13/0/0"}},
		{"device_id": {"device_uuid": {"uuid": "O1-OLS"}}, "endpoint_uuid": {"uuid": "50296d99-58cc-5ce7-82f5-fc8ee4eec2ec"}}
		]
		},

		{
		"link_id": {"link_uuid": {"uuid": "O1-OLS==R1-EMU/13/0/0/aade6001-f00b-5e2f-a357-6a0a9d3de870"}},
		"link_endpoint_ids": [
		{"device_id": {"device_uuid": {"uuid": "O1-OLS"}}, "endpoint_uuid": {"uuid": "aade6001-f00b-5e2f-a357-6a0a9d3de870"}},
		{"device_id": {"device_uuid": {"uuid": "R1-EMU"}}, "endpoint_uuid": {"uuid": "13/0/0"}}
		]
		},
		{
		"link_id": {"link_uuid": {"uuid": "O1-OLS==R2-EMU/13/0/0/eb287d83-f05e-53ec-ab5a-adf6bd2b5418"}},
		"link_endpoint_ids": [
		{"device_id": {"device_uuid": {"uuid": "O1-OLS"}}, "endpoint_uuid": {"uuid": "eb287d83-f05e-53ec-ab5a-adf6bd2b5418"}},
		{"device_id": {"device_uuid": {"uuid": "R2-EMU"}}, "endpoint_uuid": {"uuid": "13/0/0"}}
		]
		},
		{
		"link_id": {"link_uuid": {"uuid": "O1-OLS==R3-EMU/13/0/0/0ef74f99-1acc-57bd-ab9d-4b958b06c513"}},
		"link_endpoint_ids": [
		{"device_id": {"device_uuid": {"uuid": "O1-OLS"}}, "endpoint_uuid": {"uuid": "0ef74f99-1acc-57bd-ab9d-4b958b06c513"}},
		{"device_id": {"device_uuid": {"uuid": "R3-EMU"}}, "endpoint_uuid": {"uuid": "13/0/0"}}
		]
		},
		{
		"link_id": {"link_uuid": {"uuid": "O1-OLS==R4-EMU/13/0/0/50296d99-58cc-5ce7-82f5-fc8ee4eec2ec"}},
		"link_endpoint_ids": [
		{"device_id": {"device_uuid": {"uuid": "O1-OLS"}}, "endpoint_uuid": {"uuid": "50296d99-58cc-5ce7-82f5-fc8ee4eec2ec"}},
		{"device_id": {"device_uuid": {"uuid": "R4-EMU"}}, "endpoint_uuid": {"uuid": "13/0/0"}}
		]
		}
		]
		}
		No newline at end of file