- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 54 for admitPod (0.26 sec)
-
pkg/kubelet/apis/podresources/types.go
// GetAllocatableDevices returns information about all the devices known to the manager GetAllocatableDevices() []*podresourcesapi.ContainerDevices } // PodsProvider knows how to provide the pods admitted by the node type PodsProvider interface { GetPods() []*v1.Pod GetPodByName(namespace, name string) (*v1.Pod, bool) } // CPUsProvider knows how to provide the cpus used by the given container
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 14 17:33:04 UTC 2023 - 2.6K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/flowcontrol/metrics/timing_ratio_histogram_test.go
samplingPeriod := time.Nanosecond steppingPeriod := time.Millisecond tro.Set(1) // `dt` is the admitted cumulative difference in fake time // since the start of the test. "admitted" means this is // never allowed to decrease, which matches the designed // toleration for negative monotonic clock changes. var dt time.Duration // `t1` is the current fake time
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jul 13 16:03:06 UTC 2022 - 8.7K bytes - Viewed (0) -
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) -
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) -
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) -
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) -
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) -
plugin/pkg/admission/eventratelimit/admission_test.go
clock.Step(rq.delay) } attributes := attributesForRequest(rq) err = eventratelimit.Validate(context.TODO(), attributes, nil) if rq.accepted != (err == nil) { expectedAction := "admitted" if !rq.accepted { expectedAction = "blocked" } t.Fatalf("%v: Request %v should have been %v: %v", tc.name, rqIndex, expectedAction, err) } if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Sep 17 13:19:08 UTC 2021 - 15.6K bytes - Viewed (0) -
pkg/kubelet/lifecycle/predicate_test.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 01 23:13:50 UTC 2024 - 14.2K bytes - Viewed (0) -
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)