- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 17 for TestingBlock (0.17 sec)
-
pkg/kubelet/util/cache/object_cache_test.go
limitations under the License. */ package cache import ( "fmt" "testing" "time" expirationcache "k8s.io/client-go/tools/cache" "k8s.io/utils/clock" testingclock "k8s.io/utils/clock/testing" ) type testObject struct { key string val string } // A fake objectCache for unit test.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Sep 17 13:19:08 UTC 2021 - 2.6K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/healthz_test.go
limitations under the License. */ package server import ( "testing" "time" testingclock "k8s.io/utils/clock/testing" ) func TestDelayedHealthCheck(t *testing.T) { t.Run("test that liveness check returns true until the delay has elapsed", func(t *testing.T) { t0 := time.Unix(0, 0) c := testingclock.NewFakeClock(t0) doneCh := make(chan struct{})
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Sep 15 09:52:18 UTC 2021 - 2.2K bytes - Viewed (0) -
pkg/controller/tainteviction/timed_workers_test.go
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/queue/work_queue_test.go
"time" "github.com/stretchr/testify/assert" "k8s.io/apimachinery/pkg/types" "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 }
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/endpoints/filters/request_received_time_test.go
limitations under the License. */ package filters import ( "net/http" "net/http/httptest" "testing" "time" "k8s.io/apiserver/pkg/endpoints/request" testingclock "k8s.io/utils/clock/testing" ) func TestWithRequestReceivedTimestamp(t *testing.T) { receivedTimestampExpected := time.Now() var ( callCount int receivedTimestampGot time.Time
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Sep 15 09:52:18 UTC 2021 - 2K bytes - Viewed (0) -
pkg/kubelet/active_deadline_test.go
"k8s.io/api/core/v1" metav1 "k8s.io/apimachinery/pkg/apis/meta/v1" "k8s.io/apimachinery/pkg/types" "k8s.io/client-go/tools/record" "k8s.io/kubernetes/pkg/kubelet/status" "k8s.io/utils/clock" testingclock "k8s.io/utils/clock/testing" ) // mockPodStatusProvider returns the status on the specified pod type mockPodStatusProvider struct { pods []*v1.Pod }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Oct 08 09:06:42 UTC 2022 - 4.5K bytes - Viewed (0) -
pkg/controlplane/controller/legacytokentracking/controller_test.go
metav1 "k8s.io/apimachinery/pkg/apis/meta/v1" "k8s.io/apimachinery/pkg/runtime" "k8s.io/apimachinery/pkg/runtime/schema" "k8s.io/client-go/kubernetes/fake" core "k8s.io/client-go/testing" testingclock "k8s.io/utils/clock/testing" ) const throttlePeriod = 30 * time.Second func TestSyncConfigMap(t *testing.T) { now := time.Now().UTC() tests := []struct { name string
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 19 17:33:34 UTC 2023 - 7.6K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/value/encrypt/envelope/kmsv2/cache_test.go
"crypto/sha256" "fmt" "sync" "sync/atomic" "testing" "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
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/util/flowcontrol/dropped_requests_tracker_test.go
limitations under the License. */ package flowcontrol import ( "fmt" "sync" "testing" "time" testingclock "k8s.io/utils/clock/testing" ) func TestDroppedRequestsTracker(t *testing.T) { fakeClock := testingclock.NewFakeClock(time.Now()) tracker := newDroppedRequestsTracker(fakeClock.Now) // The following table represents the list over time of:
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 26 13:50:25 UTC 2023 - 4.9K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/endpoints/filterlatency/filterlatency_test.go
"net/http" "net/http/httptest" "testing" "time" sdktrace "go.opentelemetry.io/otel/sdk/trace" "go.opentelemetry.io/otel/sdk/trace/tracetest" noopoteltrace "go.opentelemetry.io/otel/trace/noop" testingclock "k8s.io/utils/clock/testing" ) func TestTrackStartedWithContextAlreadyHasFilterRecord(t *testing.T) { filterName := "my-filter" var ( callCount int filterRecord *requestFilterRecord )
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 07 17:57:37 UTC 2024 - 7.1K bytes - Viewed (0)