- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 54 for TestingBlock (0.24 sec)
-
pkg/kubelet/logs/container_log_manager_test.go
"k8s.io/apimachinery/pkg/util/wait" "k8s.io/client-go/util/workqueue" "k8s.io/kubernetes/pkg/kubelet/container" runtimeapi "k8s.io/cri-api/pkg/apis/runtime/v1" critest "k8s.io/cri-api/pkg/apis/testing" testingclock "k8s.io/utils/clock/testing" ) func TestGetAllLogs(t *testing.T) { dir, err := os.MkdirTemp("", "test-get-all-logs") require.NoError(t, err) defer os.RemoveAll(dir) testLogs := []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/admission/plugin/webhook/testing/webhook_server.go
"regexp" "strconv" "strings" "testing" "time" "k8s.io/api/admission/v1beta1" metav1 "k8s.io/apimachinery/pkg/apis/meta/v1" "k8s.io/apiserver/pkg/admission/plugin/webhook/testcerts" testingclock "k8s.io/utils/clock/testing" ) // NewTestServerWithHandler returns a webhook test HTTPS server // which uses given handler function to handle requests
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Nov 15 11:11:25 UTC 2021 - 6.3K bytes - Viewed (0) -
pkg/controlplane/controller/apiserverleasegc/gc_controller_test.go
metav1 "k8s.io/apimachinery/pkg/apis/meta/v1" "k8s.io/client-go/kubernetes/fake" testingclock "k8s.io/utils/clock/testing" "k8s.io/utils/pointer" ) // Test_Controller validates the garbage collection logic for the apiserverleasegc controller. func Test_Controller(t *testing.T) { fakeClock := testingclock.NewFakeClock(time.Now()) tests := []struct { name string lease *coordinationv1.Lease
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jan 13 20:37:22 UTC 2023 - 4.7K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/util/cache/expiring_test.go
limitations under the License. */ package cache import ( "context" "math/rand" "sync" "testing" "time" "github.com/google/uuid" testingclock "k8s.io/utils/clock/testing" ) func TestExpiringCache(t *testing.T) { cache := NewExpiring() if result, ok := cache.Get("foo"); ok || result != nil { t.Errorf("Expected null, false, got %#v, %v", result, ok)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 22 15:51:23 UTC 2023 - 7.3K bytes - Viewed (0) -
pkg/kubelet/pleg/evented_test.go
containertest "k8s.io/kubernetes/pkg/kubelet/container/testing" "k8s.io/kubernetes/pkg/kubelet/metrics" testingclock "k8s.io/utils/clock/testing" ) func newTestEventedPLEG() *EventedPLEG { return &EventedPLEG{ runtime: &containertest.FakeRuntime{}, clock: testingclock.NewFakeClock(time.Time{}), cache: kubecontainer.NewCache(), runtimeService: critest.NewFakeRuntimeService(),
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Apr 01 07:45:05 UTC 2023 - 6.4K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/util/wait/loop_test.go
limitations under the License. */ package wait import ( "context" "errors" "fmt" "reflect" "testing" "time" "github.com/google/go-cmp/cmp" "k8s.io/utils/clock" testingclock "k8s.io/utils/clock/testing" ) func timerWithClock(t Timer, c clock.WithTicker) Timer { switch t := t.(type) { case *fixedTimer: t.new = c.NewTicker case *variableTimer: t.new = c.NewTimer default:
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Oct 19 02:48:08 UTC 2023 - 15.8K bytes - Viewed (0) -
pkg/kubelet/stats/cri_stats_provider_windows_test.go
statsapi "k8s.io/kubelet/pkg/apis/stats/v1alpha1" kubecontainertest "k8s.io/kubernetes/pkg/kubelet/container/testing" "k8s.io/kubernetes/pkg/kubelet/kuberuntime" "k8s.io/kubernetes/pkg/volume" testingclock "k8s.io/utils/clock/testing" ) type fakeNetworkStatsProvider struct { containers []containerStats } type containerStats struct { container hcsshim.ContainerProperties hcsStats []hcsshim.NetworkStats
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Feb 17 00:02:10 UTC 2024 - 13.8K 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) -
staging/src/k8s.io/apimachinery/pkg/util/wait/wait_test.go
backoffMgr := NewJitteredBackoffManager(1, 1, testingclock.NewFakeClock(time.Now())) for i := 0; i < 5; i++ { backoff := backoffMgr.(*jitteredBackoffManagerImpl).getNextBackoff() if backoff < 1 || backoff > 2 { t.Errorf("backoff out of range: %d", backoff) } } // negative jitter, shall be a fixed backoff backoffMgr = NewJitteredBackoffManager(1, -1, testingclock.NewFakeClock(time.Now()))
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 26 16:28:45 UTC 2024 - 41.1K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/authentication/token/cache/cached_token_authenticator_test.go
auditinternal "k8s.io/apiserver/pkg/apis/audit" "k8s.io/apiserver/pkg/audit" "k8s.io/apiserver/pkg/authentication/authenticator" "k8s.io/apiserver/pkg/authentication/user" "k8s.io/utils/clock" testingclock "k8s.io/utils/clock/testing" ) func TestCachedTokenAuthenticator(t *testing.T) { var ( calledWithToken []string resultUsers map[string]user.Info resultOk bool resultErr error )
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jul 03 16:16:51 UTC 2023 - 20.3K bytes - Viewed (0)