Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 18 for podutil (0.12 sec)

  1. pkg/controller/daemon/daemon_controller.go

    		if ds == nil {
    			return
    		}
    		logger.V(4).Info("Pod updated", "pod", klog.KObj(curPod))
    		dsc.enqueueDaemonSet(ds)
    		changedToReady := !podutil.IsPodReady(oldPod) && podutil.IsPodReady(curPod)
    		// See https://github.com/kubernetes/kubernetes/pull/38076 for more details
    		if changedToReady && ds.Spec.MinReadySeconds > 0 {
    			// Add a second to avoid milliseconds skew in AddAfter.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 51.3K bytes
    - Viewed (0)
  2. pkg/kubelet/kuberuntime/kuberuntime_manager_test.go

    			pod:       pod,
    			container: c,
    			createdAt: fakeCreatedAt,
    			state:     runtimeapi.ContainerState_CONTAINER_RUNNING,
    		}
    	}
    	podutil.VisitContainers(&pod.Spec, podutil.AllFeatureEnabledContainers(), func(c *v1.Container, containerType podutil.ContainerType) bool {
    		containers = append(containers, makeFakeContainer(t, m, newTemplate(c)))
    		return true
    	})
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 14 16:09:17 UTC 2024
    - 96K bytes
    - Viewed (0)
  3. pkg/kubelet/status/status_manager_test.go

    	syncer.SetPodStatus(pod, anotherStatus)
    	verifyUpdates(t, syncer, 1)
    	newStatus := expectPodStatus(t, syncer, pod)
    
    	oldReadyCondition := podutil.GetPodReadyCondition(oldStatus)
    	newReadyCondition := podutil.GetPodReadyCondition(newStatus)
    	if newReadyCondition.LastTransitionTime.IsZero() {
    		t.Errorf("Unexpected: last transition time not set")
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu May 02 16:27:19 UTC 2024
    - 68.1K bytes
    - Viewed (0)
  4. pkg/controller/statefulset/stateful_set_utils_test.go

    			},
    			setUID:        "set",
    			podUID:        "pod",
    			nonController: true,
    		},
    		{
    			name: "set controller",
    			refs: []metav1.OwnerReference{
    				{
    					APIVersion: "apps/v1",
    					Kind:       "Set",
    					Name:       "set",
    					UID:        "set",
    					Controller: ptr.To(true),
    				},
    			},
    			setUID:        "set",
    			podUID:        "pod",
    			nonController: false,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 05 19:06:41 UTC 2024
    - 50.9K bytes
    - Viewed (0)
  5. pkg/kubelet/eviction/helpers.go

    	"k8s.io/apimachinery/pkg/api/resource"
    	utilfeature "k8s.io/apiserver/pkg/util/feature"
    	corev1helpers "k8s.io/component-helpers/scheduling/corev1"
    	"k8s.io/klog/v2"
    	statsapi "k8s.io/kubelet/pkg/apis/stats/v1alpha1"
    	podutil "k8s.io/kubernetes/pkg/api/v1/pod"
    	v1resource "k8s.io/kubernetes/pkg/api/v1/resource"
    	"k8s.io/kubernetes/pkg/features"
    	evictionapi "k8s.io/kubernetes/pkg/kubelet/eviction/api"
    	kubetypes "k8s.io/kubernetes/pkg/kubelet/types"
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Nov 01 18:46:33 UTC 2023
    - 53.6K bytes
    - Viewed (0)
  6. pkg/kubelet/kuberuntime/kuberuntime_manager.go

    			klog.V(4).InfoS("Sandbox does not have metadata", "sandbox", s)
    			continue
    		}
    		podUID := kubetypes.UID(s.Metadata.Uid)
    		if _, ok := pods[podUID]; !ok {
    			pods[podUID] = &kubecontainer.Pod{
    				ID:        podUID,
    				Name:      s.Metadata.Name,
    				Namespace: s.Metadata.Namespace,
    			}
    		}
    		p := pods[podUID]
    		converted, err := m.sandboxToKubeContainer(s)
    		if err != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 22 02:01:31 UTC 2024
    - 64.7K bytes
    - Viewed (0)
  7. pkg/controller/job/job_controller.go

    	batchv1listers "k8s.io/client-go/listers/batch/v1"
    	corelisters "k8s.io/client-go/listers/core/v1"
    	"k8s.io/client-go/tools/cache"
    	"k8s.io/client-go/tools/record"
    	"k8s.io/client-go/util/workqueue"
    	"k8s.io/klog/v2"
    	podutil "k8s.io/kubernetes/pkg/api/v1/pod"
    	"k8s.io/kubernetes/pkg/controller"
    	"k8s.io/kubernetes/pkg/controller/job/metrics"
    	"k8s.io/kubernetes/pkg/controller/job/util"
    	"k8s.io/kubernetes/pkg/features"
    	"k8s.io/utils/clock"
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Jun 10 23:56:37 UTC 2024
    - 77.6K bytes
    - Viewed (0)
  8. pkg/kubelet/pod_workers.go

    // UpdatePod.
    func (p *podWorkers) completeSync(podUID types.UID) {
    	p.podLock.Lock()
    	defer p.podLock.Unlock()
    
    	klog.V(4).InfoS("Pod indicated lifecycle completed naturally and should now terminate", "podUID", podUID)
    
    	status, ok := p.podSyncStatuses[podUID]
    	if !ok {
    		klog.V(4).InfoS("Pod had no status in completeSync, programmer error?", "podUID", podUID)
    		return
    	}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Apr 02 13:22:37 UTC 2024
    - 74.8K bytes
    - Viewed (0)
  9. pkg/volume/csi/csi_mounter_test.go

    	testCases := []struct {
    		name             string
    		podUID           types.UID
    		spec             func(string, []string) *volume.Spec
    		shouldFail       bool
    		exitError        error
    		createAttachment bool
    	}{
    		{
    			name:   "setup with correct persistent volume source should result in finish exit status",
    			podUID: types.UID(fmt.Sprintf("%08X", rand.Uint64())),
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 50.1K bytes
    - Viewed (0)
  10. pkg/kubelet/cm/devicemanager/manager_test.go

    	initCont1Devices := testManager.podDevices.containerDevices(podUID, initCont1, res1.resourceName)
    	initCont2Devices := testManager.podDevices.containerDevices(podUID, initCont2, res1.resourceName)
    	normalCont1Devices := testManager.podDevices.containerDevices(podUID, normalCont1, res1.resourceName)
    	normalCont2Devices := testManager.podDevices.containerDevices(podUID, normalCont2, res1.resourceName)
    	as.Equal(1, initCont1Devices.Len())
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:25:43 UTC 2024
    - 65K bytes
    - Viewed (0)
Back to top