Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 456 for admitted (0.12 sec)

  1. pkg/kubelet/runonce.go

    	ch := make(chan RunPodResult)
    	admitted := []*v1.Pod{}
    	for _, pod := range pods {
    		// Check if we can admit the pod.
    		if ok, reason, message := kl.canAdmitPod(admitted, pod); !ok {
    			kl.rejectPod(pod, reason, message)
    			results = append(results, RunPodResult{pod, nil})
    			continue
    		}
    
    		admitted = append(admitted, pod)
    		go func(pod *v1.Pod) {
    			err := kl.runPod(ctx, pod, retryDelay)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Aug 04 06:56:50 UTC 2023
    - 5.9K bytes
    - Viewed (0)
  2. plugin/pkg/admission/namespace/exists/admission_test.go

    		Spec: api.PodSpec{
    			Volumes:    []api.Volume{{Name: "vol"}},
    			Containers: []api.Container{{Name: "ctr", Image: "image"}},
    		},
    	}
    }
    
    // TestAdmissionNamespaceExists verifies pod is admitted only if namespace exists.
    func TestAdmissionNamespaceExists(t *testing.T) {
    	namespace := "test"
    	mockClient := newMockClientForTest([]string{namespace})
    	handler, informerFactory, err := newHandlerForTest(mockClient)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Mar 06 00:00:21 UTC 2024
    - 4.4K bytes
    - Viewed (0)
  3. staging/src/k8s.io/apiserver/pkg/admission/plugin/namespace/lifecycle/admission_test.go

    	if err != nil {
    		t.Error(err)
    	}
    }
    
    // TestAdmissionNamespaceDoesNotExist verifies pod is not admitted if namespace does not exist.
    func TestAdmissionNamespaceDoesNotExist(t *testing.T) {
    	namespace := "test"
    	mockClient := newMockClientForTest(map[string]v1.NamespacePhase{})
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Mar 06 00:00:21 UTC 2024
    - 14.2K bytes
    - Viewed (0)
  4. pkg/kubelet/lifecycle/predicate.go

    		return PodAdmitResult{
    			Admit:   false,
    			Reason:  "InvalidNodeInfo",
    			Message: "Kubelet cannot get node info.",
    		}
    	}
    	admitPod := attrs.Pod
    
    	// perform the checks that preemption will not help first to avoid meaningless pod eviction
    	if rejectPodAdmissionBasedOnOSSelector(admitPod, node) {
    		return PodAdmitResult{
    			Admit:   false,
    			Reason:  "PodOSSelectorNodeLabelDoesNotMatch",
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Oct 19 00:47:50 UTC 2023
    - 10.9K bytes
    - Viewed (0)
  5. pkg/kubelet/kubelet.go

    }
    
    // canAdmitPod determines if a pod can be admitted, and gives a reason if it
    // cannot. "pod" is new pod, while "pods" are all admitted pods
    // The function returns a boolean value indicating whether the pod
    // can be admitted, a brief single-word reason and a message explaining why
    // the pod cannot be admitted.
    func (kl *Kubelet) canAdmitPod(pods []*v1.Pod, pod *v1.Pod) (bool, string, string) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 14 16:09:17 UTC 2024
    - 126.1K bytes
    - Viewed (0)
  6. pkg/kubelet/lifecycle/handlers.go

    		io.Copy(io.Discard, &io.LimitedReader{R: resp.Body, N: maxRespBodyLength})
    	}
    }
    
    // NewAppArmorAdmitHandler returns a PodAdmitHandler which is used to evaluate
    // if a pod can be admitted from the perspective of AppArmor.
    func NewAppArmorAdmitHandler(validator apparmor.Validator) PodAdmitHandler {
    	return &appArmorAdmitHandler{
    		Validator: validator,
    	}
    }
    
    type appArmorAdmitHandler struct {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Feb 19 11:40:52 UTC 2024
    - 8.2K bytes
    - Viewed (0)
  7. common-protos/k8s.io/api/admissionregistration/v1beta1/generated.proto

      //
      // IfNeeded: the webhook will be called at least one additional time as part of the admission evaluation
      // if the object being admitted is modified by other admission plugins after the initial webhook call.
      // Webhooks that specify this option *must* be idempotent, able to process objects they previously admitted.
      // Note:
      // * the number of additional invocations is not guaranteed to be exactly one.
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon Mar 11 18:43:24 UTC 2024
    - 22.6K bytes
    - Viewed (0)
  8. common-protos/k8s.io/api/admissionregistration/v1/generated.proto

      //
      // IfNeeded: the webhook will be called at least one additional time as part of the admission evaluation
      // if the object being admitted is modified by other admission plugins after the initial webhook call.
      // Webhooks that specify this option *must* be idempotent, able to process objects they previously admitted.
      // Note:
      // * the number of additional invocations is not guaranteed to be exactly one.
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon Mar 11 18:43:24 UTC 2024
    - 24.4K bytes
    - Viewed (0)
  9. pkg/kubelet/lifecycle/predicate_test.go

    			expectRejection: true,
    		},
    		{
    			name:            "No label selector on the pod, should be admitted",
    			pod:             &v1.Pod{},
    			node:            &v1.Node{Spec: v1.NodeSpec{}, ObjectMeta: metav1.ObjectMeta{Labels: map[string]string{v1.LabelOSStable: "dummyOS"}}},
    			expectRejection: false,
    		},
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Mar 01 23:13:50 UTC 2024
    - 14.2K bytes
    - Viewed (0)
  10. pkg/apis/admissionregistration/types.go

    	//
    	// IfNeeded: the webhook will be called at least one additional time as part of the admission evaluation
    	// if the object being admitted is modified by other admission plugins after the initial webhook call.
    	// Webhooks that specify this option *must* be idempotent, and hence able to process objects they previously admitted.
    	// Note:
    	// * the number of additional invocations is not guaranteed to be exactly one.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Feb 29 20:14:19 UTC 2024
    - 52.6K bytes
    - Viewed (0)
Back to top