- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 47 for makeClient (0.52 sec)
-
pkg/volume/csi/csi_block_test.go
} } func TestBlockMapperMapPodDeviceNotSupportAttach(t *testing.T) { fakeClient := fakeclient.NewSimpleClientset() attachRequired := false fakeDriver := &storagev1.CSIDriver{ ObjectMeta: metav1.ObjectMeta{ Name: testDriver, }, Spec: storagev1.CSIDriverSpec{ AttachRequired: &attachRequired, }, } _, err := fakeClient.StorageV1().CSIDrivers().Create(context.TODO(), fakeDriver, metav1.CreateOptions{})
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Sep 11 06:07:40 UTC 2023 - 26.5K bytes - Viewed (0) -
pkg/volume/csi/csi_plugin_test.go
for _, test := range tests { t.Run(test.name, func(t *testing.T) { driver := getTestCSIDriver(testDriver, nil, nil, supported) fakeClient := fakeclient.NewSimpleClientset(driver) plug, tmpDir := newTestPlugin(t, fakeClient) defer os.RemoveAll(tmpDir) registerFakePlugin(testDriver, "endpoint", []string{"1.2.0"}, t) mounter, err := plug.NewMounter( test.spec,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 41.8K bytes - Viewed (0) -
pkg/registry/core/service/ipallocator/controller/repairip_test.go
serviceStore cache.Store ipAddressStore cache.Store serviceCIDRStore cache.Store } func newFakeRepair() (*fake.Clientset, *fakeRepair) { fakeClient := fake.NewSimpleClientset() informerFactory := informers.NewSharedInformerFactory(fakeClient, 0*time.Second) serviceInformer := informerFactory.Core().V1().Services() serviceIndexer := serviceInformer.Informer().GetIndexer()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Oct 31 21:05:06 UTC 2023 - 20.3K bytes - Viewed (0) -
cmd/kubeadm/app/cmd/upgrade/common.go
// Print GET and LIST requests dryRunOpts.PrintGETAndLIST = true fakeclient := apiclient.NewDryRunClientWithOpts(dryRunOpts) // As we know the return of Discovery() of the fake clientset is of type *fakediscovery.FakeDiscovery // we can convert it to that struct. fakeclientDiscovery, ok := fakeclient.Discovery().(*fakediscovery.FakeDiscovery) if !ok {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 16 08:34:39 UTC 2024 - 10.1K bytes - Viewed (0) -
pkg/controller/volume/attachdetach/metrics/metrics_test.go
"k8s.io/kubernetes/pkg/volume/util/types" ) func TestVolumesInUseMetricCollection(t *testing.T) { fakeVolumePluginMgr, _ := volumetesting.GetTestVolumePluginMgr(t) fakeClient := &fake.Clientset{} fakeInformerFactory := informers.NewSharedInformerFactory(fakeClient, controller.NoResyncPeriodFunc()) fakePodInformer := fakeInformerFactory.Core().V1().Pods() pod := &v1.Pod{ ObjectMeta: metav1.ObjectMeta{ Name: "metric-test-pod",
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 01 10:42:15 UTC 2024 - 6.1K bytes - Viewed (0) -
pilot/pkg/config/kube/ingress/controller_test.go
meshHolder := mesh.NewTestWatcher(&meshconfig.MeshConfig{ IngressControllerMode: meshconfig.MeshConfig_DEFAULT, }) fakeClient := kube.NewFakeClient() return NewController(fakeClient, meshHolder, kubecontroller.Options{}), fakeClient } func TestIngressController(t *testing.T) { ingress1 := net.Ingress{ ObjectMeta: metav1.ObjectMeta{ Namespace: "mock", // goes into backend full name
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jul 20 18:34:32 UTC 2023 - 10.1K bytes - Viewed (0) -
pkg/controller/volume/ephemeral/controller_test.go
return pvcs[i].Namespace < pvcs[j].Namespace || pvcs[i].Name < pvcs[j].Name }) return pvcs } func createTestClient(objects ...runtime.Object) *fake.Clientset { fakeClient := fake.NewSimpleClientset(objects...) return fakeClient } // Metrics helpers type expectedMetrics struct { numCreated int numFailures int } func expectMetrics(t *testing.T, em expectedMetrics) { t.Helper()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Feb 26 06:51:56 UTC 2024 - 8.5K bytes - Viewed (0) -
pkg/volume/util/operationexecutor/operation_generator_test.go
"k8s.io/kubernetes/pkg/features" "github.com/stretchr/testify/assert" v1 "k8s.io/api/core/v1" metav1 "k8s.io/apimachinery/pkg/apis/meta/v1" "k8s.io/apimachinery/pkg/types" "k8s.io/apimachinery/pkg/util/uuid" fakeclient "k8s.io/client-go/kubernetes/fake" "k8s.io/component-base/metrics/testutil" "k8s.io/kubernetes/pkg/volume" csitesting "k8s.io/kubernetes/pkg/volume/csi/testing" volumetesting "k8s.io/kubernetes/pkg/volume/testing"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 16.2K bytes - Viewed (0) -
security/pkg/pki/ca/selfsignedcarootcertrotator_test.go
// new root cert if it fails to update new root cert into configmap. func TestRollbackAtRootCertRotatorForSigningCitadel(t *testing.T) { fakeClient := fake.NewSimpleClientset() rotator := getRootCertRotator(getDefaultSelfSignedIstioCAOptions(fakeClient)) // Make a copy of CA secret, a copy of root cert form key cert bundle, and // a copy of root cert from config map for verification. certItem0 := loadCert(rotator)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Oct 11 23:33:41 UTC 2023 - 14.1K bytes - Viewed (0) -
cmd/kubeadm/app/phases/copycerts/copycerts_test.go
"encoding/hex" "os" "path/filepath" "regexp" goruntime "runtime" "testing" "github.com/lithammer/dedent" v1 "k8s.io/api/core/v1" metav1 "k8s.io/apimachinery/pkg/apis/meta/v1" fakeclient "k8s.io/client-go/kubernetes/fake" "k8s.io/client-go/util/keyutil" kubeadmapi "k8s.io/kubernetes/cmd/kubeadm/app/apis/kubeadm" kubeadmconstants "k8s.io/kubernetes/cmd/kubeadm/app/constants"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Jan 01 00:15:30 UTC 2023 - 9.1K bytes - Viewed (0)