Merge pull request #280 from shawn-hurley/issue-272

pkg/k8sclient: add cache reset on 1 minute interval

Author: fanminshi

CHANGELOG.md

@@ -12,6 +12,8 @@
 
 ### Fixed
 
+- The cache of available clients is being reset every minute for discovery of newely added resources to a cluster. [#280](https://github.com/operator-framework/operator-sdk/pull/280)
+
 ### Deprecated
 
 ### Security

pkg/k8sclient/client.go

@@ -18,6 +18,7 @@ import (
 	"fmt"
 	"net"
 	"os"
+	"time"
 
 	"github.com/operator-framework/operator-sdk/pkg/util/k8sutil"
 
@@ -45,6 +46,7 @@ func init() {
 	restMapper.Reset()
 	kubeConfig.ContentConfig = dynamic.ContentConfig()
 	clientPool = dynamic.NewClientPool(kubeConfig, restMapper, dynamic.LegacyAPIPathResolverFunc)
+	runBackgroundCacheReset(1 * time.Minute)
 }
 
 // GetResourceClient returns the dynamic client and pluralName for the resource specified by the apiVersion and kind
@@ -124,3 +126,14 @@ func outOfClusterConfig() (*rest.Config, error) {
 	config, err := clientcmd.BuildConfigFromFlags("", kubeconfig)
 	return config, err
 }
+
+// runBackgroundCacheReset - Starts the rest mapper cache reseting
+// at a duration given.
+func runBackgroundCacheReset(duration time.Duration) {
+	ticker := time.NewTicker(duration)
+	go func() {
+		for range ticker.C {
+			restMapper.Reset()
+		}
+	}()
+}