- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 23 for NewFakeClock (0.2 sec)
-
staging/src/k8s.io/apiserver/pkg/endpoints/filterlatency/filterlatency_test.go
filterRecord = requestFilterRecordFrom(req.Context()) }) requestFilterStarted := time.Now() wrapped := trackStarted(handler, noopoteltrace.NewTracerProvider(), filterName, testingclock.NewFakeClock(requestFilterStarted)) testRequest, err := http.NewRequest(http.MethodGet, "/api/v1/namespaces", nil) if err != nil { t.Fatalf("failed to create new http request - %v", err) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 07 17:57:37 UTC 2024 - 7.1K bytes - Viewed (0) -
pkg/kubelet/util/manager/cache_based_manager_test.go
t.Errorf("Unexpected secret: %v", secret) } } func TestSecretStoreGetAlwaysRefresh(t *testing.T) { fakeClient := &fake.Clientset{} fakeClock := testingclock.NewFakeClock(time.Now()) store := newSecretStore(fakeClient, fakeClock, noObjectTTL, 0) for i := 0; i < 10; i++ { store.AddReference(fmt.Sprintf("ns-%d", i), fmt.Sprintf("name-%d", i), types.UID(fmt.Sprintf("pod-%d", i))) }
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/kubelet/util/queue/work_queue_test.go
"k8s.io/apimachinery/pkg/util/sets" "k8s.io/utils/clock" testingclock "k8s.io/utils/clock/testing" ) func newTestBasicWorkQueue() (*basicWorkQueue, *testingclock.FakeClock) { fakeClock := testingclock.NewFakeClock(time.Now()) wq := &basicWorkQueue{ clock: fakeClock, queue: make(map[types.UID]time.Time), } return wq, fakeClock } func compareResults(t *testing.T, expected, actual []types.UID) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 2.4K bytes - Viewed (0) -
pkg/kubelet/logs/container_log_manager_test.go
c := &containerLogManager{ runtimeService: f, policy: LogRotatePolicy{ MaxSize: testMaxSize, MaxFiles: testMaxFiles, }, osInterface: container.RealOS{}, clock: testingclock.NewFakeClock(now), mutex: sync.Mutex{}, queue: workqueue.NewTypedRateLimitingQueueWithConfig( workqueue.DefaultTypedControllerRateLimiter[string](),
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 12.7K bytes - Viewed (0) -
pkg/kubelet/eviction/eviction_manager_test.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 15 23:14:12 UTC 2024 - 119.9K bytes - Viewed (0) -
pkg/scheduler/internal/queue/scheduling_queue_test.go
queue = NewTestQueue(ctx, newDefaultQueueSort(), WithClock(testingclock.NewFakeClock(timestamp)), WithPodMaxInUnschedulablePodsDuration(test.podMaxInUnschedulablePodsDuration)) } else { queue = NewTestQueue(ctx, newDefaultQueueSort(), WithClock(testingclock.NewFakeClock(timestamp))) } var podInfoList []*framework.QueuedPodInfo
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 13:26:09 UTC 2024 - 146.9K bytes - Viewed (0) -
pkg/controller/job/backoff_utils_test.go
maxBackoff: 700 * time.Second, wantDuration: 700 * time.Second, }, } for name, tc := range testCases { t.Run(name, func(t *testing.T) { fakeClock := clocktesting.NewFakeClock(tc.currentTime.Truncate(time.Second)) d := tc.backoffRecord.getRemainingTime(fakeClock, tc.defaultBackoff, tc.maxBackoff) if d.Seconds() != tc.wantDuration.Seconds() {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jun 06 07:46:41 UTC 2024 - 16.7K bytes - Viewed (0) -
pkg/quota/v1/evaluator/core/pods_test.go
err != nil && test.err != err.Error(): t.Errorf("%s want: %v,got: %v", testName, test.err, err) } } } func TestPodEvaluatorUsage(t *testing.T) { fakeClock := testingclock.NewFakeClock(time.Now()) evaluator := NewPodEvaluator(nil, fakeClock) // fields use to simulate a pod undergoing termination // note: we set the deletion time in the past now := fakeClock.Now()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 41.6K bytes - Viewed (0) -
pkg/controller/job/job_controller_test.go
var fakeClock clock.WithTicker if tc.controllerTime != nil { fakeClock = clocktesting.NewFakeClock(*tc.controllerTime) } else { fakeClock = clocktesting.NewFakeClock(time.Now()) } manager, sharedInformerFactory := newControllerFromClientWithClock(ctx, t, clientSet, controller.NoResyncPeriodFunc, fakeClock)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 11 15:36:36 UTC 2024 - 229.2K bytes - Viewed (0) -
pkg/kubelet/images/image_gc_manager_test.go
fakeRuntime.AllPodList = []*containertest.FakePod{ {Pod: &container.Pod{ Containers: []*container.Container{ makeContainer(1), }, }}, } fakeClock := testingclock.NewFakeClock(time.Now()) t.Log(fakeClock.Now()) _, err := manager.detectImages(ctx, fakeClock.Now()) require.NoError(t, err) require.Equal(t, manager.imageRecordsLen(), 2)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 22 15:38:20 UTC 2024 - 29.2K bytes - Viewed (0)