Commit dc405d13 authored by Leandro Campos's avatar Leandro Campos
Browse files

NBI

parent 20d2c4df

deploy/all.sh

+2 −2
Original line number Original line Diff line number Diff line
@@ -117,7 +117,7 @@ export CRDB_DEPLOY_MODE=${CRDB_DEPLOY_MODE:-"single"} 
# WARNING: ACTIVATING THIS FLAG IMPLIES LOOSING THE DATABASE INFORMATION!

# WARNING: ACTIVATING THIS FLAG IMPLIES LOOSING THE DATABASE INFORMATION!

# If CRDB_DROP_DATABASE_IF_EXISTS is "YES", the databases starting with "tfs_" will be dropped while

# If CRDB_DROP_DATABASE_IF_EXISTS is "YES", the databases starting with "tfs_" will be dropped while

# checking/deploying CockroachDB.

# checking/deploying CockroachDB.

export CRDB_DROP_DATABASE_IF_EXISTS=${CRDB_DROP_DATABASE_IF_EXISTS:-""}

export CRDB_DROP_DATABASE_IF_EXISTS=${CRDB_DROP_DATABASE_IF_EXISTS:-"YES"}





# If not already set, disable flag for re-deploying CockroachDB from scratch.

# If not already set, disable flag for re-deploying CockroachDB from scratch.

# WARNING: ACTIVATING THIS FLAG IMPLIES LOOSING THE DATABASE INFORMATION!

# WARNING: ACTIVATING THIS FLAG IMPLIES LOOSING THE DATABASE INFORMATION!
@@ -202,7 +202,7 @@ export QDB_TABLE_SLICE_GROUPS=${QDB_TABLE_SLICE_GROUPS:-"tfs_slice_groups"} 
# If QDB_DROP_TABLES_IF_EXIST is "YES", the tables pointed by variables

# If QDB_DROP_TABLES_IF_EXIST is "YES", the tables pointed by variables

# QDB_TABLE_MONITORING_KPIS and QDB_TABLE_SLICE_GROUPS will be dropped while

# QDB_TABLE_MONITORING_KPIS and QDB_TABLE_SLICE_GROUPS will be dropped while

# checking/deploying QuestDB.

# checking/deploying QuestDB.

export QDB_DROP_TABLES_IF_EXIST=${QDB_DROP_TABLES_IF_EXIST:-""}

export QDB_DROP_TABLES_IF_EXIST=${QDB_DROP_TABLES_IF_EXIST:-"YES"}





# If not already set, disable flag for re-deploying QuestDB from scratch.

# If not already set, disable flag for re-deploying QuestDB from scratch.

# WARNING: ACTIVATING THIS FLAG IMPLIES LOOSING THE DATABASE INFORMATION!

# WARNING: ACTIVATING THIS FLAG IMPLIES LOOSING THE DATABASE INFORMATION!

quick_deploy.sh

0 → 100755
+438 −0

File added.

Preview size limit exceeded, changes collapsed.

src/nbi/service/rest_server/nbi_plugins/ietf_network_bw/NameMapping.py

0 → 100644
+46 −0
Original line number Original line Diff line number Diff line 
# Copyright 2022-2024 ETSI SDG TeraFlowSDN (TFS) (https://tfs.etsi.org/)

#

# 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

#

#      http://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.



from typing import Dict, Tuple

from common.proto.context_pb2 import Device, DeviceId, EndPoint, EndPointId



class NameMappings:

    def __init__(self) -> None:

        self._device_uuid_to_name   : Dict[str,             str] = dict()

        self._endpoint_uuid_to_name : Dict[Tuple[str, str], str] = dict()



    def store_device_name(self, device : Device) -> None:

        device_uuid = device.device_id.device_uuid.uuid

        device_name = device.name

        self._device_uuid_to_name[device_uuid] = device_name

        self._device_uuid_to_name[device_name] = device_name



    def store_endpoint_name(self, device : Device, endpoint : EndPoint) -> None:

        device_uuid = device.device_id.device_uuid.uuid

        device_name = device.name

        endpoint_uuid = endpoint.endpoint_id.endpoint_uuid.uuid

        endpoint_name = endpoint.name

        self._endpoint_uuid_to_name[(device_uuid, endpoint_uuid)] = endpoint_name

        self._endpoint_uuid_to_name[(device_name, endpoint_uuid)] = endpoint_name

        self._endpoint_uuid_to_name[(device_uuid, endpoint_name)] = endpoint_name

        self._endpoint_uuid_to_name[(device_name, endpoint_name)] = endpoint_name



    def get_device_name(self, device_id : DeviceId) -> str:

        device_uuid = device_id.device_uuid.uuid

        return self._device_uuid_to_name.get(device_uuid, device_uuid)



    def get_endpoint_name(self, endpoint_id : EndPointId) -> str:

        device_uuid = endpoint_id.device_id.device_uuid.uuid

        endpoint_uuid = endpoint_id.endpoint_uuid.uuid

        return self._endpoint_uuid_to_name.get((device_uuid, endpoint_uuid), endpoint_uuid)

src/nbi/service/rest_server/nbi_plugins/ietf_network_bw/NetworkTypeEnum.py

0 → 100644
+23 −0
Original line number Original line Diff line number Diff line 
# Copyright 2022-2024 ETSI SDG TeraFlowSDN (TFS) (https://tfs.etsi.org/)

#

# 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

#

#      http://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.



from enum import Enum

from typing import Optional



class NetworkTypeEnum(Enum):

    TE_OTN_TOPOLOGY      = 'otn'

    TE_ETH_TRAN_TOPOLOGY = 'eth-tran'



def get_network_topology_type(topology_id : str) -> Optional[NetworkTypeEnum]:

    return NetworkTypeEnum._value2member_map_.get(topology_id)

src/nbi/service/rest_server/nbi_plugins/ietf_network_bw/Networks_bw.py

0 → 100644
+85 −0

File added.

Preview size limit exceeded, changes collapsed.