- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 188 for recorder (0.23 sec)
-
pkg/kubelet/images/image_gc_manager.go
// The image garbage collection policy in use. policy ImageGCPolicy // statsProvider provides stats used during image garbage collection. statsProvider StatsProvider // Recorder for Kubernetes events. recorder record.EventRecorder // Reference to this node. nodeRef *v1.ObjectReference // imageCache is the cache of latest image list. imageCache imageCache // tracer for recording spans
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 19.4K bytes - Viewed (0) -
src/cmd/trace/jsontrace_test.go
} func recordJSONTraceHandlerResponse(t *testing.T, parsed *parsedTrace) format.Data { h := JSONTraceHandler(parsed) recorder := httptest.NewRecorder() r := httptest.NewRequest("GET", "/jsontrace", nil) h.ServeHTTP(recorder, r) var data format.Data if err := json.Unmarshal(recorder.Body.Bytes(), &data); err != nil { t.Fatal(err) } return data }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 17 18:48:18 UTC 2024 - 7.8K bytes - Viewed (0) -
cmd/kube-proxy/app/server_linux.go
config.IPTables.MasqueradeAll, *config.IPTables.LocalhostNodePorts, int(*config.IPTables.MasqueradeBit), localDetectors, s.Hostname, s.NodeIPs, s.Recorder, s.HealthzServer, config.NodePortAddresses, initOnly, ) } else { // Create a single-stack proxier if and only if the node does not support dual-stack (i.e, no iptables support).
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Jun 08 13:48:54 UTC 2024 - 18.1K 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) -
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) -
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/cm/container_manager_linux.go
// Absolute cgroupfs path to a cgroup that Kubelet needs to place all pods under. // This path include a top level container for enforcing Node Allocatable. cgroupRoot CgroupName // Event recorder interface. recorder record.EventRecorder // Interface for QoS cgroup management qosContainerManager QOSContainerManager // Interface for exporting and allocating devices reported by device plugins.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 21 10:18:16 UTC 2024 - 35.1K bytes - Viewed (0) -
pkg/kubemark/hollow_kubelet.go
NodeStartupLatencyTracker: kubeletutil.NewNodeStartupLatencyTracker(), TracerProvider: noopoteltrace.NewTracerProvider(), Recorder: &record.FakeRecorder{}, // With real recorder we attempt to read /dev/kmsg. } return &HollowKubelet{ KubeletFlags: flags, KubeletConfiguration: config, KubeletDeps: d, } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 07 17:10:54 UTC 2024 - 7.8K bytes - Viewed (0) -
pkg/controller/statefulset/stateful_set.go
eventBroadcaster := record.NewBroadcaster(record.WithContext(ctx)) recorder := eventBroadcaster.NewRecorder(scheme.Scheme, v1.EventSource{Component: "statefulset-controller"}) ssc := &StatefulSetController{ kubeClient: kubeClient, control: NewDefaultStatefulSetControl( NewStatefulPodControl( kubeClient, podInformer.Lister(), pvcInformer.Lister(), recorder),
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 05 19:06:41 UTC 2024 - 18.5K bytes - Viewed (0)