rancher/steve
1
0
Fork 0
mirror of https://github.com/rancher/steve.git synced 2025-07-13 14:44:48 +00:00
Code Issues Projects Releases Wiki Activity

Make watch timeout configurable

Browse Source 
By default, a watch times out after 30 minutes. For debugging purposes,
it's convenient if this can be decreased. Add an environment variable
CATTLE_WATCH_TIMEOUT_SECONDS to enable setting the timeout in seconds.
This commit is contained in:
Colleen Murphy 2022-05-19 14:25:13 -07:00
parent ada5b33d98
commit 11fe86ab7e
1 changed files with 13 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
pkg/stores/proxy/proxy_store.go
View File

@ -7,8 +7,10 @@ import (
"io" "io"
"io/ioutil" "io/ioutil"
"net/http" "net/http"
"os"
"reflect" "reflect"
"regexp" "regexp"
"strconv"
"github.com/pkg/errors" "github.com/pkg/errors"
"github.com/rancher/apiserver/pkg/types" "github.com/rancher/apiserver/pkg/types"
@ -32,6 +34,8 @@ import (
"k8s.io/client-go/kubernetes" "k8s.io/client-go/kubernetes"
) )
const watchTimeoutEnv = "CATTLE_WATCH_TIMEOUT_SECONDS"
var ( var (
lowerChars = regexp.MustCompile("[a-z]+") lowerChars = regexp.MustCompile("[a-z]+")
paramScheme = runtime.NewScheme() paramScheme = runtime.NewScheme()
@ -291,6 +295,15 @@ func (s *Store) listAndWatch(apiOp *types.APIRequest, client dynamic.ResourceInt
} }
timeout := int64(60 * 30) timeout := int64(60 * 30)
timeoutSetting := os.Getenv(watchTimeoutEnv)
if timeoutSetting != "" {
userSetTimeout, err := strconv.Atoi(timeoutSetting)
if err != nil {
logrus.Debugf("could not parse %s environment variable, error: %v", watchTimeoutEnv, err)
} else {
timeout = int64(userSetTimeout)
}
}
k8sClient, _ := metricsStore.Wrap(client, nil) k8sClient, _ := metricsStore.Wrap(client, nil)
watcher, err := k8sClient.Watch(apiOp, metav1.ListOptions{ watcher, err := k8sClient.Watch(apiOp, metav1.ListOptions{
Watch: true, Watch: true,