- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for admitPod (0.09 sec)
-
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) -
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)