- Sort Score
- Result 10 results
- Languages All
Results 1 - 9 of 9 for LoggerWithValues (0.28 sec)
-
staging/src/k8s.io/apimachinery/pkg/util/runtime/runtime_stack_test.go
fmt.Printf("Unexpected error configuring klog: %v", err) return } } var buffer bytes.Buffer klog.SetOutput(&buffer) logger := klog.Background() logger = klog.LoggerWithValues(logger, "request", 42) ctx := klog.NewContext(context.Background(), logger) // The line number of the next call must be at line 60. Here are some // blank lines that can be removed to keep the line unchanged. //
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 26 16:28:45 UTC 2024 - 1.9K bytes - Viewed (0) -
pkg/scheduler/framework/runtime/framework.go
// Run Score method for each node in parallel. f.Parallelizer().Until(ctx, len(nodes), func(index int) { nodeName := nodes[index].Node().Name logger := logger if verboseLogs { logger = klog.LoggerWithValues(logger, "node", klog.ObjectRef{Name: nodeName}) } for _, pl := range plugins { ctx := ctx if verboseLogs { logger := klog.LoggerWithName(logger, pl.Name())
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/controller/resourcequota/resource_quota_controller.go
key, quit := queue.Get() if quit { return true } defer queue.Done(key) rq.workerLock.RLock() defer rq.workerLock.RUnlock() logger := klog.FromContext(ctx) logger = klog.LoggerWithValues(logger, "queueKey", key) ctx = klog.NewContext(ctx, logger) err := rq.syncHandler(ctx, key) if err == nil { queue.Forget(key) return false } utilruntime.HandleError(err)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 21.3K bytes - Viewed (0) -
pkg/controller/resourceclaim/controller.go
default: return fmt.Errorf("unexpected key prefix: %s", prefix) } } func (ec *Controller) syncPod(ctx context.Context, namespace, name string) error { logger := klog.LoggerWithValues(klog.FromContext(ctx), "pod", klog.KRef(namespace, name)) ctx = klog.NewContext(ctx, logger) pod, err := ec.podLister.Pods(namespace).Get(name) if err != nil { if apierrors.IsNotFound(err) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 09 03:34:25 UTC 2024 - 37.1K bytes - Viewed (0) -
pkg/kubelet/cm/dra/plugin/noderesources.go
// re-registers. func (c *nodeResourcesController) monitorPlugin(ctx context.Context, active *activePlugin, driverName string, pluginInstance *plugin) { logger := klog.FromContext(ctx) logger = klog.LoggerWithValues(logger, "driverName", driverName) logger.Info("Starting to monitor node resources of the plugin") defer func() { r := recover()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 27 20:12:53 UTC 2024 - 16.6K bytes - Viewed (0) -
pkg/scheduler/schedule_one.go
return } pod := podInfo.Pod // TODO(knelasevero): Remove duplicated keys from log entry calls // When contextualized logging hits GA // https://github.com/kubernetes/kubernetes/issues/111672 logger = klog.LoggerWithValues(logger, "pod", klog.KObj(pod)) ctx = klog.NewContext(ctx, logger) logger.V(4).Info("About to try and schedule pod", "pod", klog.KObj(pod)) fwk, err := sched.frameworkForPod(pod) if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jun 06 13:28:08 UTC 2024 - 43.4K bytes - Viewed (0) -
pkg/proxy/nftables/proxier.go
hostname string, nodeIP net.IP, recorder events.EventRecorder, healthzServer *healthcheck.ProxierHealthServer, nodePortAddressStrings []string, initOnly bool, ) (*Proxier, error) { logger := klog.LoggerWithValues(klog.FromContext(ctx), "ipFamily", ipFamily) if initOnly { logger.Info("System initialized and --init-only specified") return nil, nil } // Generate the masquerade mark to use for SNAT rules.
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/proxy/iptables/proxier.go
hostname string, nodeIP net.IP, recorder events.EventRecorder, healthzServer *healthcheck.ProxierHealthServer, nodePortAddressStrings []string, initOnly bool, ) (*Proxier, error) { logger := klog.LoggerWithValues(klog.FromContext(ctx), "ipFamily", ipFamily) nodePortAddresses := proxyutil.NewNodePortAddresses(ipFamily, nodePortAddressStrings) if !nodePortAddresses.ContainsIPv4Loopback() { localhostNodePorts = false }
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/proxy/ipvs/proxier.go
nodeIP net.IP, recorder events.EventRecorder, healthzServer *healthcheck.ProxierHealthServer, scheduler string, nodePortAddressStrings []string, initOnly bool, ) (*Proxier, error) { logger := klog.LoggerWithValues(klog.FromContext(ctx), "ipFamily", ipFamily) // Set the conntrack sysctl we need for if err := proxyutil.EnsureSysctl(sysctl, sysctlVSConnTrack, 1); err != nil { return nil, err }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Apr 28 15:51:23 UTC 2024 - 77.7K bytes - Viewed (0)