- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 188 for recorder (0.17 sec)
-
pkg/controller/job/job_controller.go
// Orphan deleted pods that still have a Job tracking finalizer to be removed orphanQueue workqueue.TypedRateLimitingInterface[string] broadcaster record.EventBroadcaster recorder record.EventRecorder clock clock.WithTicker // Store with information to compute the expotential backoff delay for pod // recreation in case of pod failures. podBackoffStore *backoffStore }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jun 10 23:56:37 UTC 2024 - 77.6K bytes - Viewed (0) -
cmd/kubelet/app/server.go
return err } return nil } // makeEventRecorder sets up kubeDeps.Recorder if it's nil. It's a no-op otherwise. func makeEventRecorder(ctx context.Context, kubeDeps *kubelet.Dependencies, nodeName types.NodeName) { if kubeDeps.Recorder != nil { return } eventBroadcaster := record.NewBroadcaster(record.WithContext(ctx))
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 07 00:05:34 UTC 2024 - 53.9K bytes - Viewed (0) -
cmd/bucket-lifecycle-handlers_test.go
expectedRespStatus int lifecycleResponse []byte errorResponse APIErrorResponse shouldPass bool }, ) { for i, testCase := range testCases { // initialize httptest Recorder, this records any mutations to response writer inside the handler. rec := httptest.NewRecorder() // construct HTTP request req, err := newTestSignedRequestV4(testCase.method, getBucketLifecycleURL("", testCase.bucketName),
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 15:50:49 UTC 2024 - 11.3K bytes - Viewed (0) -
pkg/kubelet/kubelet_node_status.go
// recordEvent records an event for this node, the Kubelet's nodeRef is passed to the recorder func (kl *Kubelet) recordEvent(eventType, event, message string) { kl.recorder.Eventf(kl.nodeRef, eventType, event, message) } // record if node schedulable change. func (kl *Kubelet) recordNodeSchedulableEvent(ctx context.Context, node *v1.Node) error { kl.lastNodeUnschedulableLock.Lock() defer kl.lastNodeUnschedulableLock.Unlock()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 31.1K bytes - Viewed (0) -
pkg/kubelet/volumemanager/volume_manager.go
kubeClient clientset.Interface, volumePluginMgr *volume.VolumePluginMgr, kubeContainerRuntime container.Runtime, mounter mount.Interface, hostutil hostutil.HostUtils, kubeletPodsDir string, recorder record.EventRecorder, blockVolumePathHandler volumepathhandler.BlockVolumePathHandler) VolumeManager { seLinuxTranslator := util.NewSELinuxLabelTranslator() vm := &volumeManager{ kubeClient: kubeClient,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 21.5K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/etcd3/store_test.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 11 12:45:33 UTC 2024 - 26.5K bytes - Viewed (0) -
pkg/controller/endpointslice/endpointslice_controller.go
endpointSliceInformer discoveryinformers.EndpointSliceInformer, maxEndpointsPerSlice int32, client clientset.Interface, endpointUpdatesBatchPeriod time.Duration, ) *Controller { broadcaster := record.NewBroadcaster(record.WithContext(ctx)) recorder := broadcaster.NewRecorder(scheme.Scheme, v1.EventSource{Component: "endpoint-slice-controller"}) endpointslicemetrics.RegisterMetrics() c := &Controller{ client: client,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 08:33:32 UTC 2024 - 23.6K bytes - Viewed (0) -
pkg/scheduler/framework/runtime/framework.go
return func(o *frameworkOptions) { o.kubeConfig = kubeConfig } } // WithEventRecorder sets clientSet for the scheduling frameworkImpl. func WithEventRecorder(recorder events.EventRecorder) Option { return func(o *frameworkOptions) { o.eventRecorder = recorder } } // WithInformerFactory sets informer factory for the scheduling frameworkImpl.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 17 09:07:27 UTC 2024 - 60.9K bytes - Viewed (0) -
cmd/bucket-handlers_test.go
Code: "InvalidAccessKeyId", Message: "The Access Key Id you provided does not exist in our records.", }, shouldPass: false, }, } for i, testCase := range testCases { if i != 1 { continue } // initialize httptest Recorder, this records any mutations to response writer inside the handler. rec := httptest.NewRecorder()
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 15:50:49 UTC 2024 - 39.8K bytes - Viewed (0) -
pkg/volume/plugins.go
// Returns the name of the node GetNodeName() types.NodeName GetAttachedVolumesFromNodeStatus() (map[v1.UniqueVolumeName]string, error) // Returns the event recorder of kubelet. GetEventRecorder() record.EventRecorder // Returns an interface that should be used to execute subpath operations GetSubpather() subpath.Interface } // VolumePluginMgr tracks registered plugins.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jun 06 16:13:15 UTC 2024 - 38.2K bytes - Viewed (0)