- Sort Score
- Result 10 results
- Languages All
Results 1 - 7 of 7 for NewFakeClock (0.35 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) -
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/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) -
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) -
staging/src/k8s.io/apiserver/pkg/storage/value/encrypt/aes/cache_test.go
twiPtrEquals(t, nil, got22) }, }, } for _, tt := range tests { tt := tt t.Run(tt.name, func(t *testing.T) { t.Parallel() clock := clocktesting.NewFakeClock(time.Now()) cache := newSimpleCache(clock, 10*time.Second) tt.test(t, cache, clock) }) } } func twiPtrEquals(t *testing.T, want, got *transformerWithInfo) { t.Helper()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jul 21 19:25:52 UTC 2023 - 3.5K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/util/cache/lruexpirecache_test.go
}) assertKeys(t, c.Keys(), []any{"other-long-lived"}) expectNotEntry(t, c, "long-lived") expectEntry(t, c, "other-long-lived", "12345") } func TestExpiredGet(t *testing.T) { fakeClock := testingclock.NewFakeClock(time.Now()) c := NewLRUExpireCacheWithClock(10, fakeClock) c.Add("short-lived", "12345", 1*time.Millisecond) // ensure the entry expired fakeClock.Step(2 * time.Millisecond)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Nov 03 18:40:48 UTC 2023 - 4.3K bytes - Viewed (0)