Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 9 of 9 for AllContainers (0.18 sec)

  1. 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)
  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/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)
  4. 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)
  5. pkg/api/pod/util_test.go

    		wantContainers []string
    		mask           ContainerType
    	}{
    		{
    			desc:           "empty podspec",
    			spec:           &api.PodSpec{},
    			wantContainers: []string{},
    			mask:           AllContainers,
    		},
    		{
    			desc: "regular containers",
    			spec: &api.PodSpec{
    				Containers: []api.Container{
    					{Name: "c1"},
    					{Name: "c2"},
    				},
    				InitContainers: []api.Container{
    					{Name: "i1"},
    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. plugin/pkg/admission/noderestriction/admission.go

    	if hasSecrets {
    		return admission.NewForbidden(a, fmt.Errorf("node %q can not create pods that reference secrets", nodeName))
    	}
    	hasConfigMaps := false
    	podutil.VisitPodConfigmapNames(pod, func(name string) (shouldContinue bool) { hasConfigMaps = true; return false }, podutil.AllContainers)
    	if hasConfigMaps {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Mar 07 21:22:55 UTC 2024
    - 23.6K bytes
    - Viewed (0)
  7. plugin/pkg/admission/serviceaccount/admission.go

    		}
    		hasSecrets := false
    		podutil.VisitPodSecretNames(pod, func(name string) bool {
    			hasSecrets = true
    			return false
    		}, podutil.AllContainers)
    		if hasSecrets {
    			return admission.NewForbidden(a, fmt.Errorf("a mirror pod may not reference secrets"))
    		}
    		for _, v := range pod.Spec.Volumes {
    			if proj := v.Projected; proj != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Apr 12 17:49:30 UTC 2024
    - 18.6K bytes
    - Viewed (0)
  8. pkg/kubelet/kuberuntime/kuberuntime_container.go

    // those already exited and dead containers (used for garbage collection).
    func (m *kubeGenericRuntimeManager) getKubeletContainers(ctx context.Context, allContainers bool) ([]*runtimeapi.Container, error) {
    	filter := &runtimeapi.ContainerFilter{}
    	if !allContainers {
    		filter.State = &runtimeapi.ContainerStateValue{
    			State: runtimeapi.ContainerState_CONTAINER_RUNNING,
    		}
    	}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:25:43 UTC 2024
    - 54.7K bytes
    - Viewed (0)
  9. pkg/kube/inject/webhook.go

    type ParsedContainers struct {
    	Containers     []corev1.Container `json:"containers,omitempty"`
    	InitContainers []corev1.Container `json:"initContainers,omitempty"`
    }
    
    func (p ParsedContainers) AllContainers() []corev1.Container {
    	return append(slices.Clone(p.Containers), p.InitContainers...)
    }
    
    // nolint directives: interfacer
    func loadConfig(injectFile, valuesFile string) (*Config, string, error) {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue May 14 17:59:39 UTC 2024
    - 42.2K bytes
    - Viewed (0)
Back to top