diff options
Diffstat (limited to 'core/setup/kubernetes.go')
| -rw-r--r-- | core/setup/kubernetes.go | 16 |
1 files changed, 14 insertions, 2 deletions
diff --git a/core/setup/kubernetes.go b/core/setup/kubernetes.go index adfbe01b0..17b37e00e 100644 --- a/core/setup/kubernetes.go +++ b/core/setup/kubernetes.go @@ -2,6 +2,7 @@ package setup import ( "errors" + "fmt" "log" "strings" "time" @@ -27,7 +28,6 @@ func Kubernetes(c *Controller) (middleware.Middleware, error) { if err != nil { return nil, err } - log.Printf("[debug] after parse and start KubeCache, APIconn is: %v", kubernetes.APIConn) return func(next middleware.Handler) middleware.Handler { kubernetes.Next = next @@ -51,7 +51,6 @@ func kubernetesParse(c *Controller) (kubernetes.Kubernetes, error) { if c.Val() == "kubernetes" { zones := c.RemainingArgs() - log.Printf("[debug] Zones: %v", zones) if len(zones) == 0 { k8s.Zones = c.ServerBlockHosts log.Printf("[debug] Zones(from ServerBlockHosts): %v", zones) @@ -97,6 +96,19 @@ func kubernetesParse(c *Controller) (kubernetes.Kubernetes, error) { log.Printf("[debug] 'endpoint' keyword provided without any endpoint url value.") return kubernetes.Kubernetes{}, c.ArgErr() } + case "resyncperiod": + args := c.RemainingArgs() + if len(args) != 0 { + k8s.ResyncPeriod, err = time.ParseDuration(args[0]) + if err != nil { + err = errors.New(fmt.Sprintf("Unable to parse resync duration value. Value provided was '%v'. Example valid values: '15s', '5m', '1h'. Error was: %v", args[0], err)) + log.Printf("[ERROR] %v", err) + return kubernetes.Kubernetes{}, err + } + } else { + log.Printf("[debug] 'resyncperiod' keyword provided without any duration value.") + return kubernetes.Kubernetes{}, c.ArgErr() + } } } return k8s, nil |