Skip to content

Commit c9b9801

Browse files
authored
Remove intermediate funcs on Ensure* interfaces (#2191)
I think these were relics of the times when we had different codepaths for Octavia and Neutron LBaaS. The latter is not supported anymore, so `Ensure*()` functions can call `ensureOctavia*()` directly.
1 parent bdfb541 commit c9b9801

File tree

1 file changed

+3
-12
lines changed

1 file changed

+3
-12
lines changed

pkg/openstack/loadbalancer.go

Lines changed: 3 additions & 12 deletions
Original file line numberDiff line numberDiff line change
@@ -1998,14 +1998,9 @@ func (lbaas *LbaasV2) ensureOctaviaLoadBalancer(ctx context.Context, clusterName
19981998
// EnsureLoadBalancer creates a new load balancer or updates the existing one.
19991999
func (lbaas *LbaasV2) EnsureLoadBalancer(ctx context.Context, clusterName string, apiService *corev1.Service, nodes []*corev1.Node) (*corev1.LoadBalancerStatus, error) {
20002000
mc := metrics.NewMetricContext("loadbalancer", "ensure")
2001-
status, err := lbaas.ensureLoadBalancer(ctx, clusterName, apiService, nodes)
2002-
return status, mc.ObserveReconcile(err)
2003-
}
2004-
2005-
func (lbaas *LbaasV2) ensureLoadBalancer(ctx context.Context, clusterName string, apiService *corev1.Service, nodes []*corev1.Node) (*corev1.LoadBalancerStatus, error) {
20062001
klog.InfoS("EnsureLoadBalancer", "cluster", clusterName, "service", klog.KObj(apiService))
2007-
2008-
return lbaas.ensureOctaviaLoadBalancer(ctx, clusterName, apiService, nodes)
2002+
status, err := lbaas.ensureOctaviaLoadBalancer(ctx, clusterName, apiService, nodes)
2003+
return status, mc.ObserveReconcile(err)
20092004
}
20102005

20112006
func (lbaas *LbaasV2) listSubnetsForNetwork(networkID string, tweak ...TweakSubNetListOpsFunction) ([]subnets.Subnet, error) {
@@ -2158,14 +2153,10 @@ func (lbaas *LbaasV2) updateOctaviaLoadBalancer(ctx context.Context, clusterName
21582153
// UpdateLoadBalancer updates hosts under the specified load balancer.
21592154
func (lbaas *LbaasV2) UpdateLoadBalancer(ctx context.Context, clusterName string, service *corev1.Service, nodes []*corev1.Node) error {
21602155
mc := metrics.NewMetricContext("loadbalancer", "update")
2161-
err := lbaas.updateLoadBalancer(ctx, clusterName, service, nodes)
2156+
err := lbaas.updateOctaviaLoadBalancer(ctx, clusterName, service, nodes)
21622157
return mc.ObserveReconcile(err)
21632158
}
21642159

2165-
func (lbaas *LbaasV2) updateLoadBalancer(ctx context.Context, clusterName string, service *corev1.Service, nodes []*corev1.Node) error {
2166-
return lbaas.updateOctaviaLoadBalancer(ctx, clusterName, service, nodes)
2167-
}
2168-
21692160
// ensureAndUpdateOctaviaSecurityGroup handles the creation and update of the security group and the securiry rules for the octavia load balancer
21702161
func (lbaas *LbaasV2) ensureAndUpdateOctaviaSecurityGroup(clusterName string, apiService *corev1.Service, nodes []*corev1.Node, memberSubnetID string) error {
21712162
// get service ports

0 commit comments

Comments
 (0)