add timeout for linodego http client

README.md

@@ -286,6 +286,15 @@ sessionAffinityConfig:
     timeoutSeconds: 100
 ```
 
+## Additional environment variables
+To tweak CCM based on needs, one can overwrite the default values set for caches and requests by setting appropriate environment variables when applying the manifest or helm chart.
+
+Environment Variable | Default | Description
+---|---|---
+`LINODE_INSTANCE_CACHE_TTL` | `15` | Default timeout of instance cache in seconds
+`LINODE_ROUTES_CACHE_TTL_SECONDS` | `60` | Default timeout of route cache in seconds
+`LINODE_REQUEST_TIMEOUT_SECONDS` | `120` | Default timeout in seconds for http requests to linode API
+
 ## Generating a Manifest for Deployment
 Use the script located at `./deploy/generate-manifest.sh` to generate a self-contained deployment manifest for the Linode CCM. Two arguments are required.
 
@@ -320,7 +329,7 @@ helm repo update ccm-linode
 ### To deploy ccm-linode. Run the following command:
 
 ```sh
-export VERSION=v0.3.22
+export VERSION=v0.4.8
 export LINODE_API_TOKEN=<linodeapitoken>
 export REGION=<linoderegion>
 helm install ccm-linode --set apiToken=$LINODE_API_TOKEN,region=$REGION ccm-linode/ccm-linode
@@ -335,7 +344,7 @@ _See [helm uninstall](https://helm.sh/docs/helm/helm_uninstall/) for command doc
 
 ### To upgrade when new changes are made to the helm chart. Run the following command:
 ```sh
-export VERSION=v0.3.22
+export VERSION=v0.4.8
 export LINODE_API_TOKEN=<linodeapitoken>
 export REGION=<linoderegion>
 

cloud/linode/client/client.go

@@ -4,8 +4,17 @@ package client
 
 import (
 	"context"
+	"net/http"
+	"time"
 
 	"github.com/linode/linodego"
+	"golang.org/x/oauth2"
+	"k8s.io/klog/v2"
+)
+
+const (
+	// DefaultClientTimeout is the default timeout for a client Linode API call
+	DefaultClientTimeout = 120 * time.Second
 )
 
 type Client interface {
@@ -48,14 +57,21 @@ type Client interface {
 var _ Client = (*linodego.Client)(nil)
 
 // New creates a new linode client with a given token, userAgent, and API URL
-func New(token, userAgent, apiURL string) (*linodego.Client, error) {
-	linodeClient := linodego.NewClient(nil)
+func New(token, userAgent, apiURL string, timeout time.Duration) (*linodego.Client, error) {
+	tokenSource := oauth2.StaticTokenSource(&oauth2.Token{AccessToken: token})
+	oauth2Client := &http.Client{
+		Transport: &oauth2.Transport{
+			Source: tokenSource,
+		},
+		Timeout: timeout,
+	}
+	linodeClient := linodego.NewClient(oauth2Client)
 	client, err := linodeClient.UseURL(apiURL)
 	if err != nil {
 		return nil, err
 	}
 	client.SetUserAgent(userAgent)
-	client.SetToken(token)
 
+	klog.V(3).Infof("Linode client created with default timeout of %v seconds", timeout)
 	return client, nil
 }

cloud/linode/cloud.go

@@ -4,7 +4,9 @@ import (
 	"fmt"
 	"io"
 	"os"
+	"strconv"
 	"sync"
+	"time"
 
 	"github.com/linode/linodego"
 	"github.com/spf13/pflag"
@@ -98,7 +100,15 @@ func newCloud() (cloudprovider.Interface, error) {
 	url := os.Getenv(urlEnv)
 	ua := fmt.Sprintf("linode-cloud-controller-manager %s", linodego.DefaultUserAgent)
 
-	linodeClient, err := client.New(apiToken, ua, url)
+	// set timeout used by linodeclient for API calls
+	timeout := client.DefaultClientTimeout
+	if raw, ok := os.LookupEnv("LINODE_REQUEST_TIMEOUT_SECONDS"); ok {
+		if t, _ := strconv.Atoi(raw); t > 0 {
+			timeout = time.Duration(t) * time.Second
+		}
+	}
+
+	linodeClient, err := client.New(apiToken, ua, url, timeout)
 	if err != nil {
 		return nil, fmt.Errorf("client was not created succesfully: %w", err)
 	}