- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 54 for TestingBlock (0.19 sec)
-
pkg/kubelet/util/node_startup_latency_tracker_test.go
package util import ( "strings" "testing" "time" "github.com/stretchr/testify/assert" "k8s.io/component-base/metrics/testutil" "k8s.io/kubernetes/pkg/kubelet/metrics" "k8s.io/utils/clock" testingclock "k8s.io/utils/clock/testing" ) const ( metricsNameNodeStartupPreKubelet = "kubelet_node_startup_pre_kubelet_duration_seconds"
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/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) -
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) -
staging/src/k8s.io/apiserver/pkg/storage/cacher/watch_progress_test.go
"k8s.io/klog/v2/ktesting" "k8s.io/utils/clock" testingclock "k8s.io/utils/clock/testing" ) var ( pollPeriod = time.Millisecond minimalNoChange = 20 * time.Millisecond pollTimeout = 5 * time.Second ) func TestConditionalProgressRequester(t *testing.T) { _, ctx := ktesting.NewTestContext(t) logger := klog.FromContext(ctx) clock := testingclock.NewFakeClock(time.Now())
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Mar 04 11:51:06 UTC 2024 - 4.6K bytes - Viewed (0) -
pkg/kubelet/util/manager/cache_based_manager_test.go
"k8s.io/apimachinery/pkg/util/sets" clientset "k8s.io/client-go/kubernetes" "k8s.io/client-go/kubernetes/fake" core "k8s.io/client-go/testing" podutil "k8s.io/kubernetes/pkg/api/v1/pod" "k8s.io/utils/clock" testingclock "k8s.io/utils/clock/testing" "github.com/stretchr/testify/assert" ) func checkObject(t *testing.T, store *objectStore, ns, name string, shouldExist bool) { _, err := store.Get(ns, name)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 19.6K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/util/cache/lruexpirecache_test.go
See the License for the specific language governing permissions and limitations under the License. */ package cache import ( "testing" "time" "github.com/google/go-cmp/cmp" testingclock "k8s.io/utils/clock/testing" ) func expectEntry(t *testing.T, c *LRUExpireCache, key interface{}, value interface{}) { t.Helper() result, ok := c.Get(key) if !ok || result != value {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Nov 03 18:40:48 UTC 2023 - 4.3K bytes - Viewed (0) -
pkg/kubelet/util/pod_startup_latency_tracker_test.go
corev1 "k8s.io/api/core/v1" metav1 "k8s.io/apimachinery/pkg/apis/meta/v1" "k8s.io/apimachinery/pkg/types" "k8s.io/component-base/metrics/testutil" "k8s.io/kubernetes/pkg/kubelet/metrics" testingclock "k8s.io/utils/clock/testing" ) var frozenTime = time.Date(2020, 1, 1, 0, 0, 0, 0, time.UTC) const ( uid = "3c1df8a9-11a8-4791-aeae-184c18cca686" metricsName = "kubelet_pod_start_sli_duration_seconds"
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/manager/watch_based_manager_test.go
clientset "k8s.io/client-go/kubernetes" "k8s.io/client-go/kubernetes/fake" core "k8s.io/client-go/testing" corev1 "k8s.io/kubernetes/pkg/apis/core/v1" "k8s.io/utils/clock" testingclock "k8s.io/utils/clock/testing" "github.com/stretchr/testify/assert" ) func listSecret(fakeClient clientset.Interface) listObjectFunc { return func(namespace string, opts metav1.ListOptions) (runtime.Object, error) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 09 10:05:43 UTC 2023 - 17.2K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/cacher/time_budget_test.go
See the License for the specific language governing permissions and limitations under the License. */ package cacher import ( "testing" "time" testingclock "k8s.io/utils/clock/testing" ) func TestTimeBudget(t *testing.T) { fakeClock := testingclock.NewFakeClock(time.Now()) budget := &timeBudgetImpl{ clock: fakeClock, budget: time.Duration(0), maxBudget: 200 * time.Millisecond,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Sep 15 09:52:18 UTC 2021 - 2.8K bytes - Viewed (0)