- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 54 for admitPod (0.13 sec)
-
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) -
pkg/kubelet/preemption/preemption.go
// to allow admission of the pod despite its previous failure. func (c *CriticalPodAdmissionHandler) HandleAdmissionFailure(admitPod *v1.Pod, failureReasons []lifecycle.PredicateFailureReason) ([]lifecycle.PredicateFailureReason, error) { if !kubetypes.IsCriticalPod(admitPod) { return failureReasons, nil } // InsufficientResourceError is not a reason to reject a critical pod.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 02 16:53:19 UTC 2023 - 11.5K bytes - Viewed (0) -
plugin/pkg/admission/priority/admission.go
return p.validatePriorityClass(a) } return nil default: return nil } } // admitPod makes sure a new pod does not set spec.Priority field. It also makes sure that the PriorityClassName exists if it is provided and resolves the pod priority from the PriorityClassName. func (p *Plugin) admitPod(a admission.Attributes) error { operation := a.GetOperation() pod, ok := a.GetObject().(*core.Pod) if !ok {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Feb 08 10:11:23 UTC 2022 - 9K bytes - Viewed (0) -
pkg/kubelet/lifecycle/admission_failure_handler_stub.go
return &AdmissionFailureHandlerStub{} } // HandleAdmissionFailure simply passes admission rejection on, with no special handling. func (n *AdmissionFailureHandlerStub) HandleAdmissionFailure(admitPod *v1.Pod, failureReasons []PredicateFailureReason) ([]PredicateFailureReason, error) { return failureReasons, nil
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Jun 21 01:44:54 UTC 2020 - 1.3K bytes - Viewed (0) -
plugin/pkg/admission/imagepolicy/admission.go
Annotations: a.filterAnnotations(pod.Annotations), Namespace: attributes.GetNamespace(), }, } if err := a.admitPod(ctx, pod, attributes, &imageReview); err != nil { return admission.NewForbidden(attributes, err) } return nil } func (a *Plugin) admitPod(ctx context.Context, pod *api.Pod, attributes admission.Attributes, review *v1alpha1.ImageReview) error { cacheKey, err := json.Marshal(review.Spec)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 02 06:05:06 UTC 2023 - 9.8K bytes - Viewed (0) -
plugin/pkg/admission/noderestriction/admission.go
case resourceSliceResource: return p.admitResourceSlice(nodeName, a) default: return nil } } // admitPod allows creating or deleting a pod if it is assigned to the // current node and fulfills related criteria. func (p *Plugin) admitPod(nodeName string, a admission.Attributes) error { switch a.GetOperation() { case admission.Create: return p.admitPodCreate(nodeName, a)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 07 21:22:55 UTC 2024 - 23.6K bytes - Viewed (0) -
pkg/kubelet/lifecycle/interfaces.go
type PodAdmitResult struct { // if true, the pod should be admitted. Admit bool // a brief single-word reason why the pod could not be admitted. Reason string // a brief message explaining why the pod could not be admitted. Message string } // PodAdmitHandler is notified during pod admission. type PodAdmitHandler interface { // Admit evaluates if a pod can be admitted. Admit(attrs *PodAdmitAttributes) PodAdmitResult }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jun 22 17:25:57 UTC 2017 - 4K bytes - Viewed (0) -
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) -
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) -
plugin/pkg/admission/podtolerationrestriction/doc.go
// no conflict, the pod's tolerations are merged with its namespace's // toleration. Resulting pod's tolerations are verified against its // namespace's whitelist of tolerations. If the verification is // successful, the pod is admitted otherwise rejected. If a namespace // does not have associated default or whitelist of tolerations, then // cluster level default or whitelist of tolerations are used instead
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 23 18:00:06 UTC 2019 - 1.5K bytes - Viewed (0)