Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 395 for podutil (0.13 sec)

  1. cni/pkg/util/podutil.go

    Ben Leggett <******@****.***> 1717175891 -0400
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri May 31 17:18:11 UTC 2024
    - 4.4K bytes
    - Viewed (0)
  2. 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)
  3. pkg/registry/core/pod/strategy.go

    		// as a signal to the caller that the request is being considered.
    		podutil.MarkPodProposedForResize(oldPod, newPod)
    	}
    
    	podutil.DropDisabledPodFields(newPod, oldPod)
    }
    
    // Validate validates a new pod.
    func (podStrategy) Validate(ctx context.Context, obj runtime.Object) field.ErrorList {
    	pod := obj.(*api.Pod)
    	opts := podutil.GetValidationOptionsFromPodSpecAndMeta(&pod.Spec, nil, &pod.ObjectMeta, nil)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Mar 07 17:51:48 UTC 2024
    - 29.8K bytes
    - Viewed (0)
  4. pkg/kubelet/container/helpers.go

    // GetContainerSpec gets the container spec by containerName.
    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)
  5. 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)
  6. pkg/volume/util/nested_volumes.go

    				retval = append(retval, mp[len(myMPSlash):])
    			}
    		}
    		return nil
    	}
    
    	var retErr error
    	podutil.VisitContainers(&pod.Spec, podutil.AllFeatureEnabledContainers(), func(c *v1.Container, containerType podutil.ContainerType) bool {
    		retErr = checkContainer(c)
    		return retErr == nil
    	})
    	if retErr != nil {
    		return nil, retErr
    	}
    
    	return retval, nil
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Oct 18 12:19:17 UTC 2022
    - 4.1K bytes
    - Viewed (0)
  7. pkg/api/v1/resource/helpers.go

    limitations under the License.
    */
    
    package resource
    
    import (
    	"fmt"
    	"math"
    	"strconv"
    	"strings"
    
    	v1 "k8s.io/api/core/v1"
    	"k8s.io/apimachinery/pkg/api/resource"
    
    	podutil "k8s.io/kubernetes/pkg/api/v1/pod"
    )
    
    // PodResourcesOptions controls the behavior of PodRequests and PodLimits.
    type PodResourcesOptions struct {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Oct 26 13:58:16 UTC 2023
    - 16.3K bytes
    - Viewed (0)
  8. pkg/kubelet/status/generate.go

    			continue
    		}
    
    		if containerStatus, ok := podutil.GetContainerStatus(containerStatuses, container.Name); ok {
    			if !containerStatus.Ready {
    				unreadyContainers = append(unreadyContainers, container.Name)
    			}
    		} else {
    			unknownContainers = append(unknownContainers, container.Name)
    		}
    	}
    
    	for _, container := range spec.Containers {
    		if containerStatus, ok := podutil.GetContainerStatus(containerStatuses, container.Name); ok {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Oct 12 15:18:11 UTC 2023
    - 9.8K bytes
    - Viewed (0)
  9. pkg/controller/controller_utils.go

    	}
    	// 3. ready < not ready
    	if podutil.IsPodReady(s[i]) != podutil.IsPodReady(s[j]) {
    		return podutil.IsPodReady(s[i])
    	}
    	// TODO: take availability into account when we push minReadySeconds information from deployment into pods,
    	//       see https://github.com/kubernetes/kubernetes/issues/22065
    	// 4. Been ready for more time < less time < empty time
    	if podutil.IsPodReady(s[i]) && podutil.IsPodReady(s[j]) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jan 12 15:34:44 UTC 2024
    - 47.6K bytes
    - Viewed (0)
  10. pkg/api/testing/backward_compatibility_test.go

    limitations under the License.
    */
    
    package testing
    
    import (
    	"testing"
    
    	v1 "k8s.io/api/core/v1"
    	"k8s.io/apimachinery/pkg/runtime"
    	"k8s.io/apimachinery/pkg/util/validation/field"
    	podutil "k8s.io/kubernetes/pkg/api/pod"
    	"k8s.io/kubernetes/pkg/api/testing/compat"
    	api "k8s.io/kubernetes/pkg/apis/core"
    	_ "k8s.io/kubernetes/pkg/apis/core/install"
    	"k8s.io/kubernetes/pkg/apis/core/validation"
    )
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Mar 01 18:45:58 UTC 2021
    - 3.5K bytes
    - Viewed (0)
Back to top