Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 15 for AllContainers (0.28 sec)

  1. pkg/apis/core/v1/helper/qos/qos.go

    	requests := v1.ResourceList{}
    	limits := v1.ResourceList{}
    	zeroQuantity := resource.MustParse("0")
    	isGuaranteed := true
    	allContainers := []v1.Container{}
    	allContainers = append(allContainers, pod.Spec.Containers...)
    	allContainers = append(allContainers, pod.Spec.InitContainers...)
    	for _, container := range allContainers {
    		// process requests
    		for name, quantity := range container.Resources.Requests {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Aug 08 04:01:46 UTC 2023
    - 3.5K bytes
    - Viewed (0)
  2. pkg/apis/core/helper/qos/qos.go

    	isGuaranteed := true
    	// note, ephemeral containers are not considered for QoS as they cannot define resources
    	allContainers := []core.Container{}
    	allContainers = append(allContainers, pod.Spec.Containers...)
    	allContainers = append(allContainers, pod.Spec.InitContainers...)
    	for _, container := range allContainers {
    		// process requests
    		for name, quantity := range container.Resources.Requests {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Aug 08 04:01:46 UTC 2023
    - 3.7K bytes
    - Viewed (0)
  3. pkg/api/v1/pod/util.go

    	EphemeralContainers
    )
    
    // AllContainers specifies that all containers be visited
    const AllContainers ContainerType = InitContainers | Containers | EphemeralContainers
    
    // AllFeatureEnabledContainers returns a ContainerType mask which includes all container
    // types except for the ones guarded by feature gate.
    func AllFeatureEnabledContainers() ContainerType {
    	return AllContainers
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Feb 24 17:18:04 UTC 2023
    - 13.2K bytes
    - Viewed (0)
  4. pkg/api/pod/util.go

    	EphemeralContainers
    )
    
    // AllContainers specifies that all containers be visited
    const AllContainers ContainerType = (InitContainers | Containers | EphemeralContainers)
    
    // AllFeatureEnabledContainers returns a ContainerType mask which includes all container
    // types except for the ones guarded by feature gate.
    func AllFeatureEnabledContainers() ContainerType {
    	return AllContainers
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 29 22:40:29 UTC 2024
    - 41.3K bytes
    - Viewed (0)
  5. pkg/kubelet/cm/cpumanager/cpu_manager.go

    			failure = append(failure, reconciledContainer{pod.Name, "", ""})
    			continue
    		}
    
    		allContainers := pod.Spec.InitContainers
    		allContainers = append(allContainers, pod.Spec.Containers...)
    		for _, container := range allContainers {
    			containerID, err := findContainerIDByName(&pstatus, container.Name)
    			if err != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 03 16:26:09 UTC 2023
    - 19.9K bytes
    - Viewed (0)
  6. pkg/security/apparmor/validate.go

    	if !isRequired(pod) {
    		return nil
    	}
    
    	if v.ValidateHost() != nil {
    		return v.validateHostErr
    	}
    
    	var retErr error
    	podutil.VisitContainers(&pod.Spec, podutil.AllContainers, func(container *v1.Container, containerType podutil.ContainerType) bool {
    		profile := GetProfile(pod, container)
    		if profile == nil {
    			return true
    		}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Mar 05 20:22:50 UTC 2024
    - 3.1K bytes
    - Viewed (0)
  7. pkg/kube/inject/app_probe.go

    				return nil
    			}
    			*probePort = intstr.FromInt32(port)
    		} else if probePort.IntVal == targetPort {
    			// Already is rewritten
    			return nil
    		}
    		return p
    	}
    	for _, c := range allContainers(pod) {
    		if c.Name == ProxyContainerName {
    			continue
    		}
    		readyz, livez, startupz := status.FormatProberURL(c.Name)
    		portMap := map[string]int32{}
    		for _, p := range c.Ports {
    			if p.Name != "" {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri Aug 04 15:06:24 UTC 2023
    - 8.4K bytes
    - Viewed (0)
  8. pkg/security/apparmor/helpers.go

    		pod.Spec.SecurityContext.AppArmorProfile.Type != v1.AppArmorProfileTypeUnconfined {
    		return true
    	}
    
    	inUse := !podutil.VisitContainers(&pod.Spec, podutil.AllContainers, func(c *v1.Container, _ podutil.ContainerType) bool {
    		if c.SecurityContext != nil && c.SecurityContext.AppArmorProfile != nil &&
    			c.SecurityContext.AppArmorProfile.Type != v1.AppArmorProfileTypeUnconfined {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Mar 06 18:46:32 UTC 2024
    - 3.5K bytes
    - Viewed (0)
  9. pkg/api/v1/pod/util_test.go

    		wantContainers []string
    		mask           ContainerType
    	}{
    		{
    			desc:           "empty podspec",
    			spec:           &v1.PodSpec{},
    			wantContainers: []string{},
    			mask:           AllContainers,
    		},
    		{
    			desc: "regular containers",
    			spec: &v1.PodSpec{
    				Containers: []v1.Container{
    					{Name: "c1"},
    					{Name: "c2"},
    				},
    				InitContainers: []v1.Container{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Sep 25 11:04:08 UTC 2023
    - 32.1K bytes
    - Viewed (0)
  10. pkg/kubelet/pleg/generic.go

    	for pid := range g.podRecords {
    		oldPod := g.podRecords.getOld(pid)
    		pod := g.podRecords.getCurrent(pid)
    		// Get all containers in the old and the new pod.
    		allContainers := getContainersFromPods(oldPod, pod)
    		for _, container := range allContainers {
    			events := computeEvents(oldPod, pod, &container.ID)
    			for _, e := range events {
    				updateEvents(eventsByPodID, e)
    			}
    		}
    	}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:25:43 UTC 2024
    - 19.3K bytes
    - Viewed (0)
Back to top