- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 151 for admitPV (0.18 sec)
-
staging/src/k8s.io/apiserver/pkg/admission/plugin/webhook/mutating/plugin.go
func (a *Plugin) ValidateInitialization() error { if err := a.Webhook.ValidateInitialization(); err != nil { return err } return nil } // Admit makes an admission decision based on the request attributes. func (a *Plugin) Admit(ctx context.Context, attr admission.Attributes, o admission.ObjectInterfaces) error { return a.Webhook.Dispatch(ctx, attr, o)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Aug 20 15:11:00 UTC 2019 - 2.1K bytes - Viewed (0) -
pkg/kubelet/lifecycle/interfaces.go
// 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/cm/topologymanager/policy_none_test.go
}, }, expectedHint: TopologyHint{}, expectedAdmit: true, }, } for _, tc := range tcases { policy := NewNonePolicy() result, admit := policy.Merge(tc.providersHints) if !result.IsEqual(tc.expectedHint) || admit != tc.expectedAdmit { t.Errorf("Test Case: %s: Expected merge hint to be %v, got %v", tc.name, tc.expectedHint, result) } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Feb 03 17:13:28 UTC 2020 - 2.8K bytes - Viewed (0) -
plugin/pkg/admission/nodetaint/admission_test.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Nov 06 04:56:21 UTC 2019 - 3.1K bytes - Viewed (0) -
pkg/kubelet/cm/topologymanager/fake_topology_manager.go
} func (m *fakeManager) RemoveContainer(containerID string) error { klog.InfoS("RemoveContainer", "containerID", containerID) return nil } func (m *fakeManager) Admit(attrs *lifecycle.PodAdmitAttributes) lifecycle.PodAdmitResult { klog.InfoS("Topology Admit Handler") return admission.GetPodAdmitResult(nil)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Aug 02 18:02:07 UTC 2022 - 2.3K bytes - Viewed (0) -
plugin/pkg/admission/limitranger/admission.go
return fmt.Errorf("missing client") } return nil } // Admit admits resources into cluster that do not violate any defined LimitRange in the namespace func (l *LimitRanger) Admit(ctx context.Context, a admission.Attributes, o admission.ObjectInterfaces) (err error) { return l.runLimitFunc(a, l.actions.MutateLimit) } // Validate admits resources into cluster that do not violate any defined LimitRange in the namespace
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Oct 24 13:04:39 UTC 2023 - 25.8K bytes - Viewed (0) -
pkg/kubelet/cm/topologymanager/policy_single_numa_node.go
bestHint := merger.Merge() if bestHint.NUMANodeAffinity.IsEqual(p.numaInfo.DefaultAffinityMask()) { bestHint = TopologyHint{nil, bestHint.Preferred} } admit := p.canAdmitPodResult(&bestHint) return bestHint, admit
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Nov 09 16:52:08 UTC 2022 - 2.5K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/admission/plugin/policy/validating/policy_decision.go
metav1 "k8s.io/apimachinery/pkg/apis/meta/v1" ) type PolicyDecisionAction string const ( ActionAdmit PolicyDecisionAction = "admit" ActionDeny PolicyDecisionAction = "deny" ) type PolicyDecisionEvaluation string const ( EvalAdmit PolicyDecisionEvaluation = "admit" EvalError PolicyDecisionEvaluation = "error" EvalDeny PolicyDecisionEvaluation = "deny" )
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Feb 12 18:58:24 UTC 2024 - 2.6K bytes - Viewed (0) -
plugin/pkg/admission/deny/admission.go
type alwaysDeny struct{} var _ admission.MutationInterface = alwaysDeny{} var _ admission.ValidationInterface = alwaysDeny{} // Admit makes an admission decision based on the request attributes. func (alwaysDeny) Admit(ctx context.Context, a admission.Attributes, o admission.ObjectInterfaces) (err error) { return admission.NewForbidden(a, errors.New("admission control is denying all modifications")) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 16 11:54:27 UTC 2020 - 2.3K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/admission/plugin/webhook/mutating/dispatcher.go
admissionmetrics.Metrics.ObserveWebhook(ctx, hook.Name, time.Since(t), rejected, versionedAttr.Attributes, "admit", int(err.Status.ErrStatus.Code)) default: rejected = true
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 28 08:48:22 UTC 2024 - 19.6K bytes - Viewed (0)