Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

[occm] add tag on floating ip create #2577

Open
wants to merge 11 commits into
base: master
Choose a base branch
from
Open

[occm] add tag on floating ip create #2577

Changes from 1 commit
Commits
Show all changes
11 commits
Select commit Hold shift + click to select a range
d28309f
[occm] add tag on floating ip create
lidongshengxdayu Apr 18, 2024
9180e6d
[occm] ensure tag exist on floating ip create or lookup
lidongshengxdayu Apr 26, 2024
a7a5daf
[occm] handling tag list error
lidongshengxdayu Apr 26, 2024
4319a88
[occm] untag FIP when force CCM to not delete the FIP
lidongshengxdayu Apr 26, 2024
0e29ff2
Merge remote-tracking branch 'origin/master'
lidongshengxdayu Apr 26, 2024
48ac312
Merge remote-tracking branch 'origin/master'
lidongshengxdayu Jul 3, 2024
51c738b
[occm] fix build issue with Upgrade Gophercloud to v2
lidongshengxdayu Jul 3, 2024
5252b7e
Merge branch 'kubernetes:master' into master
lidongshengxdayu Nov 7, 2024
7196a75
[occm] fix context argument pass to `updateFloatingIPTag`
lidongshengxdayu Nov 7, 2024
c16cc03
[occm] fix `updateFloatingIPTag` typo and error print
lidongshengxdayu Nov 7, 2024
f6189ee
[occm] add check `standard-attr-tag` when update floating ip tags
lidongshengxdayu Nov 8, 2024
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
17 changes: 14 additions & 3 deletions pkg/openstack/loadbalancer.go
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -31,6 +31,7 @@ import (
"github.com/gophercloud/gophercloud/openstack/loadbalancer/v2/loadbalancers"
v2monitors "github.com/gophercloud/gophercloud/openstack/loadbalancer/v2/monitors"
v2pools "github.com/gophercloud/gophercloud/openstack/loadbalancer/v2/pools"
"github.com/gophercloud/gophercloud/openstack/networking/v2/extensions/attributestags"
"github.com/gophercloud/gophercloud/openstack/networking/v2/extensions/layer3/floatingips"
"github.com/gophercloud/gophercloud/openstack/networking/v2/subnets"
corev1 "k8s.io/api/core/v1"
Expand Down Expand Up @@ -563,14 +564,24 @@ func (lbaas *LbaasV2) deleteOctaviaListeners(lbID string, listenerList []listene
return nil
}

func (lbaas *LbaasV2) createFloatingIP(msg string, floatIPOpts floatingips.CreateOpts) (*floatingips.FloatingIP, error) {
func (lbaas *LbaasV2) createFloatingIP(msg string, floatIPOpts floatingips.CreateOpts, tag *string) (*floatingips.FloatingIP, error) {
klog.V(4).Infof("%s floating ip with opts %+v", msg, floatIPOpts)
mc := metrics.NewMetricContext("floating_ip", "create")
floatIP, err := floatingips.Create(lbaas.network, floatIPOpts).Extract()
err = PreserveGopherError(err)
if mc.ObserveRequest(err) != nil {
return floatIP, fmt.Errorf("error creating LB floatingip: %v", err)
}

if tag != nil {
err = attributestags.Add(lbaas.network, "floatingips", floatIP.ID, *tag).ExtractErr()
err = PreserveGopherError(err)
if mc.ObserveRequest(err) != nil {
floatingips.Delete(lbaas.network, floatIP.ID)
lidongshengxdayu marked this conversation as resolved.
Show resolved Hide resolved
return floatIP, fmt.Errorf("error update LB floatingip tag: %v", err)
}
}

return floatIP, err
}

Expand Down Expand Up @@ -704,7 +715,7 @@ func (lbaas *LbaasV2) ensureFloatingIP(clusterName string, service *corev1.Servi
svcConf.lbPublicSubnetSpec, svcConf.lbPublicNetworkID)
for _, subnet := range foundSubnets {
floatIPOpts.SubnetID = subnet.ID
floatIP, err = lbaas.createFloatingIP(fmt.Sprintf("Trying subnet %s for creating", subnet.Name), floatIPOpts)
floatIP, err = lbaas.createFloatingIP(fmt.Sprintf("Trying subnet %s for creating", subnet.Name), floatIPOpts, &svcConf.lbName)
if err == nil {
foundSubnet = subnet
break
Expand All @@ -721,7 +732,7 @@ func (lbaas *LbaasV2) ensureFloatingIP(clusterName string, service *corev1.Servi
floatIPOpts.SubnetID = svcConf.lbPublicSubnetSpec.subnetID
}
floatIPOpts.FloatingIP = loadBalancerIP
floatIP, err = lbaas.createFloatingIP("Creating", floatIPOpts)
floatIP, err = lbaas.createFloatingIP("Creating", floatIPOpts, &svcConf.lbName)
if err != nil {
return "", err
}
Expand Down