- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 37 for recorder (0.35 sec)
-
pkg/proxy/nftables/proxier.go
recorder, healthzServer, nodePortAddresses, initOnly) if err != nil { return nil, fmt.Errorf("unable to create ipv4 proxier: %v", err) } ipv6Proxier, err := NewProxier(ctx, v1.IPv6Protocol, syncPeriod, minSyncPeriod, masqueradeAll, masqueradeBit, localDetectors[v1.IPv6Protocol], hostname, nodeIPs[v1.IPv6Protocol], recorder, healthzServer, nodePortAddresses, initOnly)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Jun 08 13:48:54 UTC 2024 - 55.5K bytes - Viewed (0) -
pkg/kubelet/kuberuntime/kuberuntime_manager.go
imageService = newInstrumentedImageManagerService(imageService) tracer := tracerProvider.Tracer(instrumentationScope) kubeRuntimeManager := &kubeGenericRuntimeManager{ recorder: recorder, cpuCFSQuota: cpuCFSQuota, cpuCFSQuotaPeriod: cpuCFSQuotaPeriod, seccompProfileRoot: filepath.Join(rootDirectory, "seccomp"), livenessManager: livenessManager,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 22 02:01:31 UTC 2024 - 64.7K bytes - Viewed (0) -
pkg/proxy/iptables/proxier.go
svcPortMap: make(proxy.ServicePortMap), serviceChanges: proxy.NewServiceChangeTracker(newServiceInfo, ipFamily, recorder, nil), endpointsMap: make(proxy.EndpointsMap), endpointsChanges: proxy.NewEndpointsChangeTracker(hostname, newEndpointInfo, ipFamily, recorder, nil), needFullSync: true, syncPeriod: syncPeriod, iptables: ipt,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 21 14:39:54 UTC 2024 - 65.1K bytes - Viewed (0) -
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) -
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) -
pkg/scheduler/internal/queue/scheduling_queue.go
return func(o *priorityQueueOptions) { o.preEnqueuePluginMap = m } } // WithMetricsRecorder sets metrics recorder. func WithMetricsRecorder(recorder metrics.MetricAsyncRecorder) Option { return func(o *priorityQueueOptions) { o.metricsRecorder = recorder } } // WithPluginMetricsSamplePercent sets the percentage of plugin metrics to be sampled.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 13:26:09 UTC 2024 - 61.4K bytes - Viewed (0) -
cmd/test-utils_test.go
} rec := httptest.NewRecorder() apiRouter.ServeHTTP(rec, reqI) checkRespErr(rec, http.StatusOK) decoder := xml.NewDecoder(rec.Body) multipartResponse := &InitiateMultipartUploadResponse{} err = decoder.Decode(multipartResponse) if err != nil { t.Fatalf("Error decoding the recorded response Body") } upID := multipartResponse.UploadID // Upload each part var cp []CompletePart
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 15:50:49 UTC 2024 - 76.9K bytes - Viewed (0) -
pkg/kubelet/kuberuntime/kuberuntime_container.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 54.7K bytes - Viewed (0) -
src/go/types/expr.go
// If typ is still an untyped and not the final type, updateExprType // only updates the recorded untyped type for x and possibly its // operands. Otherwise (i.e., typ is not an untyped type anymore, // or it is the final type for x), the type and value are recorded. // Also, if x is a constant, it must be representable as a value of typ, // and if x is the (formerly untyped) lhs operand of a non-constant
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 29 02:09:54 UTC 2024 - 49.7K bytes - Viewed (0)