Source code for ceilometer.neutron_client

# Copyright (C) 2014 eNovance SAS <licensing@enovance.com>
#
# 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.

import functools

from neutronclient.common import exceptions
from neutronclient.v2_0 import client as clientv20
from oslo_config import cfg

from ceilometer.openstack.common import log


SERVICE_OPTS = [
    cfg.StrOpt('neutron',
               default='network',
               help='Neutron service type.'),
]

cfg.CONF.register_opts(SERVICE_OPTS, group='service_types')
cfg.CONF.import_opt('http_timeout', 'ceilometer.service')
cfg.CONF.import_group('service_credentials', 'ceilometer.service')

LOG = log.getLogger(__name__)


def logged(func):

    @functools.wraps(func)
    def with_logging(*args, **kwargs):
        try:
            return func(*args, **kwargs)
        except exceptions.NotFound:
            # handles 404's when services are disabled in neutron
            LOG.warn("The resource could not be found.")
            return []
        except exceptions.NeutronClientException as e:
            LOG.warn(e)
            return []
        except Exception as e:
            LOG.exception(e)
            raise

    return with_logging


[docs]class Client(object): """A client which gets information via python-neutronclient.""" def __init__(self): conf = cfg.CONF.service_credentials params = { 'insecure': conf.insecure, 'ca_cert': conf.os_cacert, 'username': conf.os_username, 'password': conf.os_password, 'auth_url': conf.os_auth_url, 'region_name': conf.os_region_name, 'endpoint_type': conf.os_endpoint_type, 'timeout': cfg.CONF.http_timeout, 'service_type': cfg.CONF.service_types.neutron, } if conf.os_tenant_id: params['tenant_id'] = conf.os_tenant_id else: params['tenant_name'] = conf.os_tenant_name self.client = clientv20.Client(**params) @logged
[docs] def network_get_all(self): """Returns all networks.""" resp = self.client.list_networks() return resp.get('networks')
@logged
[docs] def port_get_all(self): resp = self.client.list_ports() return resp.get('ports')
@logged
[docs] def vip_get_all(self): resp = self.client.list_vips() return resp.get('vips')
@logged
[docs] def pool_get_all(self): resp = self.client.list_pools() return resp.get('pools')
@logged
[docs] def member_get_all(self): resp = self.client.list_members() return resp.get('members')
@logged
[docs] def health_monitor_get_all(self): resp = self.client.list_health_monitors() return resp.get('health_monitors')
@logged
[docs] def pool_stats(self, pool): return self.client.retrieve_pool_stats(pool)
@logged
[docs] def vpn_get_all(self): resp = self.client.list_vpnservices() return resp.get('vpnservices')
@logged
[docs] def ipsec_site_connections_get_all(self): resp = self.client.list_ipsec_site_connections() return resp.get('ipsec_site_connections')
@logged
[docs] def firewall_get_all(self): resp = self.client.list_firewalls() return resp.get('firewalls')
@logged
[docs] def fw_policy_get_all(self): resp = self.client.list_firewall_policies() return resp.get('firewall_policies')