X-Git-Url: https://osm.etsi.org/gitweb/?a=blobdiff_plain;f=src%2Femuvim%2Fapi%2Frest%2Frest_api_endpoint.py;h=7168f37b60ed4c754e46944fa2b36ac4a63cdae1;hb=5ec2cabc29fabd63769c96c60c8008182fc0ab72;hp=6c69a0370b5eb5aa623210f0030b4e9b7e9db77c;hpb=8945ecfc73514b99b6798dfe774263a45df2896d;p=osm%2Fvim-emu.git diff --git a/src/emuvim/api/rest/rest_api_endpoint.py b/src/emuvim/api/rest/rest_api_endpoint.py index 6c69a03..7168f37 100755 --- a/src/emuvim/api/rest/rest_api_endpoint.py +++ b/src/emuvim/api/rest/rest_api_endpoint.py @@ -1,3 +1,30 @@ +""" +Copyright (c) 2015 SONATA-NFV and Paderborn University +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 import threading from flask import Flask @@ -5,21 +32,19 @@ from flask_restful import Api # need to import total module to set its global variable dcs import compute -from compute import dcs, ComputeList, ComputeStart, ComputeStatus, ComputeStop, DatacenterList, DatacenterStatus +from compute import dcs, ComputeList, Compute, DatacenterList, DatacenterStatus # need to import total module to set its global variable net import network from network import NetworkAction import monitor -from monitor import MonitorInterfaceAction, MonitorFlowAction +from monitor import MonitorInterfaceAction, MonitorFlowAction, MonitorLinkAction, MonitorSkewAction logging.basicConfig(level=logging.INFO) - class RestApiEndpoint(object): - """ Simple API endpoint that offers a REST interface. This interface will be used by the @@ -35,27 +60,51 @@ class RestApiEndpoint(object): self.api = Api(self.app) # setup endpoints - self.api.add_resource(ComputeList, "/restapi/compute/") - self.api.add_resource(ComputeStart, "/restapi/compute///start") - self.api.add_resource(ComputeStop, "/restapi/compute///stop") - self.api.add_resource(ComputeStatus, "/restapi/compute//") - self.api.add_resource(DatacenterList, "/restapi/datacenter") + + # compute related actions (start/stop VNFs, get info) + self.api.add_resource(Compute, + "/restapi/compute//", + "/restapi/compute////") + self.api.add_resource(ComputeList, + "/restapi/compute", + "/restapi/compute/") + self.api.add_resource(DatacenterStatus, "/restapi/datacenter/") + self.api.add_resource(DatacenterList, "/restapi/datacenter") - self.api.add_resource(NetworkAction, "/restapi/network//") - self.api.add_resource(MonitorInterfaceAction, "/restapi/monitor///") - self.api.add_resource(MonitorFlowAction, "/restapi/monitor////") + # network related actions (setup chaining between VNFs) + self.api.add_resource(NetworkAction, + "/restapi/network//") + + + # monitoring related actions + # export a network interface traffic rate counter + self.api.add_resource(MonitorInterfaceAction, + "/restapi/monitor/interface//", + "/restapi/monitor/interface///", + "/restapi/monitor/interface////") + # export flow traffic counter, of a manually pre-installed flow entry, specified by its cookie + self.api.add_resource(MonitorFlowAction, + "/restapi/monitor/flow///", + "/restapi/monitor/flow////") + # install monitoring of a specific flow on a pre-existing link in the service. + # the traffic counters of the newly installed monitor flow are exported + self.api.add_resource(MonitorLinkAction, + "/restapi/monitor/link//") + # install skewness monitor of resource usage disribution + # the skewness metric is exported + self.api.add_resource(MonitorSkewAction, + "/restapi/monitor/skewness//") logging.debug("Created API endpoint %s(%s:%d)" % (self.__class__.__name__, self.ip, self.port)) - def connectDatacenter(self, dc): compute.dcs[dc.label] = dc - logging.info("Connected DC(%s) to API endpoint %s(%s:%d)" % (dc.label, self.__class__.__name__, self.ip, self.port)) + logging.info( + "Connected DC(%s) to API endpoint %s(%s:%d)" % (dc.label, self.__class__.__name__, self.ip, self.port)) def connectDCNetwork(self, DCnetwork): - network.net = DCnetwork monitor.net = DCnetwork @@ -63,11 +112,10 @@ class RestApiEndpoint(object): self.__class__.__name__, self.ip, self.port)) def start(self): - thread = threading.Thread(target= self._start_flask, args=()) + thread = threading.Thread(target=self._start_flask, args=()) thread.daemon = True thread.start() logging.info("Started API endpoint @ http://%s:%d" % (self.ip, self.port)) - def _start_flask(self): - self.app.run(self.ip, self.port, debug=True, use_reloader=False) \ No newline at end of file + self.app.run(self.ip, self.port, debug=True, use_reloader=False)