- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 38 for NewFakeClock (0.25 sec)
-
pkg/controller/tainteviction/timed_workers_test.go
atomic.AddInt32(&testVal, 1) wg.Done() return nil }) now := time.Now() then := now.Add(10 * time.Second) fakeClock := testingclock.NewFakeClock(now) queue.clock = fakeClock queue.AddWork(context.TODO(), NewWorkArgs("1", "1"), now, then) queue.AddWork(context.TODO(), NewWorkArgs("2", "2"), now, then) queue.AddWork(context.TODO(), NewWorkArgs("3", "3"), now, then)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Oct 30 12:23:56 UTC 2023 - 5.6K bytes - Viewed (0) -
pkg/kubelet/util/node_startup_latency_tracker_test.go
}) } func TestRecordAllTimestamps(t *testing.T) { t.Run("all timestamps are recorded", func(t *testing.T) { metrics.Register() defer clearMetrics() fakeClock := testingclock.NewFakeClock(frozenTime) tracker := &basicNodeStartupLatencyTracker{ bootTime: frozenTime.Add(-100 * time.Millisecond), kubeletStartTime: frozenTime, clock: fakeClock, }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Sep 11 05:54:25 UTC 2023 - 18K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/value/encrypt/envelope/kmsv2/cache_test.go
"time" "k8s.io/apimachinery/pkg/util/sets" "k8s.io/apiserver/pkg/storage/value" testingclock "k8s.io/utils/clock/testing" ) func TestSimpleCacheSetError(t *testing.T) { fakeClock := testingclock.NewFakeClock(time.Now()) cache := newSimpleCache(fakeClock, time.Second, "providerName") tests := []struct { name string key []byte transformer value.Transformer }{ {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Aug 31 20:26:58 UTC 2023 - 4.9K bytes - Viewed (0) -
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/controller/daemon/update_test.go
// all old pods are unavailable so should be surged manager.failedPodsBackoff.Clock = testingclock.NewFakeClock(time.Unix(100, 0)) clearExpectations(t, manager, ds, podControl) expectSyncDaemonSets(t, manager, ds, podControl, 5, 0, 0) // waiting for pods to go ready, old pods are deleted manager.failedPodsBackoff.Clock = testingclock.NewFakeClock(time.Unix(200, 0)) clearExpectations(t, manager, ds, podControl)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Feb 10 21:10:35 UTC 2024 - 28.9K 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/pod_startup_latency_tracker_test.go
kubelet_pod_start_sli_duration_seconds_bucket{le="+Inf"} 1 kubelet_pod_start_sli_duration_seconds_sum 2.9 kubelet_pod_start_sli_duration_seconds_count 1 ` fakeClock := testingclock.NewFakeClock(frozenTime) metrics.Register() tracker := &basicPodStartupLatencyTracker{ pods: map[types.UID]*perPodState{}, clock: fakeClock, } podInit := buildInitializingPod()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Nov 15 06:09:49 UTC 2023 - 13.7K 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) -
staging/src/k8s.io/apiserver/pkg/storage/cacher/watch_progress_test.go
pollTimeout = 5 * time.Second ) func TestConditionalProgressRequester(t *testing.T) { _, ctx := ktesting.NewTestContext(t) logger := klog.FromContext(ctx) clock := testingclock.NewFakeClock(time.Now()) pr := newTestConditionalProgressRequester(clock) stopCh := make(chan struct{}) go pr.Run(stopCh) var wantRequestsSent int32 var requestsSent int32 logger.Info("Wait for ticker to be created")
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Mar 04 11:51:06 UTC 2024 - 4.6K bytes - Viewed (0)