X-Git-Url: https://osm.etsi.org/gitweb/?p=osm%2Fvim-emu.git;a=blobdiff_plain;f=src%2Femuvim%2Fexamples%2Fsimple_topology_restapi.py;h=eabec443cf44ab45ba47623f150e703714615089;hp=121e2ef2d7a5c2ee0765ec32efef02fd9dd52f7b;hb=b1a426eeed8b2611e908869366ea0ab82c27ce36;hpb=f3bf0e72a2df0a10a62565279a71598f5d9c6e63 diff --git a/src/emuvim/examples/simple_topology_restapi.py b/src/emuvim/examples/simple_topology_restapi.py old mode 100644 new mode 100755 index 121e2ef..eabec44 --- a/src/emuvim/examples/simple_topology_restapi.py +++ b/src/emuvim/examples/simple_topology_restapi.py @@ -1,26 +1,36 @@ """ -This is an example topology for the distributed cloud emulator (dcemulator). -(c) 2015 by Manuel Peuster - - -This is an example that shows how a user of the emulation tool can -define network topologies with multiple emulated cloud data centers. - -The definition is done with a Python API which looks very similar to the -Mininet API (in fact it is a wrapper for it). - -We only specify the topology *between* data centers not within a single -data center (data center internal setups or placements are not of interest, -we want to experiment with VNF chains deployed across multiple PoPs). - -The original Mininet API has to be completely hidden and not be used by this -script. +Copyright (c) 2015 SONATA-NFV +ALL RIGHTS RESERVED. + +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. + +Neither the name of the SONATA-NFV [, ANY ADDITIONAL AFFILIATION] +nor the names of its contributors may be used to endorse or promote +products derived from this software without specific prior written +permission. + +This work has been performed in the framework of the SONATA project, +funded by the European Commission under Grant number 671517 through +the Horizon 2020 and 5G-PPP programmes. The authors would like to +acknowledge the contributions of their colleagues of the SONATA +partner consortium (www.sonata-nfv.eu). """ import logging from mininet.log import setLogLevel from emuvim.dcemulator.net import DCNetwork -from emuvim.api.rest.compute import RestApiEndpoint -#from emuvim.api.zerorpc.compute import ZeroRpcApiEndpoint +from emuvim.api.rest.rest_api_endpoint import RestApiEndpoint + +from emuvim.api.zerorpc.compute import ZeroRpcApiEndpoint from emuvim.api.zerorpc.network import ZeroRpcApiEndpointDCNetwork logging.basicConfig(level=logging.INFO) @@ -30,11 +40,12 @@ def create_topology1(): """ 1. Create a data center network object (DCNetwork) """ - net = DCNetwork() + net = DCNetwork(monitor=True, enable_learning=True) """ 1b. add a monitoring agent to the DCNetwork """ + #keep old zeroRPC interface to test the prometheus metric query mon_api = ZeroRpcApiEndpointDCNetwork("0.0.0.0", 5151) mon_api.connectDCNetwork(net) mon_api.start() @@ -76,13 +87,23 @@ def create_topology1(): one or more data centers to it, which can then be controlled through this API, e.g., start/stop/list compute instances. """ + # keep the old zeroRPC interface for the prometheus metric query test + zapi1 = ZeroRpcApiEndpoint("0.0.0.0", 4242) + # connect data centers to this endpoint + zapi1.connectDatacenter(dc1) + zapi1.connectDatacenter(dc2) + # run API endpoint server (in another thread, don't block) + zapi1.start() + # create a new instance of a endpoint implementation - api1 = RestApiEndpoint("127.0.0.1", 5000) + api1 = RestApiEndpoint("127.0.0.1", 5001) # connect data centers to this endpoint api1.connectDatacenter(dc1) api1.connectDatacenter(dc2) api1.connectDatacenter(dc3) api1.connectDatacenter(dc4) + # connect total network also, needed to do the chaining and monitoring + api1.connectDCNetwork(net) # run API endpoint server (in another thread, don't block) api1.start()