Last active
September 7, 2017 20:52
-
-
Save jackfrancis/70722e6663ef11f8e8ff6df13e2b38bb to your computer and use it in GitHub Desktop.
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
/* | |
Copyright 2017 The Kubernetes Authors. | |
Licensed under the Apache License, Version 2.0 (the "License"); | |
you may not use this file except in compliance with the License. | |
You may obtain a copy of the License at | |
http://www.apache.org/licenses/LICENSE-2.0 | |
Unless required by applicable law or agreed to in writing, software | |
distributed under the License is distributed on an "AS IS" BASIS, | |
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. | |
See the License for the specific language governing permissions and | |
limitations under the License. | |
*/ | |
package azure | |
import ( | |
"regexp" | |
"strconv" | |
"k8s.io/apimachinery/pkg/util/wait" | |
"github.com/Azure/azure-sdk-for-go/arm/compute" | |
"github.com/Azure/azure-sdk-for-go/arm/network" | |
"github.com/Azure/go-autorest/autorest" | |
"github.com/golang/glog" | |
"k8s.io/apimachinery/pkg/types" | |
) | |
// GetVirtualMachineWithRetry invokes az.getVirtualMachine with exponential backoff retry | |
func (az *Cloud) GetVirtualMachineWithRetry(name types.NodeName) (compute.VirtualMachine, bool, error) { | |
var machine compute.VirtualMachine | |
var exists bool | |
err := wait.ExponentialBackoff(az.resourceRequestBackoff, func() (bool, error) { | |
var retryErr error | |
machine, exists, retryErr = az.getVirtualMachine(name) | |
if retryErr != nil { | |
glog.Errorf("backoff: failure, will retry,err=%v", retryErr) | |
return false, nil | |
} | |
glog.V(2).Infof("backoff: success") | |
return true, nil | |
}) | |
return machine, exists, err | |
} | |
// VirtualMachineClientGetWithRetry invokes az.VirtualMachinesClient.Get with exponential backoff retry | |
func (az *Cloud) VirtualMachineClientGetWithRetry(resourceGroup, vmName string, types compute.InstanceViewTypes) (compute.VirtualMachine, error) { | |
var machine compute.VirtualMachine | |
err := wait.ExponentialBackoff(az.resourceRequestBackoff, func() (bool, error) { | |
var retryErr error | |
machine, retryErr = az.VirtualMachinesClient.Get(resourceGroup, vmName, types) | |
if retryErr != nil { | |
glog.Errorf("backoff: failure, will retry,err=%v", retryErr) | |
return false, nil | |
} | |
glog.V(2).Infof("backoff: success") | |
return true, nil | |
}) | |
return machine, err | |
} | |
// GetIPForMachineWithRetry invokes az.getIPForMachine with exponential backoff retry | |
func (az *Cloud) GetIPForMachineWithRetry(name types.NodeName) (string, error) { | |
var ip string | |
err := wait.ExponentialBackoff(az.resourceRequestBackoff, func() (bool, error) { | |
var retryErr error | |
ip, retryErr = az.getIPForMachine(name) | |
if retryErr != nil { | |
glog.Errorf("backoff: failure, will retry,err=%v", retryErr) | |
return false, nil | |
} | |
glog.V(2).Infof("backoff: success") | |
return true, nil | |
}) | |
return ip, err | |
} | |
// CreateOrUpdateSGWithRetry invokes az.SecurityGroupsClient.CreateOrUpdate with exponential backoff retry | |
func (az *Cloud) CreateOrUpdateSGWithRetry(sg network.SecurityGroup) error { | |
return wait.ExponentialBackoff(az.resourceRequestBackoff, func() (bool, error) { | |
az.operationPollRateLimiter.Accept() | |
glog.V(10).Infof("SecurityGroupsClient.CreateOrUpdate(%s): start", *sg.Name) | |
respChan, errChan := az.SecurityGroupsClient.CreateOrUpdate(az.ResourceGroup, *sg.Name, sg, nil) | |
resp := <-respChan | |
err := <-errChan | |
glog.V(10).Infof("SecurityGroupsClient.CreateOrUpdate(%s): end", *sg.Name) | |
return processRetryResponse(resp.Response, err) | |
}) | |
} | |
// CreateOrUpdateLBWithRetry invokes az.LoadBalancerClient.CreateOrUpdate with exponential backoff retry | |
func (az *Cloud) CreateOrUpdateLBWithRetry(lb network.LoadBalancer) error { | |
return wait.ExponentialBackoff(az.resourceRequestBackoff, func() (bool, error) { | |
az.operationPollRateLimiter.Accept() | |
glog.V(10).Infof("LoadBalancerClient.CreateOrUpdate(%s): start", *lb.Name) | |
respChan, errChan := az.LoadBalancerClient.CreateOrUpdate(az.ResourceGroup, *lb.Name, lb, nil) | |
resp := <-respChan | |
err := <-errChan | |
glog.V(10).Infof("LoadBalancerClient.CreateOrUpdate(%s): end", *lb.Name) | |
return processRetryResponse(resp.Response, err) | |
}) | |
} | |
// CreateOrUpdatePIPWithRetry invokes az.PublicIPAddressesClient.CreateOrUpdate with exponential backoff retry | |
func (az *Cloud) CreateOrUpdatePIPWithRetry(pip network.PublicIPAddress) error { | |
return wait.ExponentialBackoff(az.resourceRequestBackoff, func() (bool, error) { | |
az.operationPollRateLimiter.Accept() | |
glog.V(10).Infof("PublicIPAddressesClient.CreateOrUpdate(%s): start", *pip.Name) | |
respChan, errChan := az.PublicIPAddressesClient.CreateOrUpdate(az.ResourceGroup, *pip.Name, pip, nil) | |
resp := <-respChan | |
err := <-errChan | |
glog.V(10).Infof("PublicIPAddressesClient.CreateOrUpdate(%s): end", *pip.Name) | |
return processRetryResponse(resp.Response, err) | |
}) | |
} | |
// CreateOrUpdateInterfaceWithRetry invokes az.PublicIPAddressesClient.CreateOrUpdate with exponential backoff retry | |
func (az *Cloud) CreateOrUpdateInterfaceWithRetry(nic network.Interface) error { | |
return wait.ExponentialBackoff(az.resourceRequestBackoff, func() (bool, error) { | |
az.operationPollRateLimiter.Accept() | |
glog.V(10).Infof("InterfacesClient.CreateOrUpdate(%s): start", *nic.Name) | |
respChan, errChan := az.InterfacesClient.CreateOrUpdate(az.ResourceGroup, *nic.Name, nic, nil) | |
resp := <-respChan | |
err := <-errChan | |
glog.V(10).Infof("InterfacesClient.CreateOrUpdate(%s): end", *nic.Name) | |
return processRetryResponse(resp.Response, err) | |
}) | |
} | |
// DeletePublicIPWithRetry invokes az.PublicIPAddressesClient.Delete with exponential backoff retry | |
func (az *Cloud) DeletePublicIPWithRetry(pipName string) error { | |
return wait.ExponentialBackoff(az.resourceRequestBackoff, func() (bool, error) { | |
az.operationPollRateLimiter.Accept() | |
glog.V(10).Infof("PublicIPAddressesClient.Delete(%s): start", pipName) | |
respChan, errChan := az.PublicIPAddressesClient.Delete(az.ResourceGroup, pipName, nil) | |
resp := <-respChan | |
err := <-errChan | |
glog.V(10).Infof("PublicIPAddressesClient.Delete(%s): end", pipName) | |
return processRetryResponse(resp, err) | |
}) | |
} | |
// DeleteLBWithRetry invokes az.LoadBalancerClient.Delete with exponential backoff retry | |
func (az *Cloud) DeleteLBWithRetry(lbName string) error { | |
return wait.ExponentialBackoff(az.resourceRequestBackoff, func() (bool, error) { | |
az.operationPollRateLimiter.Accept() | |
glog.V(10).Infof("LoadBalancerClient.Delete(%s): start", lbName) | |
respChan, errChan := az.LoadBalancerClient.Delete(az.ResourceGroup, lbName, nil) | |
resp := <-respChan | |
err := <-errChan | |
glog.V(10).Infof("LoadBalancerClient.Delete(%s): end", lbName) | |
return processRetryResponse(resp, err) | |
}) | |
} | |
// CreateOrUpdateRouteTableWithRetry invokes az.RouteTablesClient.CreateOrUpdate with exponential backoff retry | |
func (az *Cloud) CreateOrUpdateRouteTableWithRetry(routeTable network.RouteTable) error { | |
return wait.ExponentialBackoff(az.resourceRequestBackoff, func() (bool, error) { | |
az.operationPollRateLimiter.Accept() | |
glog.V(10).Infof("RouteTablesClient.CreateOrUpdate(%s): start", routeTable) | |
respChan, errChan := az.RouteTablesClient.CreateOrUpdate(az.ResourceGroup, az.RouteTableName, routeTable, nil) | |
resp := <-respChan | |
err := <-errChan | |
glog.V(10).Infof("RouteTablesClient.CreateOrUpdate(%s): end", routeTable) | |
return processRetryResponse(resp.Response, err) | |
}) | |
} | |
// CreateOrUpdateRouteWithRetry invokes az.RoutesClient.CreateOrUpdate with exponential backoff retry | |
func (az *Cloud) CreateOrUpdateRouteWithRetry(route network.Route) error { | |
return wait.ExponentialBackoff(az.resourceRequestBackoff, func() (bool, error) { | |
az.operationPollRateLimiter.Accept() | |
glog.V(10).Infof("RoutesClient.CreateOrUpdate(%s): start", *route.Name) | |
respChan, errChan := az.RoutesClient.CreateOrUpdate(az.ResourceGroup, az.RouteTableName, *route.Name, route, nil) | |
resp := <-respChan | |
err := <-errChan | |
glog.V(10).Infof("RoutesClient.CreateOrUpdate(%s): end", *route.Name) | |
return processRetryResponse(resp.Response, err) | |
}) | |
} | |
// DeleteRouteWithRetry invokes az.RoutesClient.Delete with exponential backoff retry | |
func (az *Cloud) DeleteRouteWithRetry(routeName string) error { | |
return wait.ExponentialBackoff(az.resourceRequestBackoff, func() (bool, error) { | |
az.operationPollRateLimiter.Accept() | |
glog.V(10).Infof("RoutesClient.Delete(%s): start", az.RouteTableName) | |
respChan, errChan := az.RoutesClient.Delete(az.ResourceGroup, az.RouteTableName, routeName, nil) | |
resp := <-respChan | |
err := <-errChan | |
glog.V(10).Infof("RoutesClient.Delete(%s): end", az.RouteTableName) | |
return processRetryResponse(resp, err) | |
}) | |
} | |
// CreateOrUpdateVMWithRetry invokes az.VirtualMachinesClient.CreateOrUpdate with exponential backoff retry | |
func (az *Cloud) CreateOrUpdateVMWithRetry(vmName string, newVM compute.VirtualMachine) error { | |
return wait.ExponentialBackoff(az.resourceRequestBackoff, func() (bool, error) { | |
az.operationPollRateLimiter.Accept() | |
glog.V(10).Infof("VirtualMachinesClient.CreateOrUpdate(%s): start", vmName) | |
respChan, errChan := az.VirtualMachinesClient.CreateOrUpdate(az.ResourceGroup, vmName, newVM, nil) | |
resp := <-respChan | |
err := <-errChan | |
glog.V(10).Infof("VirtualMachinesClient.CreateOrUpdate(%s): end", vmName) | |
return processRetryResponse(resp.Response, err) | |
}) | |
} | |
// A wait.ConditionFunc function to deal with common HTTP backoff response conditions | |
func processRetryResponse(resp autorest.Response, err error) (bool, error) { | |
if isSuccessHTTPResponse(resp) { | |
glog.V(2).Infof("backoff: success, HTTP response=%d", resp.StatusCode) | |
return true, nil | |
} | |
if shouldRetryAPIRequest(resp, err) { | |
glog.Errorf("backoff: failure, will retry, HTTP response=%d, err=%v", resp.StatusCode, err) | |
// suppress the error object so that backoff process continues | |
return false, nil | |
} | |
// Fall-through: stop periodic backoff, return error object from most recent request | |
return true, err | |
} | |
// shouldRetryAPIRequest determines if the response from an HTTP request suggests periodic retry behavior | |
func shouldRetryAPIRequest(resp autorest.Response, err error) bool { | |
if err != nil { | |
return true | |
} | |
// HTTP 4xx or 5xx suggests we should retry | |
r, err := regexp.Compile(`^[45]\d\d$`) | |
if err != nil { | |
return false | |
} | |
if r.MatchString(strconv.Itoa(resp.StatusCode)) { | |
return true | |
} | |
return false | |
} | |
// isSuccessHTTPResponse determines if the response from an HTTP request suggests success | |
func isSuccessHTTPResponse(resp autorest.Response) bool { | |
// HTTP 2xx suggests a successful response | |
r, err := regexp.Compile(`^2\d\d$`) | |
if err != nil { | |
return false | |
} | |
if r.MatchString(strconv.Itoa(resp.StatusCode)) { | |
return true | |
} | |
return false | |
} |
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment