rancher/rke
1
0
Fork 0
mirror of https://github.com/rancher/rke.git synced 2025-08-01 07:08:38 +00:00
Code Issues Releases Wiki Activity

Set timeout for WrapTransport

Browse Source
This commit is contained in:
moelsayed 2018-03-27 20:38:14 +02:00
parent 8b8bc8ab8b
commit d72c0849b3
1 changed files with 4 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
k8s/k8s.go
View File

@ -11,8 +11,9 @@ import (
) )
const ( const (
DefaultRetries = 5 DefaultRetries = 5
DefaultSleepSeconds = 5 DefaultSleepSeconds = 5
K8sWrapTransportTimeout = 30
) )
type k8sCall func(*kubernetes.Clientset, interface{}) error type k8sCall func(*kubernetes.Clientset, interface{}) error
@ -28,6 +29,7 @@ func NewClient(kubeConfigPath string, k8sWrapTransport WrapTransport) (*kubernet
if k8sWrapTransport != nil { if k8sWrapTransport != nil {
config.WrapTransport = k8sWrapTransport config.WrapTransport = k8sWrapTransport
} }
config.Timeout = time.Second * time.Duration(K8sWrapTransportTimeout)
K8sClientSet, err := kubernetes.NewForConfig(config) K8sClientSet, err := kubernetes.NewForConfig(config)
if err != nil { if err != nil {
return nil, err return nil, err