- Sort Score
- Result 10 results
- Languages All
Results 1 - 8 of 8 for NewFakeRecorder (0.35 sec)
-
pkg/controller/statefulset/stateful_pod_control_test.go
_ "k8s.io/kubernetes/pkg/apis/core/install" "k8s.io/kubernetes/pkg/features" "k8s.io/utils/ptr" ) func TestStatefulPodControlCreatesPods(t *testing.T) { recorder := record.NewFakeRecorder(10) set := newStatefulSet(3) pod := newStatefulSetPod(set, 0) fakeClient := &fake.Clientset{}
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/controller/tainteviction/taint_eviction_test.go
fakeClientset := fake.NewSimpleClientset(&corev1.PodList{Items: []corev1.Pod{*item.pod}}) controller, podIndexer, _ := setupNewController(ctx, fakeClientset) controller.recorder = testutil.NewFakeRecorder() go controller.Run(ctx) controller.taintedNodes = item.taintedNodes podIndexer.Add(item.pod) controller.PodUpdated(nil, item.pod)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 25 14:24:16 UTC 2024 - 31.3K bytes - Viewed (0) -
pkg/kubelet/network/dns/dns_test.go
strings.Repeat("A", 127), strings.Repeat("A", 127), strings.Repeat("A", 127), strings.Repeat("A", 127), strings.Repeat("A", 127), strings.Repeat("A", 127), } recorder := record.NewFakeRecorder(20) nodeRef := &v1.ObjectReference{ Kind: "Node", Name: string("testNode"), UID: types.UID("testNode"), Namespace: "", } testClusterDNSDomain := "TEST"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 25.6K bytes - Viewed (0) -
pkg/controller/nodeipam/ipam/range_allocator_test.go
t.Logf("%v: found non-default implementation of CIDRAllocator, skipping white-box test...", tc.description) return } rangeAllocator.nodesSynced = test.AlwaysReady rangeAllocator.recorder = testutil.NewFakeRecorder() go allocator.Run(tCtx) // this is a bit of white box testing // pre allocate the cidrs as per the test for idx, allocatedList := range tc.allocatedCIDRs { for _, allocated := range allocatedList {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 10:06:15 UTC 2024 - 25.2K bytes - Viewed (0) -
pkg/controller/testutil/test_utils.go
Reason: reason, Message: message, FirstTimestamp: t, LastTimestamp: t, Count: 1, Type: eventtype, } } // NewFakeRecorder returns a pointer to a newly constructed FakeRecorder. func NewFakeRecorder() *FakeRecorder { return &FakeRecorder{ source: v1.EventSource{Component: "nodeControllerTest"}, Events: []*v1.Event{}, clock: testingclock.NewFakeClock(time.Now()),
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 28 08:48:22 UTC 2024 - 15.6K bytes - Viewed (0) -
pkg/registry/core/service/ipallocator/controller/repairip_test.go
} // override for testing r.servicesSynced = func() bool { return true } r.ipAddressSynced = func() bool { return true } r.serviceCIDRSynced = func() bool { return true } recorder := events.NewFakeRecorder(100) r.recorder = recorder for _, svc := range test.svcs { err := r.serviceStore.Add(svc) if err != nil { t.Errorf("Unexpected error trying to add Service %v object: %v", svc, err) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Oct 31 21:05:06 UTC 2023 - 20.3K bytes - Viewed (0) -
pkg/controller/cronjob/utils_test.go
sched, err := cron.ParseStandard(schedule) if err != nil { t.Errorf("Error parsing schedule: %#v", err) return nil } return sched } recorder := record.NewFakeRecorder(50) // T1 is a scheduled start time of that schedule T1 := *topOfTheHour() // T2 is a scheduled start time of that schedule after T1 T2 := *deltaTimeAfterTopOfTheHour(1 * time.Hour) cj := batchv1.CronJob{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 09 03:34:25 UTC 2024 - 22.8K bytes - Viewed (0) -
pkg/controller/volume/persistentvolume/framework_test.go
} ctrl, err := NewController(ctx, params) if err != nil { return nil, fmt.Errorf("failed to construct persistentvolume controller: %v", err) } ctrl.eventRecorder = record.NewFakeRecorder(1000) ctrl.volumeListerSynced = alwaysReady ctrl.claimListerSynced = alwaysReady ctrl.classListerSynced = alwaysReady // Speed up the test ctrl.createProvisionedPVInterval = 5 * time.Millisecond
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Nov 01 09:54:00 UTC 2023 - 38.3K bytes - Viewed (0)