route controller: respect rate limit for delete

Signed-off-by: Andrew Sy Kim <kiman@vmware.com>
Co-authored-by: Khaled Henidak <khnidk@microsoft.com>
This commit is contained in:
Andrew Sy Kim
2019-05-31 08:26:21 -04:00
parent 9577cbfb9f
commit 380c6cbd0d

View File

@@ -216,12 +216,14 @@ func (rc *RouteController) reconcile(nodes []*v1.Node, routes []*cloudprovider.R
// Delete the route.
go func(route *cloudprovider.Route, startTime time.Time) {
defer wg.Done()
rateLimiter <- struct{}{}
klog.Infof("Deleting route %s %s", route.Name, route.DestinationCIDR)
if err := rc.routes.DeleteRoute(context.TODO(), rc.clusterName, route); err != nil {
klog.Errorf("Could not delete route %s %s after %v: %v", route.Name, route.DestinationCIDR, time.Since(startTime), err)
} else {
klog.Infof("Deleted route %s %s after %v", route.Name, route.DestinationCIDR, time.Since(startTime))
}
<-rateLimiter
}(route, time.Now())
}
}