- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 18 for recorder (0.19 sec)
-
pkg/volume/util/operationexecutor/operation_generator.go
func NewOperationGenerator(kubeClient clientset.Interface, volumePluginMgr *volume.VolumePluginMgr, recorder record.EventRecorder, blkUtil volumepathhandler.BlockVolumePathHandler) OperationGenerator { return &operationGenerator{ kubeClient: kubeClient, volumePluginMgr: volumePluginMgr, recorder: recorder, blkUtil: blkUtil, translator: csitrans.New(), } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 14 06:17:25 UTC 2024 - 101.4K bytes - Viewed (0) -
pkg/kubelet/kubelet.go
Logger: logger, ProbeManager: klet.probeManager, Recorder: kubeDeps.Recorder, NodeRef: nodeRef, GetPodsFunc: klet.GetActivePods, KillPodFunc: killPodNow(klet.podWorkers, kubeDeps.Recorder), SyncNodeStatusFunc: klet.syncNodeStatus,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 14 16:09:17 UTC 2024 - 126.1K bytes - Viewed (0) -
pkg/kubelet/kubelet_test.go
}, }, }, }} recorder := record.NewFakeRecorder(20) nodeRef := &v1.ObjectReference{ Kind: "Node", Name: "testNode", UID: types.UID("testNode"), Namespace: "", } testClusterDNSDomain := "TEST" kl.dnsConfigurer = dns.NewConfigurer(recorder, nodeRef, nil, nil, testClusterDNSDomain, "")
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 14 16:09:17 UTC 2024 - 106.9K bytes - Viewed (0) -
pkg/kubelet/eviction/eviction_manager_test.go
killPodFunc: podKiller.killPodNow, imageGC: diskGC, containerGC: diskGC, config: config, recorder: &record.FakeRecorder{}, summaryProvider: summaryProvider, nodeRef: nodeRef, nodeConditionsLastObservedAt: nodeConditionsObservedAt{},
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 15 23:14:12 UTC 2024 - 119.9K bytes - Viewed (0) -
pkg/scheduler/framework/runtime/framework_test.go
withMetricsRecorder(recorder), WithWaitingPods(NewWaitingPodsMap()), ) if err != nil { cancel() t.Fatalf("Failed to create framework for testing: %v", err) } tt.action(f) // Stop the goroutine which records metrics and ensure it's stopped. cancel() <-recorder.IsStoppedCh
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 17 09:07:27 UTC 2024 - 103K bytes - Viewed (0) -
pkg/scheduler/schedule_one_test.go
b := action.(clienttesting.CreateAction).GetObject().(*v1.Binding) bindingChan <- b } return true, b, nil }) var recorder events.EventRecorder if broadcaster != nil { recorder = broadcaster.NewRecorder(scheme.Scheme, testSchedulerName) } else { recorder = &events.FakeRecorder{} } if informerFactory == nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:20:55 UTC 2024 - 128.1K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/pkg/apiserver/schema/cel/validation_test.go
for _, c := range cases { t.Run(c.name, func(t *testing.T) { validator := NewValidator(c.schema, false, celconfig.PerCallLimit) require.NotNil(t, validator) recorder := &warningRecorder{} ctx := warning.WithWarningRecorder(context.TODO(), recorder) budget := c.runtimeCostBudget if budget == 0 { budget = celconfig.RuntimeCELCostBudget } errs, _ := validator.Validate( ctx,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 17:14:10 UTC 2024 - 159.9K bytes - Viewed (0) -
pkg/scheduler/internal/queue/scheduling_queue_test.go
recorder := metrics.NewMetricsAsyncRecorder(3, 20*time.Microsecond, ctx.Done()) queue := NewTestQueue(ctx, newDefaultQueueSort(), WithClock(testingclock.NewFakeClock(timestamp)), WithPreEnqueuePluginMap(m), WithPluginMetricsSamplePercent(test.pluginMetricsSamplePercent), WithMetricsRecorder(*recorder)) for i, op := range test.operations {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 13:26:09 UTC 2024 - 146.9K bytes - Viewed (0) -
pkg/kubelet/kubelet_pods.go
orphanCount++ } } metrics.OrphanedRuntimePodTotal.Add(float64(orphanCount)) // Now that we have recorded any terminating pods, and added new pods that should be running, // record a summary here. Not all possible combinations of PodWorkerSync values are valid. counts := make(map[PodWorkerSync]int) for _, sync := range workingPods { counts[sync]++ }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 14 16:09:17 UTC 2024 - 101.2K bytes - Viewed (0) -
pkg/kubelet/kubelet_pods_test.go
}) drainAllWorkers(w) r, ok := records[updatedPod.UID] if !ok || len(r) != 2 || r[1].gracePeriod == nil || *r[1].gracePeriod != 2 { t.Fatalf("unexpected records: %#v", records) } // pod worker thinks pod1 exists, but the kubelet will not have it in the pod manager }, wantWorker: func(t *testing.T, w *podWorkers, records map[types.UID][]syncPodRecord) { uid := types.UID("1")
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 07 00:05:23 UTC 2024 - 198.8K bytes - Viewed (0)