Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 8 of 8 for ContainerType (2.96 sec)

  1. pkg/api/pod/util.go

    func VisitPodSecretNames(pod *api.Pod, visitor Visitor, containerType ContainerType) bool {
    	visitor = skipEmptyNames(visitor)
    	for _, reference := range pod.Spec.ImagePullSecrets {
    		if !visitor(reference.Name) {
    			return false
    		}
    	}
    	VisitContainers(&pod.Spec, containerType, func(c *api.Container, containerType ContainerType) bool {
    		return visitContainerSecretNames(c, visitor)
    	})
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 29 22:40:29 UTC 2024
    - 41.3K bytes
    - Viewed (0)
  2. pkg/kubelet/container/helpers.go

    func GetContainerSpec(pod *v1.Pod, containerName string) *v1.Container {
    	var containerSpec *v1.Container
    	podutil.VisitContainers(&pod.Spec, podutil.AllFeatureEnabledContainers(), func(c *v1.Container, containerType podutil.ContainerType) bool {
    		if containerName == c.Name {
    			containerSpec = c
    			return false
    		}
    		return true
    	})
    	return containerSpec
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:25:43 UTC 2024
    - 14.3K bytes
    - Viewed (0)
  3. pkg/volume/util/util.go

    	devices = sets.New[string]()
    	seLinuxContainerContexts = make(map[string][]*v1.SELinuxOptions)
    
    	podutil.VisitContainers(&pod.Spec, podutil.AllFeatureEnabledContainers(), func(container *v1.Container, containerType podutil.ContainerType) bool {
    		var seLinuxOptions *v1.SELinuxOptions
    		if utilfeature.DefaultFeatureGate.Enabled(features.SELinuxMountReadWriteOncePod) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 31 12:32:15 UTC 2024
    - 28.8K bytes
    - Viewed (0)
  4. pkg/scheduler/framework/types.go

    		InPlacePodVerticalScalingEnabled: utilfeature.DefaultFeatureGate.Enabled(features.InPlacePodVerticalScaling),
    		ContainerFn: func(requests v1.ResourceList, containerType podutil.ContainerType) {
    			non0CPUReq, non0MemReq := schedutil.GetNonzeroRequests(&requests)
    			switch containerType {
    			case podutil.Containers:
    				non0CPU += non0CPUReq
    				non0Mem += non0MemReq
    			case podutil.InitContainers:
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 19:28:17 UTC 2024
    - 36.7K bytes
    - Viewed (0)
  5. pkg/api/pod/util_test.go

    	"k8s.io/utils/pointer"
    )
    
    func TestVisitContainers(t *testing.T) {
    	setAllFeatureEnabledContainersDuringTest := ContainerType(0)
    	testCases := []struct {
    		desc           string
    		spec           *api.PodSpec
    		wantContainers []string
    		mask           ContainerType
    	}{
    		{
    			desc:           "empty podspec",
    			spec:           &api.PodSpec{},
    			wantContainers: []string{},
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 29 22:40:29 UTC 2024
    - 108.8K bytes
    - Viewed (0)
  6. pkg/kubelet/kuberuntime/kuberuntime_manager.go

    		isInBackOff, msg, err := m.doBackOff(pod, spec.container, podStatus, backOff)
    		if isInBackOff {
    			startContainerResult.Fail(err, msg)
    			klog.V(4).InfoS("Backing Off restarting container in pod", "containerType", typeName, "container", spec.container, "pod", klog.KObj(pod))
    			return err
    		}
    
    		metrics.StartedContainersTotal.WithLabelValues(metricLabel).Inc()
    		if sc.HasWindowsHostProcessRequest(pod, spec.container) {
    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/kubelet/kuberuntime/kuberuntime_manager_test.go

    			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
    	})
    
    	fakeRuntime.SetFakeSandboxes([]*apitest.FakePodSandbox{sandbox})
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 14 16:09:17 UTC 2024
    - 96K bytes
    - Viewed (0)
  8. pkg/apis/core/validation/validation_test.go

    			},
    		},
    	}
    
    	for name, tt := range testCases {
    		for _, podOS := range tt.podOSes {
    			for containerType, setContainerStatuses := range containerTypes {
    				t.Run(fmt.Sprintf("[podOS=%v][containerType=%s] %s", podOS, containerType, name), func(t *testing.T) {
    					oldPod := &core.Pod{
    						ObjectMeta: metav1.ObjectMeta{
    							Name:            "foo",
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 29 22:40:29 UTC 2024
    - 857.7K bytes
    - Viewed (0)
Back to top