prove that informer+lister basically functions

Author: deads2k

pkg/manifestclienttest/client_test.go

@@ -50,7 +50,7 @@ func TestSimpleChecks(t *testing.T) {
 				if err != nil {
 					t.Fatal(err)
 				}
-				obj, err := kubeClient.CoreV1().Secrets("openshift-config").Get(context.TODO(), "deployer-dockercfg-7xzx7", metav1.GetOptions{})
+				obj, err := kubeClient.CoreV1().Secrets("openshift-apiserver").Get(context.TODO(), "default-dockercfg-nrrk8", metav1.GetOptions{})
 				if err != nil {
 					t.Fatal(err)
 				}
@@ -66,7 +66,7 @@ func TestSimpleChecks(t *testing.T) {
 				if err != nil {
 					t.Fatal(err)
 				}
-				obj, err := kubeClient.CoreV1().Secrets("openshift-config").Get(context.TODO(), "pull-secret", metav1.GetOptions{})
+				obj, err := kubeClient.CoreV1().Secrets("openshift-apiserver").Get(context.TODO(), "pull-secret", metav1.GetOptions{})
 				if err != nil {
 					t.Fatal(err)
 				}
@@ -118,7 +118,7 @@ func TestSimpleChecks(t *testing.T) {
 				if err != nil {
 					t.Fatal(err)
 				}
-				if len(obj.Items) != 120 {
+				if len(obj.Items) != 2 {
 					t.Fatal(len(obj.Items))
 				}
 			},
@@ -130,11 +130,11 @@ func TestSimpleChecks(t *testing.T) {
 				if err != nil {
 					t.Fatal(err)
 				}
-				obj, err := kubeClient.AppsV1().DaemonSets("").List(context.TODO(), metav1.ListOptions{})
+				obj, err := kubeClient.AppsV1().Deployments("").List(context.TODO(), metav1.ListOptions{})
 				if err != nil {
 					t.Fatal(err)
 				}
-				if len(obj.Items) != 16 {
+				if len(obj.Items) != 3 {
 					t.Fatal(len(obj.Items))
 				}
 			},
@@ -146,11 +146,11 @@ func TestSimpleChecks(t *testing.T) {
 				if err != nil {
 					t.Fatal(err)
 				}
-				obj, err := kubeClient.CoreV1().Secrets("openshift-config").List(context.TODO(), metav1.ListOptions{})
+				obj, err := kubeClient.CoreV1().Secrets("openshift-apiserver").List(context.TODO(), metav1.ListOptions{})
 				if err != nil {
 					t.Fatal(err)
 				}
-				if len(obj.Items) != 13 {
+				if len(obj.Items) != 10 {
 					t.Fatal(len(obj.Items))
 				}
 			},

pkg/manifestclienttest/informer_test.go

@@ -0,0 +1,77 @@
+package manifestclienttest
+
+import (
+	"context"
+	"net/http"
+	"testing"
+	"time"
+
+	configinformers "github.com/openshift/client-go/config/informers/externalversions"
+	"k8s.io/client-go/tools/cache"
+
+	"github.com/davecgh/go-spew/spew"
+	configclient "github.com/openshift/client-go/config/clientset/versioned"
+	apierrors "k8s.io/apimachinery/pkg/api/errors"
+	"k8s.io/client-go/rest"
+)
+
+func TestBasicInformer(t *testing.T) {
+	tests := []struct {
+		name   string
+		testFn func(*testing.T, *http.Client)
+	}{
+		{
+			name: "informer-synced-compiled-client-with-data",
+			testFn: func(t *testing.T, httpClient *http.Client) {
+				ctx, cancel := context.WithCancel(context.Background())
+				defer cancel()
+
+				configClient, err := configclient.NewForConfigAndClient(&rest.Config{}, httpClient)
+				if err != nil {
+					t.Fatal(err)
+				}
+				informers := configinformers.NewSharedInformerFactory(configClient, 0)
+				featureGateInformer := informers.Config().V1().FeatureGates()
+				featureGateInformer.Informer()
+				informers.Start(ctx.Done())
+
+				timedOutCh := make(chan struct{})
+				go func() {
+					select {
+					case <-time.After(1 * time.Second):
+						close(timedOutCh)
+
+					}
+				}()
+				if !cache.WaitForCacheSync(timedOutCh, featureGateInformer.Informer().HasSynced) {
+					t.Fatal("failed to sync")
+				}
+
+				featureGatesCluster, err := featureGateInformer.Lister().Get("cluster")
+				if err != nil {
+					t.Fatal(err)
+				}
+				if len(featureGatesCluster.Status.FeatureGates) == 0 {
+					t.Fatal(spew.Sdump(featureGatesCluster))
+				}
+				missing, err := featureGateInformer.Lister().Get("missing")
+				if !apierrors.IsNotFound(err) {
+					t.Fatal(err)
+				}
+				if missing != nil {
+					t.Fatal(missing)
+				}
+			},
+		},
+	}
+
+	for _, roundTripperTest := range defaultRoundTrippers(t) {
+		t.Run(roundTripperTest.name, func(t *testing.T) {
+			for _, test := range tests {
+				t.Run(test.name, func(t *testing.T) {
+					test.testFn(t, roundTripperTest.getClient())
+				})
+			}
+		})
+	}
+}