- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 23 for fakeclient (0.15 sec)
-
pkg/controller/statefulset/stateful_pod_control_test.go
set := newStatefulSet(3) pod := newStatefulSetPod(set, 0) fakeClient := &fake.Clientset{} claimIndexer := cache.NewIndexer(cache.MetaNamespaceKeyFunc, cache.Indexers{cache.NamespaceIndex: cache.MetaNamespaceIndexFunc}) claimLister := corelisters.NewPersistentVolumeClaimLister(claimIndexer) control := NewStatefulPodControl(fakeClient, nil, claimLister, recorder)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 05 19:06:41 UTC 2024 - 35.5K bytes - Viewed (0) -
pkg/kubelet/util/manager/cache_based_manager_test.go
store.Get("ns1", "s20") store.Get("ns1", "s3") actions = fakeClient.Actions() assert.Equal(t, 3, len(actions), "unexpected actions: %#v", actions) fakeClient.ClearActions() } func TestRegisterIdempotence(t *testing.T) { fakeClient := &fake.Clientset{} fakeClock := testingclock.NewFakeClock(time.Now()) store := newSecretStore(fakeClient, fakeClock, noObjectTTL, time.Minute)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 19.6K bytes - Viewed (0) -
pkg/registry/core/service/ipallocator/controller/repair_test.go
r.updated = alloc return r.updateErr } func TestRepair(t *testing.T) { fakeClient := fake.NewSimpleClientset() ipregistry := &mockRangeRegistry{ item: &api.RangeAllocation{Range: "192.168.1.0/24"}, } _, cidr, _ := netutils.ParseCIDRSloppy(ipregistry.item.Range) r := NewRepair(0, fakeClient.CoreV1(), fakeClient.EventsV1(), cidr, ipregistry, nil, nil) if err := r.runOnce(); err != nil { t.Fatal(err) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Sep 30 15:46:06 UTC 2023 - 21.1K bytes - Viewed (0) -
cni/pkg/repair/repair_test.go
false, }, } for _, tt := range cases { t.Run(tt.name, func(t *testing.T) { c := &Controller{cfg: tt.config} assert.Equal(t, c.matchesFilter(tt.pod), tt.want) }) } } func fakeClient(pods ...*corev1.Pod) kube.Client { var csPods []runtime.Object for _, pod := range pods { csPods = append(csPods, pod.DeepCopy()) } return kube.NewFakeClient(csPods...) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Oct 24 03:31:28 UTC 2023 - 10.6K bytes - Viewed (0) -
pkg/registry/core/service/portallocator/controller/repair_test.go
r.updated = alloc return r.updateErr } func TestRepair(t *testing.T) { clearMetrics() fakeClient := fake.NewSimpleClientset() registry := &mockRangeRegistry{ item: &api.RangeAllocation{Range: "100-200"}, } pr, _ := net.ParsePortRange(registry.item.Range) r := NewRepair(0, fakeClient.CoreV1(), fakeClient.EventsV1(), *pr, registry) if err := r.runOnce(); err != nil { t.Fatal(err) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Sep 30 15:46:06 UTC 2023 - 10.6K bytes - Viewed (0) -
pkg/controller/volume/attachdetach/testing/testvolumespec.go
func CreateTestClient() *fake.Clientset { var extraPods *v1.PodList var volumeAttachments *storagev1.VolumeAttachmentList var pvs *v1.PersistentVolumeList var nodes *v1.NodeList fakeClient := &fake.Clientset{} extraPods = &v1.PodList{} fakeClient.AddReactor("list", "pods", func(action core.Action) (handled bool, ret runtime.Object, err error) { obj := &v1.PodList{} podNamePrefix := "mypod" namespace := "mynamespace"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Nov 17 08:48:30 UTC 2023 - 16.5K bytes - Viewed (0) -
istioctl/pkg/tag/generate_test.go
defaultWh := defaultRevisionCanonicalWebhook.DeepCopy() fakeClient := kube.NewFakeClient(defaultWh) opts := &GenerateOptions{ Generate: generate, Tag: "default", Revision: "default", } _, err := Generate(context.TODO(), fakeClient, opts, "istio-system") assert.NoError(t, err) wh, err := fakeClient.Kube().AdmissionregistrationV1().MutatingWebhookConfigurations().
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Jan 16 17:43:49 UTC 2024 - 12.1K bytes - Viewed (0) -
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)