- Sort Score
- Result 10 results
- Languages All
Results 1 - 4 of 4 for LoggerWithValues (0.24 sec)
-
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)