Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 37 for KObj (0.34 sec)

  1. pkg/kubelet/runonce.go

    			klog.InfoS("Pod's containers running", "pod", klog.KObj(pod))
    			return nil
    		}
    		klog.InfoS("Pod's containers not running: syncing", "pod", klog.KObj(pod))
    
    		klog.InfoS("Creating a mirror pod for static pod", "pod", klog.KObj(pod))
    		if err := kl.mirrorPodClient.CreateMirrorPod(pod); err != nil {
    			klog.ErrorS(err, "Failed creating a mirror pod", "pod", klog.KObj(pod))
    		}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Aug 04 06:56:50 UTC 2023
    - 5.9K bytes
    - Viewed (0)
  2. pkg/scheduler/internal/cache/node_tree.go

    			if nodeName == n.Name {
    				logger.Info("Did not add to the NodeTree because it already exists", "node", klog.KObj(n))
    				return
    			}
    		}
    		nt.tree[zone] = append(na, n.Name)
    	} else {
    		nt.zones = append(nt.zones, zone)
    		nt.tree[zone] = []string{n.Name}
    	}
    	logger.V(2).Info("Added node in listed group to NodeTree", "node", klog.KObj(n), "zone", zone)
    	nt.numNodes++
    }
    
    // removeNode removes a node from the NodeTree.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon May 29 05:26:32 UTC 2023
    - 4.5K bytes
    - Viewed (0)
  3. pkg/kubelet/cm/memorymanager/fake_memory_manager.go

    }
    
    func (m *fakeManager) Allocate(pod *v1.Pod, container *v1.Container) error {
    	klog.InfoS("Allocate", "pod", klog.KObj(pod), "containerName", container.Name)
    	return nil
    }
    
    func (m *fakeManager) AddContainer(pod *v1.Pod, container *v1.Container, containerID string) {
    	klog.InfoS("Add container", "pod", klog.KObj(pod), "containerName", container.Name, "containerID", containerID)
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Sep 27 13:02:15 UTC 2023
    - 3.1K bytes
    - Viewed (0)
  4. pkg/kubelet/kuberuntime/util/util.go

    		klog.V(2).InfoS("Multiple sandboxes are ready for Pod. Need to reconcile them", "pod", klog.KObj(pod))
    		return true, sandboxStatus.Metadata.Attempt + 1, sandboxStatus.Id
    	}
    	if sandboxStatus.State != runtimeapi.PodSandboxState_SANDBOX_READY {
    		klog.V(2).InfoS("No ready sandbox for pod can be found. Need to start a new one", "pod", klog.KObj(pod))
    		return true, sandboxStatus.Metadata.Attempt + 1, sandboxStatus.Id
    	}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Mar 13 23:14:48 UTC 2024
    - 4.6K bytes
    - Viewed (0)
  5. pkg/kubelet/cm/topologymanager/scope_container.go

    		klog.InfoS("Best TopologyHint", "bestHint", bestHint, "pod", klog.KObj(pod), "containerName", container.Name)
    
    		if !admit {
    			metrics.TopologyManagerAdmissionErrorsTotal.Inc()
    			return admission.GetPodAdmitResult(&TopologyAffinityError{})
    		}
    		klog.InfoS("Topology Affinity", "bestHint", bestHint, "pod", klog.KObj(pod), "containerName", container.Name)
    		s.setTopologyHints(string(pod.UID), container.Name, bestHint)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Apr 14 14:44:24 UTC 2023
    - 2.9K bytes
    - Viewed (0)
  6. pkg/scheduler/framework/plugins/nodeunschedulable/node_unschedulable.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(5).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: Sat Dec 16 12:50:11 UTC 2023
    - 3.9K bytes
    - Viewed (0)
  7. pkg/kubelet/prober/prober.go

    			klog.V(1).ErrorS(err, "Probe errored", "probeType", probeType, "pod", klog.KObj(pod), "podUID", pod.UID, "containerName", container.Name)
    			pb.recordContainerEvent(pod, &container, v1.EventTypeWarning, events.ContainerUnhealthy, "%s probe errored: %v", probeType, err)
    		} else { // result != probe.Success
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Feb 16 10:50:13 UTC 2024
    - 8.7K bytes
    - Viewed (0)
  8. pkg/kubelet/cm/topologymanager/scope_pod.go

    	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)
  9. pkg/proxy/node.go

    			"node", klog.KObj(node), "newPodCIDRs", podCIDRs, "oldPODCIDRs", n.podCIDRs)
    		klog.FlushAndExit(klog.ExitFlushTimeout, 1)
    	}
    }
    
    // OnNodeDelete is a handler for Node deletes.
    func (n *NodePodCIDRHandler) OnNodeDelete(node *v1.Node) {
    	n.logger.Error(nil, "Current Node is being deleted", "node", klog.KObj(node))
    }
    
    // OnNodeSynced is a handler for Node syncs.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Apr 22 05:08:41 UTC 2024
    - 3.5K bytes
    - Viewed (0)
  10. pkg/scheduler/framework/plugins/nodeports/node_ports.go

    		return framework.QueueSkip, nil
    	}
    
    	logger.V(4).Info("the deleted pod and the target pod have any common port(s), returning Queue as deleting this Pod may make the Pod schedulable", "pod", klog.KObj(pod), "deletedPod", klog.KObj(deletedPod))
    	return framework.Queue, nil
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Mar 26 10:53:29 UTC 2024
    - 7.5K bytes
    - Viewed (0)
Back to top