diff --git a/pkg/cloudprovider/providers/gce/gce.go b/pkg/cloudprovider/providers/gce/gce.go index 8ebe9dde413..dcc1d74f347 100644 --- a/pkg/cloudprovider/providers/gce/gce.go +++ b/pkg/cloudprovider/providers/gce/gce.go @@ -1446,6 +1446,14 @@ func (gce *GCECloud) deleteForwardingRule(name, region string) error { return nil } +func (gce *GCECloud) DeleteForwardingRule(name string) error { + region, err := GetGCERegion(gce.localZone) + if err != nil { + return err + } + return gce.deleteForwardingRule(name, region) +} + // DeleteTargetPool deletes the given target pool. func (gce *GCECloud) DeleteTargetPool(name string, hc *compute.HttpHealthCheck) error { region, err := GetGCERegion(gce.localZone) diff --git a/test/e2e/framework/util.go b/test/e2e/framework/util.go index 442d8009f03..ccc4846ef0d 100644 --- a/test/e2e/framework/util.go +++ b/test/e2e/framework/util.go @@ -4589,7 +4589,7 @@ func CleanupGCEResources(loadBalancerName string) (err error) { return fmt.Errorf("failed to convert CloudConfig.Provider to GCECloud: %#v", TestContext.CloudConfig.Provider) } gceCloud.DeleteFirewall(loadBalancerName) - gceCloud.DeleteGlobalForwardingRule(loadBalancerName) + gceCloud.DeleteForwardingRule(loadBalancerName) gceCloud.DeleteGlobalStaticIP(loadBalancerName) hc, _ := gceCloud.GetHttpHealthCheck(loadBalancerName) gceCloud.DeleteTargetPool(loadBalancerName, hc)