821ce1c3f4
Previously several types of name are used for same type operations in Neutron releated API method names. * XXXX_modify -> XXXX_update * <plural>_get -> <singular>_list * <plural>_list -> <singular>_list Closes-Bug: #1261283 Change-Id: I95c268822d1a55ea0440b44ea2c7993979ee4c36
333 lines
11 KiB
Python
333 lines
11 KiB
Python
# vim: tabstop=4 shiftwidth=4 softtabstop=4
|
|
|
|
# Copyright 2013, Big Switch Networks, Inc.
|
|
#
|
|
# 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 __future__ import absolute_import
|
|
|
|
from openstack_dashboard.api import neutron
|
|
|
|
neutronclient = neutron.neutronclient
|
|
|
|
|
|
class Vip(neutron.NeutronAPIDictWrapper):
|
|
"""Wrapper for neutron load balancer vip."""
|
|
|
|
def __init__(self, apiresource):
|
|
super(Vip, self).__init__(apiresource)
|
|
|
|
|
|
class Pool(neutron.NeutronAPIDictWrapper):
|
|
"""Wrapper for neutron load balancer pool."""
|
|
|
|
def __init__(self, apiresource):
|
|
if 'provider' not in apiresource:
|
|
apiresource['provider'] = None
|
|
super(Pool, self).__init__(apiresource)
|
|
|
|
class AttributeDict(dict):
|
|
def __getattr__(self, attr):
|
|
return self[attr]
|
|
|
|
def __setattr__(self, attr, value):
|
|
self[attr] = value
|
|
|
|
def readable(self, request):
|
|
pFormatted = {'id': self.id,
|
|
'name': self.name,
|
|
'description': self.description,
|
|
'status': self.status,
|
|
'protocol': self.protocol,
|
|
'health_monitors': self.health_monitors,
|
|
'provider': self.provider}
|
|
try:
|
|
pFormatted['subnet_id'] = self.subnet_id
|
|
pFormatted['subnet_name'] = neutron.subnet_get(
|
|
request, self.subnet_id).cidr
|
|
except Exception:
|
|
pFormatted['subnet_id'] = self.subnet_id
|
|
pFormatted['subnet_name'] = self.subnet_id
|
|
|
|
if self.vip_id is not None:
|
|
try:
|
|
pFormatted['vip_id'] = self.vip_id
|
|
pFormatted['vip_name'] = vip_get(
|
|
request, self.vip_id).name
|
|
except Exception:
|
|
pFormatted['vip_id'] = self.vip_id
|
|
pFormatted['vip_name'] = self.vip_id
|
|
else:
|
|
pFormatted['vip_id'] = None
|
|
pFormatted['vip_name'] = None
|
|
|
|
return self.AttributeDict(pFormatted)
|
|
|
|
|
|
class Member(neutron.NeutronAPIDictWrapper):
|
|
"""Wrapper for neutron load balancer member."""
|
|
|
|
def __init__(self, apiresource):
|
|
super(Member, self).__init__(apiresource)
|
|
|
|
class AttributeDict(dict):
|
|
def __getattr__(self, attr):
|
|
return self[attr]
|
|
|
|
def __setattr__(self, attr, value):
|
|
self[attr] = value
|
|
|
|
def readable(self, request):
|
|
mFormatted = {'id': self.id,
|
|
'status': self.status,
|
|
'address': self.address,
|
|
'protocol_port': self.protocol_port}
|
|
try:
|
|
mFormatted['pool_id'] = self.pool_id
|
|
mFormatted['pool_name'] = pool_get(
|
|
request, self.pool_id).name
|
|
except Exception:
|
|
mFormatted['pool_id'] = self.pool_id
|
|
mFormatted['pool_name'] = self.pool_id
|
|
|
|
return self.AttributeDict(mFormatted)
|
|
|
|
|
|
class PoolStats(neutron.NeutronAPIDictWrapper):
|
|
"""Wrapper for neutron load balancer pool stats."""
|
|
|
|
def __init__(self, apiresource):
|
|
super(PoolStats, self).__init__(apiresource)
|
|
|
|
|
|
class PoolMonitor(neutron.NeutronAPIDictWrapper):
|
|
"""Wrapper for neutron load balancer pool health monitor."""
|
|
|
|
def __init__(self, apiresource):
|
|
super(PoolMonitor, self).__init__(apiresource)
|
|
|
|
|
|
def vip_create(request, **kwargs):
|
|
"""Create a vip for a specified pool.
|
|
|
|
:param request: request context
|
|
:param address: virtual IP address
|
|
:param name: name for vip
|
|
:param description: description for vip
|
|
:param subnet_id: subnet_id for subnet of vip
|
|
:param protocol_port: transport layer port number for vip
|
|
:returns: Vip object
|
|
"""
|
|
body = {'vip': {'name': kwargs['name'],
|
|
'description': kwargs['description'],
|
|
'subnet_id': kwargs['subnet_id'],
|
|
'protocol_port': kwargs['protocol_port'],
|
|
'protocol': kwargs['protocol'],
|
|
'pool_id': kwargs['pool_id'],
|
|
'session_persistence': kwargs['session_persistence'],
|
|
'admin_state_up': kwargs['admin_state_up']
|
|
}}
|
|
if kwargs.get('connection_limit'):
|
|
body['vip']['connection_limit'] = kwargs['connection_limit']
|
|
|
|
if kwargs.get('address'):
|
|
body['vip']['address'] = kwargs['address']
|
|
|
|
vip = neutronclient(request).create_vip(body).get('vip')
|
|
return Vip(vip)
|
|
|
|
|
|
def vip_list(request, **kwargs):
|
|
vips = neutronclient(request).list_vips(**kwargs).get('vips')
|
|
return [Vip(v) for v in vips]
|
|
|
|
|
|
def vip_get(request, vip_id):
|
|
vip = neutronclient(request).show_vip(vip_id).get('vip')
|
|
return Vip(vip)
|
|
|
|
|
|
def vip_update(request, vip_id, **kwargs):
|
|
vip = neutronclient(request).update_vip(vip_id, kwargs).get('vip')
|
|
return Vip(vip)
|
|
|
|
|
|
def vip_delete(request, vip_id):
|
|
neutronclient(request).delete_vip(vip_id)
|
|
|
|
|
|
def pool_create(request, **kwargs):
|
|
"""Create a pool for specified protocol
|
|
|
|
:param request: request context
|
|
:param name: name for pool
|
|
:param description: description for pool
|
|
:param subnet_id: subnet_id for subnet of pool
|
|
:param protocol: load balanced protocol
|
|
:param lb_method: load balancer method
|
|
:param admin_state_up: admin state (default on)
|
|
"""
|
|
body = {'pool': {'name': kwargs['name'],
|
|
'description': kwargs['description'],
|
|
'subnet_id': kwargs['subnet_id'],
|
|
'protocol': kwargs['protocol'],
|
|
'lb_method': kwargs['lb_method'],
|
|
'admin_state_up': kwargs['admin_state_up'],
|
|
'provider': kwargs['provider'],
|
|
}}
|
|
pool = neutronclient(request).create_pool(body).get('pool')
|
|
return Pool(pool)
|
|
|
|
|
|
def pool_list(request, **kwargs):
|
|
pools = neutronclient(request).list_pools(**kwargs).get('pools')
|
|
return [Pool(p) for p in pools]
|
|
|
|
|
|
def pool_get(request, pool_id):
|
|
pool = neutronclient(request).show_pool(pool_id).get('pool')
|
|
return Pool(pool)
|
|
|
|
|
|
def pool_update(request, pool_id, **kwargs):
|
|
pool = neutronclient(request).update_pool(pool_id, kwargs).get('pool')
|
|
return Pool(pool)
|
|
|
|
|
|
def pool_delete(request, pool):
|
|
neutronclient(request).delete_pool(pool)
|
|
|
|
|
|
# not linked to UI yet
|
|
def pool_stats(request, pool_id, **kwargs):
|
|
stats = neutronclient(request).retrieve_pool_stats(pool_id, **kwargs)
|
|
return PoolStats(stats)
|
|
|
|
|
|
def pool_health_monitor_create(request, **kwargs):
|
|
"""Create a health monitor
|
|
|
|
:param request: request context
|
|
:param type: type of monitor
|
|
:param delay: delay of monitor
|
|
:param timeout: timeout of monitor
|
|
:param max_retries: max retries [1..10]
|
|
:param http_method: http method
|
|
:param url_path: url path
|
|
:param expected_codes: http return code
|
|
:param admin_state_up: admin state
|
|
"""
|
|
monitor_type = kwargs['type'].upper()
|
|
body = {'health_monitor': {'type': monitor_type,
|
|
'delay': kwargs['delay'],
|
|
'timeout': kwargs['timeout'],
|
|
'max_retries': kwargs['max_retries'],
|
|
'admin_state_up': kwargs['admin_state_up']
|
|
}}
|
|
if monitor_type in ['HTTP', 'HTTPS']:
|
|
body['health_monitor']['http_method'] = kwargs['http_method']
|
|
body['health_monitor']['url_path'] = kwargs['url_path']
|
|
body['health_monitor']['expected_codes'] = kwargs['expected_codes']
|
|
mon = neutronclient(request).create_health_monitor(body).get(
|
|
'health_monitor')
|
|
|
|
return PoolMonitor(mon)
|
|
|
|
|
|
def pool_health_monitor_list(request, **kwargs):
|
|
monitors = neutronclient(request).list_health_monitors(
|
|
**kwargs).get('health_monitors')
|
|
return [PoolMonitor(m) for m in monitors]
|
|
|
|
|
|
def pool_health_monitor_get(request, monitor_id):
|
|
monitor = neutronclient(request
|
|
).show_health_monitor(monitor_id
|
|
).get('health_monitor')
|
|
return PoolMonitor(monitor)
|
|
|
|
|
|
def pool_health_monitor_update(request, monitor_id, **kwargs):
|
|
monitor = neutronclient(request).update_health_monitor(monitor_id, kwargs)
|
|
return PoolMonitor(monitor)
|
|
|
|
|
|
def pool_health_monitor_delete(request, mon_id):
|
|
neutronclient(request).delete_health_monitor(mon_id)
|
|
|
|
|
|
def member_create(request, **kwargs):
|
|
"""Create a load balance member
|
|
|
|
:param request: request context
|
|
:param pool_id: pool_id of pool for member
|
|
:param address: IP address
|
|
:param protocol_port: transport layer port number
|
|
:param weight: weight for member
|
|
:param admin_state_up: admin_state
|
|
"""
|
|
body = {'member': {'pool_id': kwargs['pool_id'],
|
|
'address': kwargs['address'],
|
|
'protocol_port': kwargs['protocol_port'],
|
|
'admin_state_up': kwargs['admin_state_up']
|
|
}}
|
|
if kwargs.get('weight'):
|
|
body['member']['weight'] = kwargs['weight']
|
|
member = neutronclient(request).create_member(body).get('member')
|
|
return Member(member)
|
|
|
|
|
|
def member_list(request, **kwargs):
|
|
members = neutronclient(request).list_members(**kwargs).get('members')
|
|
return [Member(m) for m in members]
|
|
|
|
|
|
def member_get(request, member_id):
|
|
member = neutronclient(request).show_member(member_id).get('member')
|
|
return Member(member)
|
|
|
|
|
|
def member_update(request, member_id, **kwargs):
|
|
member = neutronclient(request).update_member(member_id, kwargs)
|
|
return Member(member)
|
|
|
|
|
|
def member_delete(request, mem_id):
|
|
neutronclient(request).delete_member(mem_id)
|
|
|
|
|
|
def pool_monitor_association_create(request, **kwargs):
|
|
"""Associate a health monitor with pool
|
|
|
|
:param request: request context
|
|
:param monitor_id: id of monitor
|
|
:param pool_id: id of pool
|
|
"""
|
|
|
|
body = {'health_monitor': {'id': kwargs['monitor_id'], }}
|
|
|
|
neutronclient(request).associate_health_monitor(
|
|
kwargs['pool_id'], body)
|
|
|
|
|
|
def pool_monitor_association_delete(request, **kwargs):
|
|
"""Disassociate a health monitor from pool
|
|
|
|
:param request: request context
|
|
:param monitor_id: id of monitor
|
|
:param pool_id: id of pool
|
|
"""
|
|
|
|
neutronclient(request).disassociate_health_monitor(
|
|
kwargs['pool_id'], kwargs['monitor_id'])
|