- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 614 for recorder (0.21 sec)
-
pkg/kubelet/images/image_manager.go
var puller imagePuller if serialized { puller = newSerialImagePuller(imageService) } else { puller = newParallelImagePuller(imageService, maxParallelImagePulls) } return &imageManager{ recorder: recorder, imageService: imageService, backOff: imageBackOff, puller: puller, podPullingTimeRecorder: podPullingTimeRecorder, } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Feb 08 00:30:31 UTC 2024 - 8.9K bytes - Viewed (0) -
pkg/registry/core/service/portallocator/controller/repair.go
recorder := eventBroadcaster.NewRecorder(legacyscheme.Scheme, "portallocator-repair-controller") registerMetrics() return &Repair{ interval: interval, serviceClient: serviceClient, portRange: portRange, alloc: alloc, leaks: map[int]int{}, broadcaster: eventBroadcaster, recorder: recorder, } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Sep 30 15:46:06 UTC 2023 - 10.4K bytes - Viewed (0) -
pkg/kubelet/network/dns/dns_test.go
// testHostNameserver and testHostDomain are also being used in dns_windows_test.go. testHostNameserver = "8.8.8.8" testHostDomain = "host.domain" fetchEvent = func(recorder *record.FakeRecorder) string { select { case event := <-recorder.Events: return event default: return "" } } ) func TestParseResolvConf(t *testing.T) { testCases := []struct { data string nameservers []string
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 25.6K bytes - Viewed (0) -
pkg/proxy/kubemark/hollow_proxy.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 22 05:08:41 UTC 2024 - 2.9K bytes - Viewed (0) -
pkg/controller/tainteviction/taint_eviction_test.go
}, } if diff := cmp.Diff(want, recorder.Events, cmp.FilterPath(f, cmp.Ignore())); len(diff) > 0 { t.Errorf("emitPodDeletionEvent() returned data (-want,+got):\n%s", diff) } }) t.Run("emitCancelPodDeletionEvent", func(t *testing.T) { controller := &Controller{} recorder := testutil.NewFakeRecorder() controller.recorder = recorder controller.emitCancelPodDeletionEvent(types.NamespacedName{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 25 14:24:16 UTC 2024 - 31.3K bytes - Viewed (0) -
pkg/controller/statefulset/stateful_pod_control.go
} // NewStatefulPodControlFromManager creates a StatefulPodControl using the given StatefulPodControlObjectManager and recorder. func NewStatefulPodControlFromManager(om StatefulPodControlObjectManager, recorder record.EventRecorder) *StatefulPodControl { return &StatefulPodControl{om, recorder} }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 05 19:06:41 UTC 2024 - 14.9K bytes - Viewed (0) -
pkg/controller/tainteviction/taint_eviction.go
metrics.Register() eventBroadcaster := record.NewBroadcaster(record.WithContext(ctx)) recorder := eventBroadcaster.NewRecorder(scheme.Scheme, v1.EventSource{Component: controllerName}) podIndexer := podInformer.Informer().GetIndexer() tm := &Controller{ name: controllerName, client: c, broadcaster: eventBroadcaster, recorder: recorder, podLister: podInformer.Lister(),
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 19.9K bytes - Viewed (0) -
pkg/proxy/servicechangetracker.go
func NewServiceChangeTracker(makeServiceInfo makeServicePortFunc, ipFamily v1.IPFamily, recorder events.EventRecorder, processServiceMapChange processServiceMapChangeFunc) *ServiceChangeTracker { return &ServiceChangeTracker{ items: make(map[types.NamespacedName]*serviceChange), makeServiceInfo: makeServiceInfo, recorder: recorder, ipFamily: ipFamily,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Dec 21 14:44:08 UTC 2023 - 8.7K bytes - Viewed (0) -
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/pluginmanager/operationexecutor/operation_generator.go
} // NewOperationGenerator is returns instance of operationGenerator func NewOperationGenerator(recorder record.EventRecorder) OperationGenerator { return &operationGenerator{ recorder: recorder, } } // OperationGenerator interface that extracts out the functions from operation_executor to make it dependency injectable type OperationGenerator interface {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Mar 16 14:21:15 UTC 2024 - 7.1K bytes - Viewed (0)