- Sort Score
- Result 10 results
- Languages All
Results 71 - 80 of 694 for recorder (0.24 sec)
-
pkg/controller/volume/ephemeral/controller.go
podSynced cache.InformerSynced // podIndexer has the common PodPVC indexer indexer installed To // limit iteration over pods to those of interest. podIndexer cache.Indexer // recorder is used to record events in the API server recorder record.EventRecorder queue workqueue.TypedRateLimitingInterface[string] } // NewController creates an ephemeral volume controller. func NewController( ctx context.Context,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 9.2K bytes - Viewed (0) -
pkg/kubelet/pluginmanager/plugin_manager.go
// PluginManager interface. func NewPluginManager( sockDir string, recorder record.EventRecorder) PluginManager { asw := cache.NewActualStateOfWorld() dsw := cache.NewDesiredStateOfWorld() reconciler := reconciler.NewReconciler( operationexecutor.NewOperationExecutor( operationexecutor.NewOperationGenerator( recorder, ), ), loopSleepDuration, dsw, asw, ) pm := &pluginManager{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jul 01 05:56:33 UTC 2022 - 4.3K bytes - Viewed (0) -
pkg/controller/nodeipam/ipam/range_allocator.go
nodeLister corelisters.NodeLister // nodesSynced returns true if the node shared informer has been synced at least once. nodesSynced cache.InformerSynced broadcaster record.EventBroadcaster recorder record.EventRecorder // queues are where incoming work is placed to de-dup and to allow "easy" // rate limited requeues on errors queue workqueue.RateLimitingInterface }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 10:06:15 UTC 2024 - 16.2K bytes - Viewed (0) -
pkg/kubelet/nodeshutdown/nodeshutdown_manager_linux.go
if conf.Clock == nil { conf.Clock = clock.RealClock{} } manager := &managerImpl{ logger: conf.Logger, probeManager: conf.ProbeManager, recorder: conf.Recorder, nodeRef: conf.NodeRef, getPods: conf.GetPodsFunc, killPodFunc: conf.KillPodFunc,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Nov 09 08:02:40 UTC 2022 - 15.5K bytes - Viewed (0) -
pkg/kubelet/server/stats/testing/mock_stats_provider.go
type MockProvider struct { ctrl *gomock.Controller recorder *MockProviderMockRecorder } // MockProviderMockRecorder is the mock recorder for MockProvider. type MockProviderMockRecorder struct { mock *MockProvider } // NewMockProvider creates a new mock instance. func NewMockProvider(ctrl *gomock.Controller) *MockProvider { mock := &MockProvider{ctrl: ctrl} mock.recorder = &MockProviderMockRecorder{mock} return mock }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 07 08:12:16 UTC 2024 - 11.8K 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/eviction/eviction_manager.go
// nodeRef is a reference to the node nodeRef *v1.ObjectReference // used to record events about the node recorder record.EventRecorder // used to measure usage stats on system summaryProvider stats.SummaryProvider // records when a threshold was first observed thresholdsFirstObservedAt thresholdsObservedAt // records the set of thresholds that have been met (including graceperiod) but not yet resolved
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Mar 27 18:55:56 UTC 2024 - 24.6K 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/proxy/winkernel/proxier.go
endPointChangeTracker := proxy.NewEndpointsChangeTracker(hostname, proxier.newEndpointInfo, ipFamily, recorder, proxier.endpointsMapChange) proxier.endpointsChanges = endPointChangeTracker proxier.serviceChanges = serviceChanges burstSyncs := 2
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 18 13:25:06 UTC 2024 - 59K bytes - Viewed (0) -
cmd/http-tracer.go
return http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) { // Setup a http request response recorder - this is needed for // http stats requests and audit if enabled. respRecorder := xhttp.NewResponseRecorder(w) // Setup a http request body recorder reqRecorder := &xhttp.RequestRecorder{Reader: r.Body} r.Body = reqRecorder
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 03 15:45:54 UTC 2024 - 6K bytes - Viewed (0)