mirror of
https://github.com/vmware-tanzu/pinniped.git
synced 2026-08-15 11:46:12 +00:00
standardize import of "k8s.io/client-go/kubernetes/fake"
This commit is contained in:
@@ -16,7 +16,7 @@ import (
|
||||
"k8s.io/apimachinery/pkg/runtime"
|
||||
"k8s.io/apimachinery/pkg/runtime/schema"
|
||||
k8sinformers "k8s.io/client-go/informers"
|
||||
kubernetesfake "k8s.io/client-go/kubernetes/fake"
|
||||
kubefake "k8s.io/client-go/kubernetes/fake"
|
||||
coretesting "k8s.io/client-go/testing"
|
||||
apiregistrationv1 "k8s.io/kube-aggregator/pkg/apis/apiregistration/v1"
|
||||
aggregatorfake "k8s.io/kube-aggregator/pkg/client/clientset_generated/clientset/fake"
|
||||
@@ -109,7 +109,7 @@ func TestAPIServiceUpdaterControllerSync(t *testing.T) {
|
||||
|
||||
var subject controllerlib.Controller
|
||||
var aggregatorAPIClient *aggregatorfake.Clientset
|
||||
var kubeInformerClient *kubernetesfake.Clientset
|
||||
var kubeInformerClient *kubefake.Clientset
|
||||
var kubeInformers k8sinformers.SharedInformerFactory
|
||||
var cancelContext context.Context
|
||||
var cancelContextCancelFunc context.CancelFunc
|
||||
@@ -148,7 +148,7 @@ func TestAPIServiceUpdaterControllerSync(t *testing.T) {
|
||||
|
||||
cancelContext, cancelContextCancelFunc = context.WithCancel(context.Background())
|
||||
|
||||
kubeInformerClient = kubernetesfake.NewClientset()
|
||||
kubeInformerClient = kubefake.NewClientset()
|
||||
kubeInformers = k8sinformers.NewSharedInformerFactory(kubeInformerClient, 0)
|
||||
//nolint:staticcheck // as of v0.35.0, this package does not offer a NewClientset() function
|
||||
aggregatorAPIClient = aggregatorfake.NewSimpleClientset()
|
||||
|
||||
@@ -21,7 +21,7 @@ import (
|
||||
"k8s.io/apimachinery/pkg/runtime/schema"
|
||||
"k8s.io/apimachinery/pkg/types"
|
||||
k8sinformers "k8s.io/client-go/informers"
|
||||
kubernetesfake "k8s.io/client-go/kubernetes/fake"
|
||||
kubefake "k8s.io/client-go/kubernetes/fake"
|
||||
kubetesting "k8s.io/client-go/testing"
|
||||
|
||||
"go.pinniped.dev/internal/controllerlib"
|
||||
@@ -90,7 +90,7 @@ func TestExpirerControllerFilters(t *testing.T) {
|
||||
t.Parallel()
|
||||
|
||||
secretsInformer := k8sinformers.NewSharedInformerFactory(
|
||||
kubernetesfake.NewClientset(),
|
||||
kubefake.NewClientset(),
|
||||
0,
|
||||
).Core().V1().Secrets()
|
||||
withInformer := testutil.NewObservableWithInformerOption()
|
||||
@@ -127,7 +127,7 @@ func TestExpirerControllerSync(t *testing.T) {
|
||||
name string
|
||||
renewBefore time.Duration
|
||||
fillSecretData func(*testing.T, map[string][]byte)
|
||||
configKubeAPIClient func(*kubernetesfake.Clientset)
|
||||
configKubeAPIClient func(*kubefake.Clientset)
|
||||
wantDelete bool
|
||||
wantLog string
|
||||
wantError string
|
||||
@@ -197,7 +197,7 @@ func TestExpirerControllerSync(t *testing.T) {
|
||||
|
||||
m[fakeTestKey] = certPEM
|
||||
},
|
||||
configKubeAPIClient: func(c *kubernetesfake.Clientset) {
|
||||
configKubeAPIClient: func(c *kubefake.Clientset) {
|
||||
c.PrependReactor("delete", "secrets", func(_ kubetesting.Action) (bool, runtime.Object, error) {
|
||||
return true, nil, errors.New("delete failed: some delete error")
|
||||
})
|
||||
@@ -224,7 +224,7 @@ func TestExpirerControllerSync(t *testing.T) {
|
||||
ctx, cancel := context.WithCancel(context.Background())
|
||||
defer cancel()
|
||||
|
||||
kubeAPIClient := kubernetesfake.NewClientset()
|
||||
kubeAPIClient := kubefake.NewClientset()
|
||||
if test.configKubeAPIClient != nil {
|
||||
test.configKubeAPIClient(kubeAPIClient)
|
||||
}
|
||||
@@ -232,7 +232,7 @@ func TestExpirerControllerSync(t *testing.T) {
|
||||
testRV := "rv_001"
|
||||
testUID := types.UID("uid_002")
|
||||
|
||||
kubeInformerClient := kubernetesfake.NewClientset()
|
||||
kubeInformerClient := kubefake.NewClientset()
|
||||
name := certsSecretResourceName
|
||||
namespace := "some-namespace"
|
||||
if test.fillSecretData != nil {
|
||||
|
||||
@@ -17,7 +17,7 @@ import (
|
||||
"k8s.io/apimachinery/pkg/runtime"
|
||||
"k8s.io/apimachinery/pkg/runtime/schema"
|
||||
k8sinformers "k8s.io/client-go/informers"
|
||||
kubernetesfake "k8s.io/client-go/kubernetes/fake"
|
||||
kubefake "k8s.io/client-go/kubernetes/fake"
|
||||
coretesting "k8s.io/client-go/testing"
|
||||
|
||||
"go.pinniped.dev/internal/controllerlib"
|
||||
@@ -123,8 +123,8 @@ func TestManagerControllerSync(t *testing.T) {
|
||||
var r *require.Assertions
|
||||
|
||||
var subject controllerlib.Controller
|
||||
var kubeAPIClient *kubernetesfake.Clientset
|
||||
var kubeInformerClient *kubernetesfake.Clientset
|
||||
var kubeAPIClient *kubefake.Clientset
|
||||
var kubeInformerClient *kubefake.Clientset
|
||||
var kubeInformers k8sinformers.SharedInformerFactory
|
||||
var cancelContext context.Context
|
||||
var cancelContextCancelFunc context.CancelFunc
|
||||
@@ -170,9 +170,9 @@ func TestManagerControllerSync(t *testing.T) {
|
||||
|
||||
cancelContext, cancelContextCancelFunc = context.WithCancel(context.Background())
|
||||
|
||||
kubeInformerClient = kubernetesfake.NewClientset()
|
||||
kubeInformerClient = kubefake.NewClientset()
|
||||
kubeInformers = k8sinformers.NewSharedInformerFactory(kubeInformerClient, 0)
|
||||
kubeAPIClient = kubernetesfake.NewClientset()
|
||||
kubeAPIClient = kubefake.NewClientset()
|
||||
})
|
||||
|
||||
it.After(func() {
|
||||
|
||||
@@ -15,7 +15,7 @@ import (
|
||||
corev1 "k8s.io/api/core/v1"
|
||||
metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
|
||||
k8sinformers "k8s.io/client-go/informers"
|
||||
kubernetesfake "k8s.io/client-go/kubernetes/fake"
|
||||
kubefake "k8s.io/client-go/kubernetes/fake"
|
||||
|
||||
"go.pinniped.dev/internal/certauthority"
|
||||
"go.pinniped.dev/internal/controllerlib"
|
||||
@@ -105,7 +105,7 @@ func TestObserverControllerSync(t *testing.T) {
|
||||
var r *require.Assertions
|
||||
|
||||
var subject controllerlib.Controller
|
||||
var kubeInformerClient *kubernetesfake.Clientset
|
||||
var kubeInformerClient *kubefake.Clientset
|
||||
var kubeInformers k8sinformers.SharedInformerFactory
|
||||
var cancelContext context.Context
|
||||
var cancelContextCancelFunc context.CancelFunc
|
||||
@@ -144,7 +144,7 @@ func TestObserverControllerSync(t *testing.T) {
|
||||
|
||||
cancelContext, cancelContextCancelFunc = context.WithCancel(context.Background())
|
||||
|
||||
kubeInformerClient = kubernetesfake.NewClientset()
|
||||
kubeInformerClient = kubefake.NewClientset()
|
||||
kubeInformers = k8sinformers.NewSharedInformerFactory(kubeInformerClient, 0)
|
||||
dynamicCertProvider = dynamiccert.NewServingCert(name)
|
||||
})
|
||||
|
||||
@@ -35,7 +35,7 @@ import (
|
||||
"k8s.io/apiserver/pkg/authentication/authenticator"
|
||||
"k8s.io/apiserver/pkg/authentication/user"
|
||||
k8sinformers "k8s.io/client-go/informers"
|
||||
kubernetesfake "k8s.io/client-go/kubernetes/fake"
|
||||
kubefake "k8s.io/client-go/kubernetes/fake"
|
||||
coretesting "k8s.io/client-go/testing"
|
||||
clocktesting "k8s.io/utils/clock/testing"
|
||||
|
||||
@@ -2993,7 +2993,7 @@ func TestController(t *testing.T) {
|
||||
tt.configClient(pinnipedAPIClient)
|
||||
}
|
||||
pinnipedInformers := conciergeinformers.NewSharedInformerFactory(pinnipedAPIClient, 0)
|
||||
kubeInformers := k8sinformers.NewSharedInformerFactory(kubernetesfake.NewClientset(tt.secretsAndConfigMaps...), 0)
|
||||
kubeInformers := k8sinformers.NewSharedInformerFactory(kubefake.NewClientset(tt.secretsAndConfigMaps...), 0)
|
||||
cache := authncache.New()
|
||||
|
||||
logger, log := plog.TestLogger(t)
|
||||
@@ -3536,7 +3536,7 @@ func TestControllerFilterSecret(t *testing.T) {
|
||||
nowDoesntMatter := time.Date(1122, time.September, 33, 4, 55, 56, 778899, time.Local)
|
||||
frozenClock := clocktesting.NewFakeClock(nowDoesntMatter)
|
||||
|
||||
kubeInformers := k8sinformers.NewSharedInformerFactoryWithOptions(kubernetesfake.NewClientset(), 0)
|
||||
kubeInformers := k8sinformers.NewSharedInformerFactoryWithOptions(kubefake.NewClientset(), 0)
|
||||
secretInformer := kubeInformers.Core().V1().Secrets()
|
||||
configMapInformer := kubeInformers.Core().V1().ConfigMaps()
|
||||
//nolint:staticcheck // our codegen does not yet generate a NewClientset() function
|
||||
@@ -3597,7 +3597,7 @@ func TestControllerFilterConfigMap(t *testing.T) {
|
||||
nowDoesntMatter := time.Date(1122, time.September, 33, 4, 55, 56, 778899, time.Local)
|
||||
frozenClock := clocktesting.NewFakeClock(nowDoesntMatter)
|
||||
|
||||
kubeInformers := k8sinformers.NewSharedInformerFactoryWithOptions(kubernetesfake.NewClientset(), 0)
|
||||
kubeInformers := k8sinformers.NewSharedInformerFactoryWithOptions(kubefake.NewClientset(), 0)
|
||||
secretInformer := kubeInformers.Core().V1().Secrets()
|
||||
configMapInformer := kubeInformers.Core().V1().ConfigMaps()
|
||||
//nolint:staticcheck // our codegen does not yet generate a NewClientset() function
|
||||
|
||||
@@ -27,7 +27,7 @@ import (
|
||||
"k8s.io/apimachinery/pkg/runtime"
|
||||
"k8s.io/apimachinery/pkg/runtime/schema"
|
||||
k8sinformers "k8s.io/client-go/informers"
|
||||
kubernetesfake "k8s.io/client-go/kubernetes/fake"
|
||||
kubefake "k8s.io/client-go/kubernetes/fake"
|
||||
coretesting "k8s.io/client-go/testing"
|
||||
clocktesting "k8s.io/utils/clock/testing"
|
||||
"k8s.io/utils/ptr"
|
||||
@@ -2124,7 +2124,7 @@ func TestController(t *testing.T) {
|
||||
tt.configClient(pinnipedAPIClient)
|
||||
}
|
||||
pinnipedInformers := conciergeinformers.NewSharedInformerFactory(pinnipedAPIClient, 0)
|
||||
kubeInformers := k8sinformers.NewSharedInformerFactory(kubernetesfake.NewClientset(tt.secretsAndConfigMaps...), 0)
|
||||
kubeInformers := k8sinformers.NewSharedInformerFactory(kubefake.NewClientset(tt.secretsAndConfigMaps...), 0)
|
||||
cache := authncache.New()
|
||||
|
||||
logger, log := plog.TestLogger(t)
|
||||
@@ -2378,7 +2378,7 @@ func TestControllerFilterSecret(t *testing.T) {
|
||||
nowDoesntMatter := time.Date(1122, time.September, 33, 4, 55, 56, 778899, time.Local)
|
||||
frozenClock := clocktesting.NewFakeClock(nowDoesntMatter)
|
||||
|
||||
kubeInformers := k8sinformers.NewSharedInformerFactoryWithOptions(kubernetesfake.NewClientset(), 0)
|
||||
kubeInformers := k8sinformers.NewSharedInformerFactoryWithOptions(kubefake.NewClientset(), 0)
|
||||
secretInformer := kubeInformers.Core().V1().Secrets()
|
||||
configMapInformer := kubeInformers.Core().V1().ConfigMaps()
|
||||
//nolint:staticcheck // our codegen does not yet generate a NewClientset() function
|
||||
@@ -2442,7 +2442,7 @@ func TestControllerFilterConfigMap(t *testing.T) {
|
||||
nowDoesntMatter := time.Date(1122, time.September, 33, 4, 55, 56, 778899, time.Local)
|
||||
frozenClock := clocktesting.NewFakeClock(nowDoesntMatter)
|
||||
|
||||
kubeInformers := k8sinformers.NewSharedInformerFactoryWithOptions(kubernetesfake.NewClientset(), 0)
|
||||
kubeInformers := k8sinformers.NewSharedInformerFactoryWithOptions(kubefake.NewClientset(), 0)
|
||||
secretInformer := kubeInformers.Core().V1().Secrets()
|
||||
configMapInformer := kubeInformers.Core().V1().ConfigMaps()
|
||||
//nolint:staticcheck // our codegen does not yet generate a NewClientset() function
|
||||
|
||||
@@ -31,7 +31,7 @@ import (
|
||||
"k8s.io/apimachinery/pkg/runtime/schema"
|
||||
"k8s.io/apimachinery/pkg/util/intstr"
|
||||
k8sinformers "k8s.io/client-go/informers"
|
||||
kubernetesfake "k8s.io/client-go/kubernetes/fake"
|
||||
kubefake "k8s.io/client-go/kubernetes/fake"
|
||||
coretesting "k8s.io/client-go/testing"
|
||||
clocktesting "k8s.io/utils/clock/testing"
|
||||
|
||||
@@ -282,11 +282,11 @@ func TestImpersonatorConfigControllerSync(t *testing.T) {
|
||||
var r *require.Assertions
|
||||
|
||||
var subject controllerlib.Controller
|
||||
var kubeAPIClient *kubernetesfake.Clientset
|
||||
var kubeAPIClient *kubefake.Clientset
|
||||
var pinnipedAPIClient *conciergefake.Clientset
|
||||
var pinnipedInformerClient *conciergefake.Clientset
|
||||
var pinnipedInformers conciergeinformers.SharedInformerFactory
|
||||
var kubeInformerClient *kubernetesfake.Clientset
|
||||
var kubeInformerClient *kubefake.Clientset
|
||||
var kubeInformers k8sinformers.SharedInformerFactory
|
||||
var cancelContext context.Context
|
||||
var cancelContextCancelFunc context.CancelFunc
|
||||
@@ -807,19 +807,19 @@ func TestImpersonatorConfigControllerSync(t *testing.T) {
|
||||
waitForObjectToAppearInInformer(service, informer)
|
||||
}
|
||||
|
||||
var addLoadBalancerServiceToTracker = func(resourceName string, client *kubernetesfake.Clientset) {
|
||||
var addLoadBalancerServiceToTracker = func(resourceName string, client *kubefake.Clientset) {
|
||||
loadBalancerService := newLoadBalancerService(resourceName, corev1.ServiceStatus{})
|
||||
r.NoError(client.Tracker().Add(loadBalancerService))
|
||||
}
|
||||
|
||||
var addLoadBalancerServiceWithIngressToTracker = func(resourceName string, ingress []corev1.LoadBalancerIngress, client *kubernetesfake.Clientset) {
|
||||
var addLoadBalancerServiceWithIngressToTracker = func(resourceName string, ingress []corev1.LoadBalancerIngress, client *kubefake.Clientset) {
|
||||
loadBalancerService := newLoadBalancerService(resourceName, corev1.ServiceStatus{
|
||||
LoadBalancer: corev1.LoadBalancerStatus{Ingress: ingress},
|
||||
})
|
||||
r.NoError(client.Tracker().Add(loadBalancerService))
|
||||
}
|
||||
|
||||
var addClusterIPServiceToTracker = func(resourceName string, clusterIP string, client *kubernetesfake.Clientset) {
|
||||
var addClusterIPServiceToTracker = func(resourceName string, clusterIP string, client *kubefake.Clientset) {
|
||||
clusterIPService := newClusterIPService(resourceName, corev1.ServiceStatus{}, corev1.ServiceSpec{
|
||||
Type: corev1.ServiceTypeClusterIP,
|
||||
ClusterIP: clusterIP,
|
||||
@@ -835,7 +835,7 @@ func TestImpersonatorConfigControllerSync(t *testing.T) {
|
||||
r.NoError(client.Tracker().Add(clusterIPService))
|
||||
}
|
||||
|
||||
var addDualStackClusterIPServiceToTracker = func(resourceName string, clusterIP0 string, clusterIP1 string, client *kubernetesfake.Clientset) {
|
||||
var addDualStackClusterIPServiceToTracker = func(resourceName string, clusterIP0 string, clusterIP1 string, client *kubefake.Clientset) {
|
||||
clusterIPService := newClusterIPService(resourceName, corev1.ServiceStatus{}, corev1.ServiceSpec{
|
||||
Type: corev1.ServiceTypeClusterIP,
|
||||
ClusterIP: clusterIP0,
|
||||
@@ -852,21 +852,21 @@ func TestImpersonatorConfigControllerSync(t *testing.T) {
|
||||
r.NoError(client.Tracker().Add(clusterIPService))
|
||||
}
|
||||
|
||||
var addSecretToTrackers = func(secret *corev1.Secret, clients ...*kubernetesfake.Clientset) {
|
||||
var addSecretToTrackers = func(secret *corev1.Secret, clients ...*kubefake.Clientset) {
|
||||
for _, client := range clients {
|
||||
secretCopy := secret.DeepCopy()
|
||||
r.NoError(client.Tracker().Add(secretCopy))
|
||||
}
|
||||
}
|
||||
|
||||
var addServiceToTrackers = func(service *corev1.Service, clients ...*kubernetesfake.Clientset) {
|
||||
var addServiceToTrackers = func(service *corev1.Service, clients ...*kubefake.Clientset) {
|
||||
for _, client := range clients {
|
||||
serviceCopy := service.DeepCopy()
|
||||
r.NoError(client.Tracker().Add(serviceCopy))
|
||||
}
|
||||
}
|
||||
|
||||
var deleteServiceFromTracker = func(resourceName string, client *kubernetesfake.Clientset) {
|
||||
var deleteServiceFromTracker = func(resourceName string, client *kubefake.Clientset) {
|
||||
r.NoError(client.Tracker().Delete(
|
||||
schema.GroupVersionResource{Version: "v1", Resource: "services"},
|
||||
installedInNamespace,
|
||||
@@ -874,7 +874,7 @@ func TestImpersonatorConfigControllerSync(t *testing.T) {
|
||||
))
|
||||
}
|
||||
|
||||
var deleteSecretFromTracker = func(resourceName string, client *kubernetesfake.Clientset) {
|
||||
var deleteSecretFromTracker = func(resourceName string, client *kubefake.Clientset) {
|
||||
r.NoError(client.Tracker().Delete(
|
||||
schema.GroupVersionResource{Version: "v1", Resource: "secrets"},
|
||||
installedInNamespace,
|
||||
@@ -882,7 +882,7 @@ func TestImpersonatorConfigControllerSync(t *testing.T) {
|
||||
))
|
||||
}
|
||||
|
||||
var addNodeWithRoleToTracker = func(role string, client *kubernetesfake.Clientset) {
|
||||
var addNodeWithRoleToTracker = func(role string, client *kubefake.Clientset) {
|
||||
r.NoError(client.Tracker().Add(
|
||||
&corev1.Node{
|
||||
ObjectMeta: metav1.ObjectMeta{
|
||||
@@ -1132,11 +1132,11 @@ func TestImpersonatorConfigControllerSync(t *testing.T) {
|
||||
pinnipedInformerClient = conciergefake.NewSimpleClientset()
|
||||
pinnipedInformers = conciergeinformers.NewSharedInformerFactoryWithOptions(pinnipedInformerClient, 0)
|
||||
|
||||
kubeInformerClient = kubernetesfake.NewClientset()
|
||||
kubeInformerClient = kubefake.NewClientset()
|
||||
kubeInformers = k8sinformers.NewSharedInformerFactoryWithOptions(kubeInformerClient, 0,
|
||||
k8sinformers.WithNamespace(installedInNamespace),
|
||||
)
|
||||
kubeAPIClient = kubernetesfake.NewClientset()
|
||||
kubeAPIClient = kubefake.NewClientset()
|
||||
//nolint:staticcheck // our codegen does not yet generate a NewClientset() function
|
||||
pinnipedAPIClient = conciergefake.NewSimpleClientset()
|
||||
frozenNow = time.Date(2021, time.March, 2, 7, 42, 0, 0, time.Local)
|
||||
|
||||
+6
-6
@@ -14,7 +14,7 @@ import (
|
||||
"k8s.io/apimachinery/pkg/runtime"
|
||||
"k8s.io/apimachinery/pkg/runtime/schema"
|
||||
kubeinformers "k8s.io/client-go/informers"
|
||||
kubernetesfake "k8s.io/client-go/kubernetes/fake"
|
||||
kubefake "k8s.io/client-go/kubernetes/fake"
|
||||
kubetesting "k8s.io/client-go/testing"
|
||||
|
||||
"go.pinniped.dev/internal/controllerlib"
|
||||
@@ -77,7 +77,7 @@ func TestSync(t *testing.T) {
|
||||
name string
|
||||
secretNameToDelete string
|
||||
namespace string
|
||||
addReactors func(*kubernetesfake.Clientset)
|
||||
addReactors func(*kubefake.Clientset)
|
||||
expectedErrMessage string
|
||||
expectedActions []kubetesting.Action
|
||||
}{
|
||||
@@ -106,7 +106,7 @@ func TestSync(t *testing.T) {
|
||||
name: "returns API errors",
|
||||
secretNameToDelete: "secret-to-delete",
|
||||
namespace: "other-namespace",
|
||||
addReactors: func(clientset *kubernetesfake.Clientset) {
|
||||
addReactors: func(clientset *kubefake.Clientset) {
|
||||
clientset.PrependReactor(
|
||||
"delete",
|
||||
"secrets",
|
||||
@@ -170,11 +170,11 @@ func TestSync(t *testing.T) {
|
||||
}
|
||||
}
|
||||
|
||||
func setupKubernetes(t *testing.T, namespace string) (*kubernetesfake.Clientset, kubeinformers.SharedInformerFactory) {
|
||||
func setupKubernetes(t *testing.T, namespace string) (*kubefake.Clientset, kubeinformers.SharedInformerFactory) {
|
||||
t.Helper()
|
||||
|
||||
kubeAPIClient := kubernetesfake.NewClientset()
|
||||
kubeInformerClient := kubernetesfake.NewClientset()
|
||||
kubeAPIClient := kubefake.NewClientset()
|
||||
kubeInformerClient := kubefake.NewClientset()
|
||||
|
||||
kubeInformers := kubeinformers.NewSharedInformerFactory(
|
||||
kubeInformerClient,
|
||||
|
||||
+5
-5
@@ -20,7 +20,7 @@ import (
|
||||
metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
|
||||
"k8s.io/apimachinery/pkg/runtime"
|
||||
"k8s.io/client-go/informers"
|
||||
"k8s.io/client-go/kubernetes/fake"
|
||||
kubefake "k8s.io/client-go/kubernetes/fake"
|
||||
|
||||
idpv1alpha1 "go.pinniped.dev/generated/latest/apis/supervisor/idp/v1alpha1"
|
||||
supervisorfake "go.pinniped.dev/generated/latest/client/supervisor/clientset/versioned/fake"
|
||||
@@ -99,7 +99,7 @@ func TestActiveDirectoryUpstreamWatcherControllerFilterSecrets(t *testing.T) {
|
||||
fakePinnipedClient := supervisorfake.NewSimpleClientset()
|
||||
pinnipedInformers := supervisorinformers.NewSharedInformerFactory(fakePinnipedClient, 0)
|
||||
activeDirectoryIDPInformer := pinnipedInformers.IDP().V1alpha1().ActiveDirectoryIdentityProviders()
|
||||
fakeKubeClient := fake.NewClientset()
|
||||
fakeKubeClient := kubefake.NewClientset()
|
||||
kubeInformers := informers.NewSharedInformerFactory(fakeKubeClient, 0)
|
||||
secretInformer := kubeInformers.Core().V1().Secrets()
|
||||
configMapInformer := kubeInformers.Core().V1().ConfigMaps()
|
||||
@@ -145,7 +145,7 @@ func TestActiveDirectoryUpstreamWatcherControllerFilterConfigMaps(t *testing.T)
|
||||
fakePinnipedClient := supervisorfake.NewSimpleClientset()
|
||||
pinnipedInformers := supervisorinformers.NewSharedInformerFactory(fakePinnipedClient, 0)
|
||||
activeDirectoryIDPInformer := pinnipedInformers.IDP().V1alpha1().ActiveDirectoryIdentityProviders()
|
||||
fakeKubeClient := fake.NewClientset()
|
||||
fakeKubeClient := kubefake.NewClientset()
|
||||
kubeInformers := informers.NewSharedInformerFactory(fakeKubeClient, 0)
|
||||
secretInformer := kubeInformers.Core().V1().Secrets()
|
||||
configMapInformer := kubeInformers.Core().V1().ConfigMaps()
|
||||
@@ -191,7 +191,7 @@ func TestActiveDirectoryUpstreamWatcherControllerFilterActiveDirectoryIdentityPr
|
||||
fakePinnipedClient := supervisorfake.NewSimpleClientset()
|
||||
pinnipedInformers := supervisorinformers.NewSharedInformerFactory(fakePinnipedClient, 0)
|
||||
activeDirectoryIDPInformer := pinnipedInformers.IDP().V1alpha1().ActiveDirectoryIdentityProviders()
|
||||
fakeKubeClient := fake.NewClientset()
|
||||
fakeKubeClient := kubefake.NewClientset()
|
||||
kubeInformers := informers.NewSharedInformerFactory(fakeKubeClient, 0)
|
||||
secretInformer := kubeInformers.Core().V1().Secrets()
|
||||
configMapInformer := kubeInformers.Core().V1().ConfigMaps()
|
||||
@@ -2313,7 +2313,7 @@ func TestActiveDirectoryUpstreamWatcherControllerSync(t *testing.T) {
|
||||
//nolint:staticcheck // our codegen does not yet generate a NewClientset() function
|
||||
fakePinnipedClient := supervisorfake.NewSimpleClientset(tt.inputUpstreams...)
|
||||
pinnipedInformers := supervisorinformers.NewSharedInformerFactory(fakePinnipedClient, 0)
|
||||
fakeKubeClient := fake.NewClientset(tt.inputK8sObjects...)
|
||||
fakeKubeClient := kubefake.NewClientset(tt.inputK8sObjects...)
|
||||
kubeInformers := informers.NewSharedInformerFactory(fakeKubeClient, 0)
|
||||
cache := dynamicupstreamprovider.NewDynamicUpstreamIDPProvider()
|
||||
cache.SetActiveDirectoryIdentityProviders([]upstreamprovider.UpstreamLDAPIdentityProviderI{
|
||||
|
||||
@@ -19,7 +19,7 @@ import (
|
||||
"k8s.io/apimachinery/pkg/runtime"
|
||||
"k8s.io/apimachinery/pkg/runtime/schema"
|
||||
k8sinformers "k8s.io/client-go/informers"
|
||||
kubernetesfake "k8s.io/client-go/kubernetes/fake"
|
||||
kubefake "k8s.io/client-go/kubernetes/fake"
|
||||
kubetesting "k8s.io/client-go/testing"
|
||||
|
||||
supervisorconfigv1alpha1 "go.pinniped.dev/generated/latest/apis/supervisor/config/v1alpha1"
|
||||
@@ -180,7 +180,7 @@ func TestFederationDomainControllerFilterSecret(t *testing.T) {
|
||||
)
|
||||
|
||||
secretInformer := k8sinformers.NewSharedInformerFactory(
|
||||
kubernetesfake.NewClientset(),
|
||||
kubefake.NewClientset(),
|
||||
0,
|
||||
).Core().V1().Secrets()
|
||||
federationDomainInformer := supervisorinformers.NewSharedInformerFactory(
|
||||
@@ -243,7 +243,7 @@ func TestNewFederationDomainSecretsControllerFilterFederationDomain(t *testing.T
|
||||
)
|
||||
|
||||
secretInformer := k8sinformers.NewSharedInformerFactory(
|
||||
kubernetesfake.NewClientset(),
|
||||
kubefake.NewClientset(),
|
||||
0,
|
||||
).Core().V1().Secrets()
|
||||
federationDomainInformer := supervisorinformers.NewSharedInformerFactory(
|
||||
@@ -362,7 +362,7 @@ func TestFederationDomainSecretsControllerSync(t *testing.T) {
|
||||
tests := []struct {
|
||||
name string
|
||||
storage func(**supervisorconfigv1alpha1.FederationDomain, **corev1.Secret)
|
||||
client func(*supervisorfake.Clientset, *kubernetesfake.Clientset)
|
||||
client func(*supervisorfake.Clientset, *kubefake.Clientset)
|
||||
secretHelper func(*mocksecrethelper.MockSecretHelper)
|
||||
wantFederationDomainActions []kubetesting.Action
|
||||
wantSecretActions []kubetesting.Action
|
||||
@@ -408,7 +408,7 @@ func TestFederationDomainSecretsControllerSync(t *testing.T) {
|
||||
secretHelper.EXPECT().Generate(goodFederationDomain).Times(1).Return(goodSecret, nil)
|
||||
secretHelper.EXPECT().ObserveActiveSecretAndUpdateParentFederationDomain(goodFederationDomain, goodSecret).Times(1).Return(goodFederationDomainWithTokenSigningKey)
|
||||
},
|
||||
client: func(c *supervisorfake.Clientset, _ *kubernetesfake.Clientset) {
|
||||
client: func(c *supervisorfake.Clientset, _ *kubefake.Clientset) {
|
||||
c.PrependReactor("get", "federationdomains", func(_ kubetesting.Action) (bool, runtime.Object, error) {
|
||||
return true, goodFederationDomainWithJWKS, nil
|
||||
})
|
||||
@@ -431,7 +431,7 @@ func TestFederationDomainSecretsControllerSync(t *testing.T) {
|
||||
secretHelper.EXPECT().Generate(goodFederationDomain).Times(1).Return(goodSecret, nil)
|
||||
secretHelper.EXPECT().ObserveActiveSecretAndUpdateParentFederationDomain(goodFederationDomain, goodSecret).Times(1).Return(goodFederationDomainWithTokenSigningKey)
|
||||
},
|
||||
client: func(c *supervisorfake.Clientset, _ *kubernetesfake.Clientset) {
|
||||
client: func(c *supervisorfake.Clientset, _ *kubefake.Clientset) {
|
||||
c.PrependReactor("get", "federationdomains", func(_ kubetesting.Action) (bool, runtime.Object, error) {
|
||||
return true, goodFederationDomainWithJWKSAndTokenSigningKey, nil
|
||||
})
|
||||
@@ -495,7 +495,7 @@ func TestFederationDomainSecretsControllerSync(t *testing.T) {
|
||||
secretHelper.EXPECT().Generate(goodFederationDomain).Times(1).Return(goodSecret, nil)
|
||||
secretHelper.EXPECT().IsValid(goodFederationDomain, goodSecret).Times(1).Return(false)
|
||||
},
|
||||
client: func(_ *supervisorfake.Clientset, c *kubernetesfake.Clientset) {
|
||||
client: func(_ *supervisorfake.Clientset, c *kubefake.Clientset) {
|
||||
c.PrependReactor("get", "secrets", func(_ kubetesting.Action) (bool, runtime.Object, error) {
|
||||
return true, nil, errors.New("some get error")
|
||||
})
|
||||
@@ -513,7 +513,7 @@ func TestFederationDomainSecretsControllerSync(t *testing.T) {
|
||||
secretHelper: func(secretHelper *mocksecrethelper.MockSecretHelper) {
|
||||
secretHelper.EXPECT().Generate(goodFederationDomain).Times(1).Return(goodSecret, nil)
|
||||
},
|
||||
client: func(_ *supervisorfake.Clientset, c *kubernetesfake.Clientset) {
|
||||
client: func(_ *supervisorfake.Clientset, c *kubefake.Clientset) {
|
||||
c.PrependReactor("create", "secrets", func(_ kubetesting.Action) (bool, runtime.Object, error) {
|
||||
return true, nil, errors.New("some create error")
|
||||
})
|
||||
@@ -530,7 +530,7 @@ func TestFederationDomainSecretsControllerSync(t *testing.T) {
|
||||
secretHelper.EXPECT().Generate(goodFederationDomain).Times(1).Return(goodSecret, nil)
|
||||
secretHelper.EXPECT().IsValid(goodFederationDomain, goodSecret).Times(2).Return(false)
|
||||
},
|
||||
client: func(_ *supervisorfake.Clientset, c *kubernetesfake.Clientset) {
|
||||
client: func(_ *supervisorfake.Clientset, c *kubefake.Clientset) {
|
||||
c.PrependReactor("update", "secrets", func(_ kubetesting.Action) (bool, runtime.Object, error) {
|
||||
return true, nil, errors.New("some update error")
|
||||
})
|
||||
@@ -551,7 +551,7 @@ func TestFederationDomainSecretsControllerSync(t *testing.T) {
|
||||
secretHelper.EXPECT().IsValid(goodFederationDomain, invalidSecret).Times(3).Return(false)
|
||||
secretHelper.EXPECT().ObserveActiveSecretAndUpdateParentFederationDomain(goodFederationDomain, goodSecret).Times(1).Return(goodFederationDomainWithTokenSigningKey)
|
||||
},
|
||||
client: func(_ *supervisorfake.Clientset, c *kubernetesfake.Clientset) {
|
||||
client: func(_ *supervisorfake.Clientset, c *kubefake.Clientset) {
|
||||
once := sync.Once{}
|
||||
c.PrependReactor("update", "secrets", func(_ kubetesting.Action) (bool, runtime.Object, error) {
|
||||
var err error
|
||||
@@ -580,7 +580,7 @@ func TestFederationDomainSecretsControllerSync(t *testing.T) {
|
||||
secretHelper.EXPECT().IsValid(goodFederationDomain, invalidSecret).Times(2).Return(false)
|
||||
secretHelper.EXPECT().ObserveActiveSecretAndUpdateParentFederationDomain(goodFederationDomain, goodSecret).Times(1).Return(goodFederationDomainWithTokenSigningKey)
|
||||
},
|
||||
client: func(c *supervisorfake.Clientset, _ *kubernetesfake.Clientset) {
|
||||
client: func(c *supervisorfake.Clientset, _ *kubefake.Clientset) {
|
||||
c.PrependReactor("get", "federationdomains", func(_ kubetesting.Action) (bool, runtime.Object, error) {
|
||||
return true, nil, errors.New("some get error")
|
||||
})
|
||||
@@ -604,7 +604,7 @@ func TestFederationDomainSecretsControllerSync(t *testing.T) {
|
||||
secretHelper.EXPECT().IsValid(goodFederationDomain, invalidSecret).Times(2).Return(false)
|
||||
secretHelper.EXPECT().ObserveActiveSecretAndUpdateParentFederationDomain(goodFederationDomain, goodSecret).Times(1).Return(goodFederationDomainWithTokenSigningKey)
|
||||
},
|
||||
client: func(c *supervisorfake.Clientset, _ *kubernetesfake.Clientset) {
|
||||
client: func(c *supervisorfake.Clientset, _ *kubefake.Clientset) {
|
||||
once := sync.Once{}
|
||||
c.PrependReactor("update", "federationdomains", func(_ kubetesting.Action) (bool, runtime.Object, error) {
|
||||
var err error
|
||||
@@ -636,8 +636,8 @@ func TestFederationDomainSecretsControllerSync(t *testing.T) {
|
||||
//nolint:staticcheck // our codegen does not yet generate a NewClientset() function
|
||||
pinnipedInformerClient := supervisorfake.NewSimpleClientset()
|
||||
|
||||
kubeAPIClient := kubernetesfake.NewClientset()
|
||||
kubeInformerClient := kubernetesfake.NewClientset()
|
||||
kubeAPIClient := kubefake.NewClientset()
|
||||
kubeInformerClient := kubefake.NewClientset()
|
||||
|
||||
federationDomain := goodFederationDomain.DeepCopy()
|
||||
secret := goodSecret.DeepCopy()
|
||||
|
||||
@@ -17,7 +17,7 @@ import (
|
||||
"k8s.io/apimachinery/pkg/runtime"
|
||||
"k8s.io/apimachinery/pkg/runtime/schema"
|
||||
k8sinformers "k8s.io/client-go/informers"
|
||||
kubernetesfake "k8s.io/client-go/kubernetes/fake"
|
||||
kubefake "k8s.io/client-go/kubernetes/fake"
|
||||
kubetesting "k8s.io/client-go/testing"
|
||||
|
||||
"go.pinniped.dev/internal/controllerlib"
|
||||
@@ -104,7 +104,7 @@ func TestSupervisorSecretsControllerFilterSecret(t *testing.T) {
|
||||
t.Parallel()
|
||||
|
||||
secretInformer := k8sinformers.NewSharedInformerFactory(
|
||||
kubernetesfake.NewClientset(),
|
||||
kubefake.NewClientset(),
|
||||
0,
|
||||
).Core().V1().Secrets()
|
||||
withInformer := testutil.NewObservableWithInformerOption()
|
||||
@@ -131,7 +131,7 @@ func TestSupervisorSecretsControllerFilterSecret(t *testing.T) {
|
||||
func TestSupervisorSecretsControllerInitialEvent(t *testing.T) {
|
||||
initialEventOption := testutil.NewObservableWithInitialEventOption()
|
||||
secretInformer := k8sinformers.NewSharedInformerFactory(
|
||||
kubernetesfake.NewClientset(),
|
||||
kubefake.NewClientset(),
|
||||
0,
|
||||
).Core().V1().Secrets()
|
||||
_ = NewSupervisorSecretsController(
|
||||
@@ -199,7 +199,7 @@ func TestSupervisorSecretsControllerSync(t *testing.T) {
|
||||
name string
|
||||
storedSecret func(**corev1.Secret)
|
||||
generateKey func() ([]byte, error)
|
||||
apiClient func(*testing.T, *kubernetesfake.Clientset)
|
||||
apiClient func(*testing.T, *kubefake.Clientset)
|
||||
wantError string
|
||||
wantActions []kubetesting.Action
|
||||
wantCallbackSecret []byte
|
||||
@@ -256,7 +256,7 @@ func TestSupervisorSecretsControllerSync(t *testing.T) {
|
||||
storedSecret: func(secret **corev1.Secret) {
|
||||
*secret = nil
|
||||
},
|
||||
apiClient: func(t *testing.T, client *kubernetesfake.Clientset) {
|
||||
apiClient: func(t *testing.T, client *kubefake.Clientset) {
|
||||
client.PrependReactor("create", "secrets", func(action kubetesting.Action) (bool, runtime.Object, error) {
|
||||
return true, nil, errors.New("some create error")
|
||||
})
|
||||
@@ -271,7 +271,7 @@ func TestSupervisorSecretsControllerSync(t *testing.T) {
|
||||
storedSecret: func(secret **corev1.Secret) {
|
||||
(*secret).Data["key"] = []byte("too short") // force updating
|
||||
},
|
||||
apiClient: func(t *testing.T, client *kubernetesfake.Clientset) {
|
||||
apiClient: func(t *testing.T, client *kubefake.Clientset) {
|
||||
client.PrependReactor("update", "secrets", func(action kubetesting.Action) (bool, runtime.Object, error) {
|
||||
return true, nil, errors.New("some update error")
|
||||
})
|
||||
@@ -287,7 +287,7 @@ func TestSupervisorSecretsControllerSync(t *testing.T) {
|
||||
storedSecret: func(secret **corev1.Secret) {
|
||||
(*secret).Data["key"] = []byte("too short") // force updating
|
||||
},
|
||||
apiClient: func(t *testing.T, client *kubernetesfake.Clientset) {
|
||||
apiClient: func(t *testing.T, client *kubefake.Clientset) {
|
||||
client.PrependReactor("get", "secrets", func(action kubetesting.Action) (bool, runtime.Object, error) {
|
||||
return true, nil, errors.New("some get error")
|
||||
})
|
||||
@@ -302,7 +302,7 @@ func TestSupervisorSecretsControllerSync(t *testing.T) {
|
||||
storedSecret: func(secret **corev1.Secret) {
|
||||
(*secret).Data["key"] = []byte("too short") // force updating
|
||||
},
|
||||
apiClient: func(t *testing.T, client *kubernetesfake.Clientset) {
|
||||
apiClient: func(t *testing.T, client *kubefake.Clientset) {
|
||||
client.PrependReactor("update", "secrets", func(action kubetesting.Action) (bool, runtime.Object, error) {
|
||||
var err error
|
||||
once.Do(func() {
|
||||
@@ -324,7 +324,7 @@ func TestSupervisorSecretsControllerSync(t *testing.T) {
|
||||
storedSecret: func(secret **corev1.Secret) {
|
||||
(*secret).Data["key"] = []byte("too short") // force updating
|
||||
},
|
||||
apiClient: func(t *testing.T, client *kubernetesfake.Clientset) {
|
||||
apiClient: func(t *testing.T, client *kubefake.Clientset) {
|
||||
client.PrependReactor("get", "secrets", func(action kubetesting.Action) (bool, runtime.Object, error) {
|
||||
return true, otherGeneratedSecret, nil
|
||||
})
|
||||
@@ -361,7 +361,7 @@ func TestSupervisorSecretsControllerSync(t *testing.T) {
|
||||
storedSecret: func(secret **corev1.Secret) {
|
||||
(*secret).Data["key"] = []byte("too short") // force updating
|
||||
},
|
||||
apiClient: func(t *testing.T, client *kubernetesfake.Clientset) {
|
||||
apiClient: func(t *testing.T, client *kubefake.Clientset) {
|
||||
client.PrependReactor("get", "secrets", func(action kubetesting.Action) (bool, runtime.Object, error) {
|
||||
return true, nil, apierrors.NewNotFound(secretsGVR.GroupResource(), generatedSecretName)
|
||||
})
|
||||
@@ -380,7 +380,7 @@ func TestSupervisorSecretsControllerSync(t *testing.T) {
|
||||
storedSecret: func(secret **corev1.Secret) {
|
||||
(*secret).Data["key"] = []byte("too short") // force updating
|
||||
},
|
||||
apiClient: func(t *testing.T, client *kubernetesfake.Clientset) {
|
||||
apiClient: func(t *testing.T, client *kubefake.Clientset) {
|
||||
client.PrependReactor("get", "secrets", func(action kubetesting.Action) (bool, runtime.Object, error) {
|
||||
return true, nil, apierrors.NewNotFound(secretsGVR.GroupResource(), generatedSecretName)
|
||||
})
|
||||
@@ -420,11 +420,11 @@ func TestSupervisorSecretsControllerSync(t *testing.T) {
|
||||
}
|
||||
}
|
||||
|
||||
apiClient := kubernetesfake.NewClientset()
|
||||
apiClient := kubefake.NewClientset()
|
||||
if test.apiClient != nil {
|
||||
test.apiClient(t, apiClient)
|
||||
}
|
||||
informerClient := kubernetesfake.NewClientset()
|
||||
informerClient := kubefake.NewClientset()
|
||||
|
||||
storedSecret := generatedSecret.DeepCopy()
|
||||
if test.storedSecret != nil {
|
||||
|
||||
+8
-8
@@ -25,7 +25,7 @@ import (
|
||||
"k8s.io/apimachinery/pkg/util/cache"
|
||||
utilnet "k8s.io/apimachinery/pkg/util/net"
|
||||
k8sinformers "k8s.io/client-go/informers"
|
||||
kubernetesfake "k8s.io/client-go/kubernetes/fake"
|
||||
kubefake "k8s.io/client-go/kubernetes/fake"
|
||||
coretesting "k8s.io/client-go/testing"
|
||||
"k8s.io/utils/clock"
|
||||
clocktesting "k8s.io/utils/clock/testing"
|
||||
@@ -2441,7 +2441,7 @@ func TestController(t *testing.T) {
|
||||
fakeSupervisorClient := supervisorfake.NewSimpleClientset(tt.githubIdentityProviders...)
|
||||
supervisorInformers := supervisorinformers.NewSharedInformerFactory(fakeSupervisorClient, 0)
|
||||
|
||||
fakeKubeClient := kubernetesfake.NewClientset(tt.secretsAndConfigMaps...)
|
||||
fakeKubeClient := kubefake.NewClientset(tt.secretsAndConfigMaps...)
|
||||
kubeInformers := k8sinformers.NewSharedInformerFactoryWithOptions(fakeKubeClient, 0)
|
||||
|
||||
idpCache := dynamicupstreamprovider.NewDynamicUpstreamIDPProvider()
|
||||
@@ -2840,7 +2840,7 @@ func TestController_OnlyWantActions(t *testing.T) {
|
||||
tt.addSupervisorReactors(fakeSupervisorClient)
|
||||
}
|
||||
|
||||
kubeInformers := k8sinformers.NewSharedInformerFactoryWithOptions(kubernetesfake.NewClientset(tt.secrets...), 0)
|
||||
kubeInformers := k8sinformers.NewSharedInformerFactoryWithOptions(kubefake.NewClientset(tt.secrets...), 0)
|
||||
|
||||
logger, _ := plog.TestLogger(t)
|
||||
|
||||
@@ -2960,7 +2960,7 @@ func TestGitHubUpstreamWatcherControllerFilterSecret(t *testing.T) {
|
||||
t.Run(tt.name, func(t *testing.T) {
|
||||
t.Parallel()
|
||||
|
||||
kubeInformers := k8sinformers.NewSharedInformerFactoryWithOptions(kubernetesfake.NewClientset(), 0)
|
||||
kubeInformers := k8sinformers.NewSharedInformerFactoryWithOptions(kubefake.NewClientset(), 0)
|
||||
|
||||
logger, _ := plog.TestLogger(t)
|
||||
|
||||
@@ -3023,7 +3023,7 @@ func TestGitHubUpstreamWatcherControllerFilterConfigMaps(t *testing.T) {
|
||||
logger, _ := plog.TestLogger(t)
|
||||
|
||||
observableInformers := testutil.NewObservableWithInformerOption()
|
||||
configMapInformer := k8sinformers.NewSharedInformerFactoryWithOptions(kubernetesfake.NewClientset(), 0).Core().V1().ConfigMaps()
|
||||
configMapInformer := k8sinformers.NewSharedInformerFactoryWithOptions(kubefake.NewClientset(), 0).Core().V1().ConfigMaps()
|
||||
|
||||
_ = New(
|
||||
namespace,
|
||||
@@ -3032,7 +3032,7 @@ func TestGitHubUpstreamWatcherControllerFilterConfigMaps(t *testing.T) {
|
||||
supervisorfake.NewSimpleClientset(),
|
||||
//nolint:staticcheck // our codegen does not yet generate a NewClientset() function
|
||||
supervisorinformers.NewSharedInformerFactory(supervisorfake.NewSimpleClientset(), 0).IDP().V1alpha1().GitHubIdentityProviders(),
|
||||
k8sinformers.NewSharedInformerFactoryWithOptions(kubernetesfake.NewClientset(), 0).Core().V1().Secrets(),
|
||||
k8sinformers.NewSharedInformerFactoryWithOptions(kubefake.NewClientset(), 0).Core().V1().Secrets(),
|
||||
configMapInformer,
|
||||
logger,
|
||||
observableInformers.WithInformer,
|
||||
@@ -3090,8 +3090,8 @@ func TestGitHubUpstreamWatcherControllerFilterGitHubIDP(t *testing.T) {
|
||||
//nolint:staticcheck // our codegen does not yet generate a NewClientset() function
|
||||
supervisorfake.NewSimpleClientset(),
|
||||
gitHubIdentityProviderInformer,
|
||||
k8sinformers.NewSharedInformerFactoryWithOptions(kubernetesfake.NewClientset(), 0).Core().V1().Secrets(),
|
||||
k8sinformers.NewSharedInformerFactoryWithOptions(kubernetesfake.NewClientset(), 0).Core().V1().ConfigMaps(),
|
||||
k8sinformers.NewSharedInformerFactoryWithOptions(kubefake.NewClientset(), 0).Core().V1().Secrets(),
|
||||
k8sinformers.NewSharedInformerFactoryWithOptions(kubefake.NewClientset(), 0).Core().V1().ConfigMaps(),
|
||||
logger,
|
||||
observableInformers.WithInformer,
|
||||
clock.RealClock{},
|
||||
|
||||
@@ -15,7 +15,7 @@ import (
|
||||
corev1 "k8s.io/api/core/v1"
|
||||
metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
|
||||
k8sinformers "k8s.io/client-go/informers"
|
||||
kubernetesfake "k8s.io/client-go/kubernetes/fake"
|
||||
kubefake "k8s.io/client-go/kubernetes/fake"
|
||||
|
||||
supervisorconfigv1alpha1 "go.pinniped.dev/generated/latest/apis/supervisor/config/v1alpha1"
|
||||
supervisorfake "go.pinniped.dev/generated/latest/client/supervisor/clientset/versioned/fake"
|
||||
@@ -126,7 +126,7 @@ func TestJWKSObserverControllerSync(t *testing.T) {
|
||||
r *require.Assertions
|
||||
subject controllerlib.Controller
|
||||
pinnipedInformerClient *supervisorfake.Clientset
|
||||
kubeInformerClient *kubernetesfake.Clientset
|
||||
kubeInformerClient *kubefake.Clientset
|
||||
pinnipedInformers supervisorinformers.SharedInformerFactory
|
||||
kubeInformers k8sinformers.SharedInformerFactory
|
||||
cancelContext context.Context
|
||||
@@ -167,7 +167,7 @@ func TestJWKSObserverControllerSync(t *testing.T) {
|
||||
|
||||
cancelContext, cancelContextCancelFunc = context.WithCancel(context.Background())
|
||||
|
||||
kubeInformerClient = kubernetesfake.NewClientset()
|
||||
kubeInformerClient = kubefake.NewClientset()
|
||||
kubeInformers = k8sinformers.NewSharedInformerFactory(kubeInformerClient, 0)
|
||||
//nolint:staticcheck // our codegen does not yet generate a NewClientset() function
|
||||
pinnipedInformerClient = supervisorfake.NewSimpleClientset()
|
||||
|
||||
@@ -19,7 +19,7 @@ import (
|
||||
"k8s.io/apimachinery/pkg/runtime"
|
||||
"k8s.io/apimachinery/pkg/runtime/schema"
|
||||
k8sinformers "k8s.io/client-go/informers"
|
||||
kubernetesfake "k8s.io/client-go/kubernetes/fake"
|
||||
kubefake "k8s.io/client-go/kubernetes/fake"
|
||||
kubetesting "k8s.io/client-go/testing"
|
||||
|
||||
supervisorconfigv1alpha1 "go.pinniped.dev/generated/latest/apis/supervisor/config/v1alpha1"
|
||||
@@ -171,7 +171,7 @@ func TestJWKSWriterControllerFilterSecret(t *testing.T) {
|
||||
t.Parallel()
|
||||
|
||||
secretInformer := k8sinformers.NewSharedInformerFactory(
|
||||
kubernetesfake.NewClientset(),
|
||||
kubefake.NewClientset(),
|
||||
0,
|
||||
).Core().V1().Secrets()
|
||||
federationDomainInformer := supervisorinformers.NewSharedInformerFactory(
|
||||
@@ -225,7 +225,7 @@ func TestJWKSWriterControllerFilterFederationDomain(t *testing.T) {
|
||||
t.Parallel()
|
||||
|
||||
secretInformer := k8sinformers.NewSharedInformerFactory(
|
||||
kubernetesfake.NewClientset(),
|
||||
kubefake.NewClientset(),
|
||||
0,
|
||||
).Core().V1().Secrets()
|
||||
federationDomainInformer := supervisorinformers.NewSharedInformerFactory(
|
||||
@@ -332,7 +332,7 @@ func TestJWKSWriterControllerSync(t *testing.T) {
|
||||
name string
|
||||
key controllerlib.Key
|
||||
secrets []*corev1.Secret
|
||||
configKubeClient func(*kubernetesfake.Clientset)
|
||||
configKubeClient func(*kubefake.Clientset)
|
||||
configPinnipedClient func(*supervisorfake.Clientset)
|
||||
federationDomains []*supervisorconfigv1alpha1.FederationDomain
|
||||
generateKeyErr error
|
||||
@@ -600,7 +600,7 @@ func TestJWKSWriterControllerSync(t *testing.T) {
|
||||
federationDomains: []*supervisorconfigv1alpha1.FederationDomain{
|
||||
goodFederationDomain,
|
||||
},
|
||||
configKubeClient: func(client *kubernetesfake.Clientset) {
|
||||
configKubeClient: func(client *kubefake.Clientset) {
|
||||
client.PrependReactor("get", "secrets", func(_ kubetesting.Action) (bool, runtime.Object, error) {
|
||||
return true, nil, errors.New("some get error")
|
||||
})
|
||||
@@ -613,7 +613,7 @@ func TestJWKSWriterControllerSync(t *testing.T) {
|
||||
federationDomains: []*supervisorconfigv1alpha1.FederationDomain{
|
||||
goodFederationDomain,
|
||||
},
|
||||
configKubeClient: func(client *kubernetesfake.Clientset) {
|
||||
configKubeClient: func(client *kubefake.Clientset) {
|
||||
client.PrependReactor("create", "secrets", func(_ kubetesting.Action) (bool, runtime.Object, error) {
|
||||
return true, nil, errors.New("some create error")
|
||||
})
|
||||
@@ -629,7 +629,7 @@ func TestJWKSWriterControllerSync(t *testing.T) {
|
||||
secrets: []*corev1.Secret{
|
||||
newSecret("", ""),
|
||||
},
|
||||
configKubeClient: func(client *kubernetesfake.Clientset) {
|
||||
configKubeClient: func(client *kubefake.Clientset) {
|
||||
client.PrependReactor("update", "secrets", func(_ kubetesting.Action) (bool, runtime.Object, error) {
|
||||
return true, nil, errors.New("some update error")
|
||||
})
|
||||
@@ -675,8 +675,8 @@ func TestJWKSWriterControllerSync(t *testing.T) {
|
||||
ctx, cancel := context.WithCancel(context.Background())
|
||||
defer cancel()
|
||||
|
||||
kubeAPIClient := kubernetesfake.NewClientset()
|
||||
kubeInformerClient := kubernetesfake.NewClientset()
|
||||
kubeAPIClient := kubefake.NewClientset()
|
||||
kubeInformerClient := kubefake.NewClientset()
|
||||
for _, secret := range test.secrets {
|
||||
require.NoError(t, kubeAPIClient.Tracker().Add(secret))
|
||||
require.NoError(t, kubeInformerClient.Tracker().Add(secret))
|
||||
|
||||
+5
-5
@@ -19,7 +19,7 @@ import (
|
||||
metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
|
||||
"k8s.io/apimachinery/pkg/runtime"
|
||||
"k8s.io/client-go/informers"
|
||||
"k8s.io/client-go/kubernetes/fake"
|
||||
kubefake "k8s.io/client-go/kubernetes/fake"
|
||||
|
||||
idpv1alpha1 "go.pinniped.dev/generated/latest/apis/supervisor/idp/v1alpha1"
|
||||
supervisorfake "go.pinniped.dev/generated/latest/client/supervisor/clientset/versioned/fake"
|
||||
@@ -98,7 +98,7 @@ func TestLDAPUpstreamWatcherControllerFilterSecrets(t *testing.T) {
|
||||
fakePinnipedClient := supervisorfake.NewSimpleClientset()
|
||||
pinnipedInformers := supervisorinformers.NewSharedInformerFactory(fakePinnipedClient, 0)
|
||||
ldapIDPInformer := pinnipedInformers.IDP().V1alpha1().LDAPIdentityProviders()
|
||||
fakeKubeClient := fake.NewClientset()
|
||||
fakeKubeClient := kubefake.NewClientset()
|
||||
kubeInformers := informers.NewSharedInformerFactory(fakeKubeClient, 0)
|
||||
secretInformer := kubeInformers.Core().V1().Secrets()
|
||||
configMapInformer := kubeInformers.Core().V1().ConfigMaps()
|
||||
@@ -144,7 +144,7 @@ func TestLDAPUpstreamWatcherControllerFilterConfigMaps(t *testing.T) {
|
||||
fakePinnipedClient := supervisorfake.NewSimpleClientset()
|
||||
pinnipedInformers := supervisorinformers.NewSharedInformerFactory(fakePinnipedClient, 0)
|
||||
ldapIDPInformer := pinnipedInformers.IDP().V1alpha1().LDAPIdentityProviders()
|
||||
fakeKubeClient := fake.NewClientset()
|
||||
fakeKubeClient := kubefake.NewClientset()
|
||||
kubeInformers := informers.NewSharedInformerFactory(fakeKubeClient, 0)
|
||||
secretInformer := kubeInformers.Core().V1().Secrets()
|
||||
configMapInformer := kubeInformers.Core().V1().ConfigMaps()
|
||||
@@ -190,7 +190,7 @@ func TestLDAPUpstreamWatcherControllerFilterLDAPIdentityProviders(t *testing.T)
|
||||
fakePinnipedClient := supervisorfake.NewSimpleClientset()
|
||||
pinnipedInformers := supervisorinformers.NewSharedInformerFactory(fakePinnipedClient, 0)
|
||||
ldapIDPInformer := pinnipedInformers.IDP().V1alpha1().LDAPIdentityProviders()
|
||||
fakeKubeClient := fake.NewClientset()
|
||||
fakeKubeClient := kubefake.NewClientset()
|
||||
kubeInformers := informers.NewSharedInformerFactory(fakeKubeClient, 0)
|
||||
secretInformer := kubeInformers.Core().V1().Secrets()
|
||||
configMapInformer := kubeInformers.Core().V1().ConfigMaps()
|
||||
@@ -1411,7 +1411,7 @@ func TestLDAPUpstreamWatcherControllerSync(t *testing.T) {
|
||||
//nolint:staticcheck // our codegen does not yet generate a NewClientset() function
|
||||
fakePinnipedClient := supervisorfake.NewSimpleClientset(tt.inputUpstreams...)
|
||||
pinnipedInformers := supervisorinformers.NewSharedInformerFactory(fakePinnipedClient, 0)
|
||||
fakeKubeClient := fake.NewClientset(tt.inputSecrets...)
|
||||
fakeKubeClient := kubefake.NewClientset(tt.inputSecrets...)
|
||||
kubeInformers := informers.NewSharedInformerFactory(fakeKubeClient, 0)
|
||||
cache := dynamicupstreamprovider.NewDynamicUpstreamIDPProvider()
|
||||
cache.SetLDAPIdentityProviders([]upstreamprovider.UpstreamLDAPIdentityProviderI{
|
||||
|
||||
@@ -14,7 +14,7 @@ import (
|
||||
metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
|
||||
"k8s.io/apimachinery/pkg/runtime"
|
||||
k8sinformers "k8s.io/client-go/informers"
|
||||
kubernetesfake "k8s.io/client-go/kubernetes/fake"
|
||||
kubefake "k8s.io/client-go/kubernetes/fake"
|
||||
|
||||
supervisorconfigv1alpha1 "go.pinniped.dev/generated/latest/apis/supervisor/config/v1alpha1"
|
||||
supervisorfake "go.pinniped.dev/generated/latest/client/supervisor/clientset/versioned/fake"
|
||||
@@ -63,7 +63,7 @@ func TestOIDCClientWatcherControllerFilterSecret(t *testing.T) {
|
||||
t.Parallel()
|
||||
|
||||
secretInformer := k8sinformers.NewSharedInformerFactory(
|
||||
kubernetesfake.NewClientset(),
|
||||
kubefake.NewClientset(),
|
||||
0,
|
||||
).Core().V1().Secrets()
|
||||
oidcClientsInformer := supervisorinformers.NewSharedInformerFactory(
|
||||
@@ -133,7 +133,7 @@ func TestOIDCClientWatcherControllerFilterOIDCClient(t *testing.T) {
|
||||
t.Parallel()
|
||||
|
||||
secretInformer := k8sinformers.NewSharedInformerFactory(
|
||||
kubernetesfake.NewClientset(),
|
||||
kubefake.NewClientset(),
|
||||
0,
|
||||
).Core().V1().Secrets()
|
||||
oidcClientsInformer := supervisorinformers.NewSharedInformerFactory(
|
||||
@@ -963,7 +963,7 @@ func TestOIDCClientWatcherControllerSync(t *testing.T) {
|
||||
//nolint:staticcheck // our codegen does not yet generate a NewClientset() function
|
||||
fakePinnipedClientForInformers := supervisorfake.NewSimpleClientset(tt.inputObjects...)
|
||||
pinnipedInformers := supervisorinformers.NewSharedInformerFactory(fakePinnipedClientForInformers, 0)
|
||||
fakeKubeClient := kubernetesfake.NewClientset(tt.inputSecrets...)
|
||||
fakeKubeClient := kubefake.NewClientset(tt.inputSecrets...)
|
||||
kubeInformers := k8sinformers.NewSharedInformerFactoryWithOptions(fakeKubeClient, 0)
|
||||
|
||||
controller := NewOIDCClientWatcherController(
|
||||
|
||||
+4
-4
@@ -25,7 +25,7 @@ import (
|
||||
"k8s.io/apimachinery/pkg/util/net"
|
||||
"k8s.io/apimachinery/pkg/util/sets"
|
||||
"k8s.io/client-go/informers"
|
||||
"k8s.io/client-go/kubernetes/fake"
|
||||
kubefake "k8s.io/client-go/kubernetes/fake"
|
||||
|
||||
idpv1alpha1 "go.pinniped.dev/generated/latest/apis/supervisor/idp/v1alpha1"
|
||||
supervisorfake "go.pinniped.dev/generated/latest/client/supervisor/clientset/versioned/fake"
|
||||
@@ -104,7 +104,7 @@ func TestOIDCUpstreamWatcherControllerFilterSecret(t *testing.T) {
|
||||
//nolint:staticcheck // our codegen does not yet generate a NewClientset() function
|
||||
fakePinnipedClient := supervisorfake.NewSimpleClientset()
|
||||
pinnipedInformers := supervisorinformers.NewSharedInformerFactory(fakePinnipedClient, 0)
|
||||
fakeKubeClient := fake.NewClientset()
|
||||
fakeKubeClient := kubefake.NewClientset()
|
||||
kubeInformers := informers.NewSharedInformerFactory(fakeKubeClient, 0)
|
||||
cache := dynamicupstreamprovider.NewDynamicUpstreamIDPProvider()
|
||||
cache.SetOIDCIdentityProviders([]upstreamprovider.UpstreamOIDCIdentityProviderI{
|
||||
@@ -165,7 +165,7 @@ func TestOIDCUpstreamWatcherControllerFilterConfigMaps(t *testing.T) {
|
||||
//nolint:staticcheck // our codegen does not yet generate a NewClientset() function
|
||||
fakePinnipedClient := supervisorfake.NewSimpleClientset()
|
||||
pinnipedInformers := supervisorinformers.NewSharedInformerFactory(fakePinnipedClient, 0)
|
||||
fakeKubeClient := fake.NewClientset()
|
||||
fakeKubeClient := kubefake.NewClientset()
|
||||
kubeInformers := informers.NewSharedInformerFactory(fakeKubeClient, 0)
|
||||
cache := dynamicupstreamprovider.NewDynamicUpstreamIDPProvider()
|
||||
cache.SetOIDCIdentityProviders([]upstreamprovider.UpstreamOIDCIdentityProviderI{
|
||||
@@ -1765,7 +1765,7 @@ func TestOIDCUpstreamWatcherControllerSync(t *testing.T) {
|
||||
//nolint:staticcheck // our codegen does not yet generate a NewClientset() function
|
||||
fakePinnipedClient := supervisorfake.NewSimpleClientset(tt.inputUpstreams...)
|
||||
pinnipedInformers := supervisorinformers.NewSharedInformerFactory(fakePinnipedClient, 0)
|
||||
fakeKubeClient := fake.NewClientset(tt.inputResources...)
|
||||
fakeKubeClient := kubefake.NewClientset(tt.inputResources...)
|
||||
kubeInformers := informers.NewSharedInformerFactory(fakeKubeClient, 0)
|
||||
cache := dynamicupstreamprovider.NewDynamicUpstreamIDPProvider()
|
||||
cache.SetOIDCIdentityProviders([]upstreamprovider.UpstreamOIDCIdentityProviderI{
|
||||
|
||||
@@ -16,7 +16,7 @@ import (
|
||||
corev1 "k8s.io/api/core/v1"
|
||||
metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
|
||||
k8sinformers "k8s.io/client-go/informers"
|
||||
kubernetesfake "k8s.io/client-go/kubernetes/fake"
|
||||
kubefake "k8s.io/client-go/kubernetes/fake"
|
||||
|
||||
supervisorconfigv1alpha1 "go.pinniped.dev/generated/latest/apis/supervisor/config/v1alpha1"
|
||||
supervisorfake "go.pinniped.dev/generated/latest/client/supervisor/clientset/versioned/fake"
|
||||
@@ -132,7 +132,7 @@ func TestTLSCertObserverControllerSync(t *testing.T) {
|
||||
r *require.Assertions
|
||||
subject controllerlib.Controller
|
||||
pinnipedInformerClient *supervisorfake.Clientset
|
||||
kubeInformerClient *kubernetesfake.Clientset
|
||||
kubeInformerClient *kubefake.Clientset
|
||||
pinnipedInformers supervisorinformers.SharedInformerFactory
|
||||
kubeInformers k8sinformers.SharedInformerFactory
|
||||
cancelContext context.Context
|
||||
@@ -180,7 +180,7 @@ func TestTLSCertObserverControllerSync(t *testing.T) {
|
||||
|
||||
cancelContext, cancelContextCancelFunc = context.WithCancel(context.Background())
|
||||
|
||||
kubeInformerClient = kubernetesfake.NewClientset()
|
||||
kubeInformerClient = kubefake.NewClientset()
|
||||
kubeInformers = k8sinformers.NewSharedInformerFactory(kubeInformerClient, 0)
|
||||
//nolint:staticcheck // our codegen does not yet generate a NewClientset() function
|
||||
pinnipedInformerClient = supervisorfake.NewSimpleClientset()
|
||||
|
||||
@@ -20,7 +20,7 @@ import (
|
||||
"k8s.io/apimachinery/pkg/runtime"
|
||||
"k8s.io/apimachinery/pkg/runtime/schema"
|
||||
k8sinformers "k8s.io/client-go/informers"
|
||||
kubernetesfake "k8s.io/client-go/kubernetes/fake"
|
||||
kubefake "k8s.io/client-go/kubernetes/fake"
|
||||
kubetesting "k8s.io/client-go/testing"
|
||||
"k8s.io/utils/clock"
|
||||
clocktesting "k8s.io/utils/clock/testing"
|
||||
@@ -131,8 +131,8 @@ func TestGarbageCollectorControllerSync(t *testing.T) {
|
||||
var (
|
||||
r *require.Assertions
|
||||
subject controllerlib.Controller
|
||||
kubeInformerClient *kubernetesfake.Clientset
|
||||
kubeClient *kubernetesfake.Clientset
|
||||
kubeInformerClient *kubefake.Clientset
|
||||
kubeClient *kubefake.Clientset
|
||||
kubeInformers k8sinformers.SharedInformerFactory
|
||||
cancelContext context.Context
|
||||
cancelContextCancelFunc context.CancelFunc
|
||||
@@ -179,8 +179,8 @@ func TestGarbageCollectorControllerSync(t *testing.T) {
|
||||
|
||||
cancelContext, cancelContextCancelFunc = context.WithCancel(context.Background())
|
||||
|
||||
kubeInformerClient = kubernetesfake.NewClientset()
|
||||
kubeClient = kubernetesfake.NewClientset()
|
||||
kubeInformerClient = kubefake.NewClientset()
|
||||
kubeClient = kubefake.NewClientset()
|
||||
kubeInformers = k8sinformers.NewSharedInformerFactory(kubeInformerClient, 0)
|
||||
frozenNow = time.Now().UTC()
|
||||
fakeClock = clocktesting.NewFakeClock(frozenNow)
|
||||
|
||||
@@ -15,7 +15,7 @@ import (
|
||||
"k8s.io/apimachinery/pkg/runtime"
|
||||
"k8s.io/client-go/informers"
|
||||
corev1informers "k8s.io/client-go/informers/core/v1"
|
||||
"k8s.io/client-go/kubernetes/fake"
|
||||
kubefake "k8s.io/client-go/kubernetes/fake"
|
||||
|
||||
authenticationv1alpha1 "go.pinniped.dev/generated/latest/apis/concierge/authentication/v1alpha1"
|
||||
idpv1alpha1 "go.pinniped.dev/generated/latest/apis/supervisor/idp/v1alpha1"
|
||||
@@ -474,7 +474,7 @@ func TestValidateTLSConfig(t *testing.T) {
|
||||
var secretsInformer corev1informers.SecretInformer
|
||||
var configMapInformer corev1informers.ConfigMapInformer
|
||||
|
||||
fakeClient := fake.NewClientset(tt.k8sObjects...)
|
||||
fakeClient := kubefake.NewClientset(tt.k8sObjects...)
|
||||
sharedInformers := informers.NewSharedInformerFactory(fakeClient, 0)
|
||||
configMapInformer = sharedInformers.Core().V1().ConfigMaps()
|
||||
secretsInformer = sharedInformers.Core().V1().Secrets()
|
||||
|
||||
Reference in New Issue
Block a user