1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
|
# 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 openstack.common import tag
from openstack import exceptions
from openstack import resource
from openstack import utils
class LoadBalancer(resource.Resource, tag.TagMixin):
resource_key = 'loadbalancer'
resources_key = 'loadbalancers'
base_path = '/lbaas/loadbalancers'
# capabilities
allow_create = True
allow_fetch = True
allow_commit = True
allow_delete = True
allow_list = True
_query_mapping = resource.QueryParameters(
'description',
'flavor_id',
'name',
'project_id',
'provider',
'vip_address',
'vip_network_id',
'vip_port_id',
'vip_subnet_id',
'vip_qos_policy_id',
'provisioning_status',
'operating_status',
'availability_zone',
is_admin_state_up='admin_state_up',
**tag.TagMixin._tag_query_parameters,
)
# Properties
#: The administrative state of the load balancer *Type: bool*
is_admin_state_up = resource.Body('admin_state_up', type=bool)
#: Name of the target Octavia availability zone
availability_zone = resource.Body('availability_zone')
#: Timestamp when the load balancer was created
created_at = resource.Body('created_at')
#: The load balancer description
description = resource.Body('description')
#: The load balancer flavor ID
flavor_id = resource.Body('flavor_id')
#: List of listeners associated with this load balancer
listeners = resource.Body('listeners', type=list)
#: The load balancer name
name = resource.Body('name')
#: Operating status of the load balancer
operating_status = resource.Body('operating_status')
#: List of pools associated with this load balancer
pools = resource.Body('pools', type=list)
#: The ID of the project this load balancer is associated with.
project_id = resource.Body('project_id')
#: Provider name for the load balancer.
provider = resource.Body('provider')
#: The provisioning status of this load balancer
provisioning_status = resource.Body('provisioning_status')
#: Timestamp when the load balancer was last updated
updated_at = resource.Body('updated_at')
#: VIP address of load balancer
vip_address = resource.Body('vip_address')
#: VIP netowrk ID
vip_network_id = resource.Body('vip_network_id')
#: VIP port ID
vip_port_id = resource.Body('vip_port_id')
#: VIP subnet ID
vip_subnet_id = resource.Body('vip_subnet_id')
# VIP qos policy id
vip_qos_policy_id = resource.Body('vip_qos_policy_id')
#: Additional VIPs
additional_vips = resource.Body('additional_vips', type=list)
def delete(self, session, error_message=None, **kwargs):
request = self._prepare_request()
params = {}
if (
hasattr(self, 'cascade')
and isinstance(self.cascade, bool)
and self.cascade
):
params['cascade'] = True
response = session.delete(request.url, params=params)
self._translate_response(
response, has_body=False, error_message=error_message
)
return self
def failover(self, session):
"""Failover load balancer.
:param session: The session to use for making this request.
:returns: None
"""
session = self._get_session(session)
version = self._get_microversion(session, action='patch')
request = self._prepare_request(requires_id=True)
request.url = utils.urljoin(request.url, 'failover')
response = session.put(
request.url,
headers=request.headers,
microversion=version,
)
msg = f"Failed to failover load balancer {self.id}"
exceptions.raise_from_response(response, error_message=msg)
class LoadBalancerStats(resource.Resource):
resource_key = 'stats'
base_path = '/lbaas/loadbalancers/%(lb_id)s/stats'
# capabilities
allow_create = False
allow_fetch = True
allow_commit = False
allow_delete = False
allow_list = False
# Properties
#: The ID of the load balancer.
lb_id = resource.URI('lb_id')
#: The currently active connections.
active_connections = resource.Body('active_connections', type=int)
#: The total bytes received.
bytes_in = resource.Body('bytes_in', type=int)
#: The total bytes sent.
bytes_out = resource.Body('bytes_out', type=int)
#: The total requests that were unable to be fulfilled.
request_errors = resource.Body('request_errors', type=int)
#: The total connections handled.
total_connections = resource.Body('total_connections', type=int)
# TODO(stephenfin): Delete this: it's useless
class LoadBalancerFailover(resource.Resource):
base_path = '/lbaas/loadbalancers/%(lb_id)s/failover'
# capabilities
allow_create = False
allow_fetch = False
allow_commit = True
allow_delete = False
allow_list = False
allow_empty_commit = True
requires_id = False
# Properties
#: The ID of the load balancer.
lb_id = resource.URI('lb_id')
# The default _update code path also has no
# way to pass has_body into this function, so overriding the method here.
def commit(
self, session, prepend_key=True, has_body=False, *args, **kwargs
):
return super().commit(session, prepend_key, has_body, *args, **kwargs)
|
