- Sort Score
- Result 10 results
- Languages All
Results 151 - 160 of 1,192 for slog (0.21 sec)
-
pkg/controller/resourceclaim/controller.go
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/controller/volume/pvprotection/pv_protection_controller.go
return true } func (c *Controller) processPV(ctx context.Context, pvName string) error { logger := klog.FromContext(ctx) logger.V(4).Info("Processing PV", "PV", klog.KRef("", pvName)) startTime := time.Now() defer func() { logger.V(4).Info("Finished processing PV", "PV", klog.KRef("", pvName), "cost", time.Since(startTime)) }() pv, err := c.pvLister.Get(pvName) if apierrors.IsNotFound(err) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 6.4K bytes - Viewed (0) -
pkg/kubelet/cm/dra/plugin/noderesources.go
if kubeClient == nil { return nil } logger := klog.FromContext(ctx) logger = klog.LoggerWithName(logger, "node resources controller") ctx = klog.NewContext(ctx, logger) c := &nodeResourcesController{ ctx: ctx, kubeClient: kubeClient, getNode: getNode,
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/volume/flexvolume/detacher-defaults.go
limitations under the License. */ package flexvolume import ( "time" "k8s.io/klog/v2" "k8s.io/mount-utils" "k8s.io/apimachinery/pkg/types" ) type detacherDefaults flexVolumeDetacher // Detach is part of the volume.Detacher interface. func (d *detacherDefaults) Detach(volumeName string, hostName types.NodeName) error {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Sep 17 04:51:24 UTC 2020 - 1.6K bytes - Viewed (0) -
pkg/volume/csi/csi_mounter.go
func removeMountDir(plug *csiPlugin, mountPath string) error { klog.V(4).Info(log("removing mount path [%s]", mountPath)) mnt, err := isDirMounted(plug, mountPath) if err != nil { return err } if !mnt { klog.V(4).Info(log("dir not mounted, deleting it [%s]", mountPath)) if err := os.Remove(mountPath); err != nil && !os.IsNotExist(err) { return errors.New(log("failed to remove dir [%s]: %v", mountPath, err)) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jan 30 10:47:59 UTC 2024 - 21K bytes - Viewed (1) -
pkg/scheduler/schedule_one.go
// 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 { // This shouldn't happen, because we only accept for scheduling the pods // which specify a scheduler name that matches one of the profiles.
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/volume/portworx/portworx_util.go
if _, present := spec.VolumeLabels[k]; present { klog.Warningf("not saving annotation: %s=%s in spec labels due to an existing key", k, v) continue } spec.VolumeLabels[k] = v } volumeID, err := driver.Create(locator, source, spec) if err != nil { klog.Errorf("Error creating Portworx Volume : %v", err) return "", 0, nil, err }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Sep 16 11:12:06 UTC 2022 - 12.2K bytes - Viewed (0) -
pkg/controller/daemon/daemon_controller.go
podsToDelete = append(podsToDelete, oldestOldPod.Name) case podutil.IsPodAvailable(oldestNewPod, ds.Spec.MinReadySeconds, metav1.Time{Time: dsc.failedPodsBackoff.Clock.Now()}):
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 51.3K bytes - Viewed (0) -
pkg/kubelet/cm/topologymanager/scope_pod.go
bestHint, admit := s.calculateAffinity(pod) klog.InfoS("Best TopologyHint", "bestHint", bestHint, "pod", klog.KObj(pod)) if !admit { metrics.TopologyManagerAdmissionErrorsTotal.Inc() return admission.GetPodAdmitResult(&TopologyAffinityError{}) } for _, container := range append(pod.Spec.InitContainers, pod.Spec.Containers...) { klog.InfoS("Topology Affinity", "bestHint", bestHint, "pod", klog.KObj(pod), "containerName", container.Name)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Apr 14 14:44:24 UTC 2023 - 2.6K bytes - Viewed (0) -
pkg/kubelet/cm/devicemanager/plugin/v1beta1/server.go
} dir, name := filepath.Split(socketPath) klog.V(2).InfoS("Creating device plugin registration server", "version", api.Version, "socket", socketPath) s := &server{ socketName: name, socketDir: dir, rhandler: rh, chandler: ch, clients: make(map[string]Client), } return s, nil } func (s *server) Start() error { klog.V(2).InfoS("Starting device plugin registration server")
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Jan 27 02:10:25 UTC 2024 - 5.4K bytes - Viewed (0)