- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 83 for KObj (0.04 sec)
-
pkg/scheduler/framework/plugins/nodeaffinity/node_affinity.go
return framework.Queue, nil } // TODO: also check if the original node meets the pod's requestments once preCheck is completely removed. // See: https://github.com/kubernetes/kubernetes/issues/110175 logger.V(4).Info("node was created or updated, but it doesn't make this pod schedulable", "pod", klog.KObj(pod), "node", klog.KObj(modifiedNode))
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Dec 18 12:00:10 UTC 2023 - 12.6K bytes - Viewed (0) -
pkg/kubelet/cm/dra/plugin/noderesources.go
if !ok { return } if loggerV := logger.V(6); loggerV.Enabled() { loggerV.Info("ResourceSlice update", "slice", klog.KObj(newSlice), "diff", cmp.Diff(oldSlice, newSlice)) } else { logger.V(5).Info("ResourceSlice update", "slice", klog.KObj(newSlice)) } c.queue.Add(newSlice.DriverName) }, DeleteFunc: func(obj any) { if tombstone, ok := obj.(cache.DeletedFinalStateUnknown); ok {
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/kubelet/cm/devicemanager/topology_hints.go
deviceHints[resource] = []topologymanager.TopologyHint{} continue } klog.InfoS("Regenerating TopologyHints for resource already allocated to pod", "resource", resource, "pod", klog.KObj(pod), "containerName", container.Name)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Jan 27 02:10:25 UTC 2024 - 9.9K bytes - Viewed (0) -
pkg/kubelet/prober/prober_manager.go
"pod", klog.KObj(pod), "containerName", c.Name) return } w := newWorker(m, startup, pod, c) m.workers[key] = w go w.run() } if c.ReadinessProbe != nil { key.probeType = readiness if _, ok := m.workers[key]; ok { klog.V(8).ErrorS(nil, "Readiness probe already exists for container", "pod", klog.KObj(pod), "containerName", c.Name) return }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jul 07 22:26:12 UTC 2023 - 11K bytes - Viewed (0) -
pkg/kubelet/cm/cpumanager/policy_static.go
klog.InfoS("Static policy: container already present in state, skipping", "pod", klog.KObj(pod), "containerName", container.Name) return nil } // Call Topology Manager to get the aligned socket affinity across all hint providers. hint := p.affinity.GetAffinity(string(pod.UID), container.Name) klog.InfoS("Topology Affinity", "pod", klog.KObj(pod), "containerName", container.Name, "affinity", hint)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Oct 06 13:16:15 UTC 2023 - 28.8K bytes - Viewed (0) -
pkg/kubelet/volumemanager/populator/desired_state_of_world_populator.go
continue } klog.V(4).InfoS("Removing volume from desired state", "pod", klog.KObj(volumeToMount.Pod), "podUID", volumeToMount.Pod.UID, "volumeName", volumeToMountSpecName) dswp.desiredStateOfWorld.DeletePodFromVolume(
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 11 09:02:45 UTC 2024 - 23.8K bytes - Viewed (0) -
pkg/kubelet/kubelet_node_status.go
klog.ErrorS(err, "Unable to construct v1.Node object for kubelet") continue } klog.InfoS("Attempting to register node", "node", klog.KObj(node)) registered := kl.tryRegisterWithAPIServer(node) if registered { klog.InfoS("Successfully registered node", "node", klog.KObj(node)) kl.registrationCompleted = true return } } } // tryRegisterWithAPIServer makes an attempt to register the given node with
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 31.1K bytes - Viewed (0) -
pkg/controller/volume/persistentvolume/pv_controller_base.go
// Version conflict error happens quite often and the controller // recovers from it easily. logger.V(3).Info("Could not sync claim", "PVC", klog.KObj(claim), "err", err) } else { logger.Error(err, "Could not sync volume", "PVC", klog.KObj(claim)) } } } // Unit test [5-5] [5-6] [5-7] // deleteClaim runs in worker thread and handles "claim deleted" event.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 10 08:42:31 UTC 2024 - 29.5K bytes - Viewed (0) -
pkg/controller/volume/expand/expand_controller.go
if err != nil { logger.Error(err, "Error starting ExpandVolume for pvc", "PVC", klog.KObj(pvc)) return err } } else { pvc, err := util.MarkResizeInProgressWithResizer(pvc, resizerName, expc.kubeClient) if err != nil { logger.Error(err, "Error setting PVC in progress with error", "PVC", klog.KObj(pvc), "err", err) return err }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 16.2K bytes - Viewed (0) -
pkg/controller/endpoint/endpoints_controller.go
for _, pod := range pods { if !endpointsliceutil.ShouldPodBeInEndpoints(pod, service.Spec.PublishNotReadyAddresses) { logger.V(5).Info("Pod is not included on endpoints for Service", "pod", klog.KObj(pod), "service", klog.KObj(service)) continue } ep, err := podToEndpointAddressForService(service, pod) if err != nil { // this will happen, if the cluster runs with some nodes configured as dual stack and some as not
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 26.3K bytes - Viewed (0)