[occm] add tag on floating ip create

pkg/openstack/loadbalancer.go

@@ -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"
@@ -571,6 +572,7 @@ func (lbaas *LbaasV2) createFloatingIP(msg string, floatIPOpts floatingips.Creat
 	if mc.ObserveRequest(err) != nil {
 		return floatIP, fmt.Errorf("error creating LB floatingip: %v", err)
 	}
+
 	return floatIP, err
 }
 
@@ -735,6 +737,24 @@ func (lbaas *LbaasV2) ensureFloatingIP(clusterName string, service *corev1.Servi
 	}
 
 	if floatIP != nil {
+		tags, err := attributestags.List(lbaas.network, "floatingips", floatIP.ID).Extract()
+		if err != nil {
+			klog.V(3).Infof("Cannot get floatIP tags for floating %s", floatIP.ID)
+			return floatIP.FloatingIP, nil
+		}
+		found := false
+		for _, tag := range tags {
+			if tag == svcConf.lbName {
+				found = true
+			}
+		}
+		if !found {
+			err = attributestags.Add(lbaas.network, "floatingips", floatIP.ID, svcConf.lbName).ExtractErr()
+			if err != nil {
+				klog.V(3).Infof("Cannot update floatIP tag %s for floating %s", svcConf.lbName, floatIP.ID)
+			}
+		}
+
 		return floatIP.FloatingIP, nil
 	}