diff --git a/Godeps/Godeps.json b/Godeps/Godeps.json index a29fb7491..64e2e7c86 100644 --- a/Godeps/Godeps.json +++ b/Godeps/Godeps.json @@ -584,7 +584,7 @@ }, { "ImportPath": "k8s.io/client-go", - "Rev": "526b2fff5289" + "Rev": "787fa2adce7c" }, { "ImportPath": "k8s.io/component-base", diff --git a/go.mod b/go.mod index 4c9b10d47..bf514ec8a 100644 --- a/go.mod +++ b/go.mod @@ -47,7 +47,7 @@ require ( gotest.tools v2.2.0+incompatible // indirect k8s.io/api v0.0.0-20191230033939-7dc09db16fb8 k8s.io/apimachinery v0.0.0-20191230155340-4d9f99a83526 - k8s.io/client-go v0.0.0-20191227015938-526b2fff5289 + k8s.io/client-go v0.0.0-20200103113829-787fa2adce7c k8s.io/component-base v0.0.0-20191231153918-e498b4d116ab k8s.io/klog v1.0.0 k8s.io/kube-openapi v0.0.0-20191107075043-30be4d16710a @@ -61,6 +61,6 @@ replace ( golang.org/x/tools => golang.org/x/tools v0.0.0-20190821162956-65e3620a7ae7 // pinned to release-branch.go1.13 k8s.io/api => k8s.io/api v0.0.0-20191230033939-7dc09db16fb8 k8s.io/apimachinery => k8s.io/apimachinery v0.0.0-20191230155340-4d9f99a83526 - k8s.io/client-go => k8s.io/client-go v0.0.0-20191227015938-526b2fff5289 + k8s.io/client-go => k8s.io/client-go v0.0.0-20200103113829-787fa2adce7c k8s.io/component-base => k8s.io/component-base v0.0.0-20191231153918-e498b4d116ab ) diff --git a/go.sum b/go.sum index 1fb316e15..32733d28b 100644 --- a/go.sum +++ b/go.sum @@ -357,7 +357,7 @@ honnef.co/go/tools v0.0.0-20190106161140-3f1c8253044a/go.mod h1:rf3lG4BRIbNafJWh honnef.co/go/tools v0.0.0-20190523083050-ea95bdfd59fc/go.mod h1:rf3lG4BRIbNafJWhAfAdb/ePZxsR/4RtNHQocxwk9r4= k8s.io/api v0.0.0-20191230033939-7dc09db16fb8/go.mod h1:cUvsxRRcutO57eFbvcbKsHasCbJP9NF8JA7Q9icijjI= k8s.io/apimachinery v0.0.0-20191230155340-4d9f99a83526/go.mod h1:f763v4YxJPg8tVQiktAorc+M5Ot35n9qV7zC0bCzr0s= -k8s.io/client-go v0.0.0-20191227015938-526b2fff5289/go.mod h1:lGXQyJl/X4GntUREa90IWFXpZ3q+6WGSUQRYmHc5HuU= +k8s.io/client-go v0.0.0-20200103113829-787fa2adce7c/go.mod h1:+S6KNcqj2QO0Q6GHaJ0M7z8yMCxacfz7+7lJ51fV/ok= k8s.io/component-base v0.0.0-20191231153918-e498b4d116ab/go.mod h1:z21BE1lrzlWfjf1EP+UOy8xKp199XmlIu34NLrpuKDw= k8s.io/gengo v0.0.0-20190128074634-0689ccc1d7d6/go.mod h1:ezvh/TsK7cY6rbqRK0oQQ8IAqLxYwwyPxAX1Pzy0ii0= k8s.io/klog v0.0.0-20181102134211-b9b56d5dfc92/go.mod h1:Gq+BEi5rUBO/HRz0bTSXDUcqjScdoY3a9IHpCEIOOfk= diff --git a/pkg/server/dynamiccertificates/configmap_cafile_content.go b/pkg/server/dynamiccertificates/configmap_cafile_content.go index dad6fc306..d2b01dfbb 100644 --- a/pkg/server/dynamiccertificates/configmap_cafile_content.go +++ b/pkg/server/dynamiccertificates/configmap_cafile_content.go @@ -217,7 +217,7 @@ func (c *ConfigMapCAController) Run(workers int, stopCh <-chan struct{}) { go wait.Until(c.runWorker, time.Second, stopCh) // start timer that rechecks every minute, just in case. this also serves to prime the controller quickly. - _ = wait.PollImmediateUntil(FileRefreshDuration, func() (bool, error) { + go wait.PollImmediateUntil(FileRefreshDuration, func() (bool, error) { c.queue.Add(workItemKey) return false, nil }, stopCh) diff --git a/pkg/server/dynamiccertificates/dynamic_cafile_content.go b/pkg/server/dynamiccertificates/dynamic_cafile_content.go index 09b5e616a..6dbd3bee6 100644 --- a/pkg/server/dynamiccertificates/dynamic_cafile_content.go +++ b/pkg/server/dynamiccertificates/dynamic_cafile_content.go @@ -170,7 +170,7 @@ func (c *DynamicFileCAContent) Run(workers int, stopCh <-chan struct{}) { go wait.Until(c.runWorker, time.Second, stopCh) // start timer that rechecks every minute, just in case. this also serves to prime the controller quickly. - _ = wait.PollImmediateUntil(FileRefreshDuration, func() (bool, error) { + go wait.PollImmediateUntil(FileRefreshDuration, func() (bool, error) { c.queue.Add(workItemKey) return false, nil }, stopCh) diff --git a/pkg/server/dynamiccertificates/dynamic_serving_content.go b/pkg/server/dynamiccertificates/dynamic_serving_content.go index 39be47fb0..94d956d41 100644 --- a/pkg/server/dynamiccertificates/dynamic_serving_content.go +++ b/pkg/server/dynamiccertificates/dynamic_serving_content.go @@ -133,7 +133,7 @@ func (c *DynamicFileServingContent) Run(workers int, stopCh <-chan struct{}) { go wait.Until(c.runWorker, time.Second, stopCh) // start timer that rechecks every minute, just in case. this also serves to prime the controller quickly. - _ = wait.PollImmediateUntil(FileRefreshDuration, func() (bool, error) { + go wait.PollImmediateUntil(FileRefreshDuration, func() (bool, error) { c.queue.Add(workItemKey) return false, nil }, stopCh)