d2f36a2ed1
This patch makes the regex more broad to cover both services and ingresses that create load balancers in octavia. In cloud-provider-openstack repo, the load balancer description is defined in: -f056677572/pkg/cloudprovider/providers/openstack/openstack_loadbalancer.go (L459)-f056677572/pkg/ingress/controller/openstack/octavia.go (L316)The floating ip description is defined in: -f056677572/pkg/cloudprovider/providers/openstack/openstack_loadbalancer.go (L1063)-f056677572/pkg/ingress/controller/openstack/neutron.go (L72)Change-Id: I7ce38e38de0d66fac340e287ce520de4c4bf679d Story: 2004839
77 lines
2.6 KiB
Python
77 lines
2.6 KiB
Python
# Copyright 2019 Catalyst Cloud Ltd.
|
|
#
|
|
# 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 re
|
|
|
|
from oslo_log import log as logging
|
|
|
|
from magnum.common import clients
|
|
from magnum.common import exception
|
|
|
|
LOG = logging.getLogger(__name__)
|
|
|
|
|
|
def delete_floatingip(context, fix_port_id, cluster):
|
|
"""Deletes the floating IP associated with the fix_port_id.
|
|
|
|
Only delete the floating IP if it's created and associated with the
|
|
the load balancers that corresponding to the services and ingresses in
|
|
Kubernetes cluster.
|
|
|
|
This method only works with the Kubernetes cluster with
|
|
cloud-provider-openstack controller manager deployed.
|
|
"""
|
|
pattern = (r'Floating IP for Kubernetes .+ from cluster %s$' %
|
|
cluster.uuid)
|
|
|
|
try:
|
|
n_client = clients.OpenStackClients(context).neutron()
|
|
fips = n_client.list_floatingips(port_id=fix_port_id)
|
|
if len(fips["floatingips"]) == 0:
|
|
return
|
|
|
|
# Liberty Neutron doesn't support description field, although Liberty
|
|
# is no longer supported, we write good code here.
|
|
desc = fips["floatingips"][0].get("description", "")
|
|
id = fips["floatingips"][0]["id"]
|
|
|
|
if re.match(pattern, desc):
|
|
LOG.debug("Deleting floating ip %s for cluster %s", id,
|
|
cluster.uuid)
|
|
n_client.delete_floatingip(id)
|
|
except Exception as e:
|
|
raise exception.PreDeletionFailed(cluster_uuid=cluster.uuid,
|
|
msg=str(e))
|
|
|
|
|
|
def get_network_id(context, network_name):
|
|
nets = []
|
|
n_client = clients.OpenStackClients(context).neutron()
|
|
ext_filter = {'router:external': True}
|
|
|
|
networks = n_client.list_networks(**ext_filter)
|
|
for net in networks.get('networks'):
|
|
if net.get('name') == network_name:
|
|
nets.append(net)
|
|
|
|
if len(nets) == 0:
|
|
raise exception.ExternalNetworkNotFound(network=network_name)
|
|
|
|
if len(nets) > 1:
|
|
raise exception.Conflict(
|
|
"Multiple networks exist with same name '%s'. Please use the "
|
|
"network ID instead." % network_name
|
|
)
|
|
|
|
return nets[0]["id"]
|