Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 151 for admitPV (0.13 sec)

  1. staging/src/k8s.io/apiserver/pkg/endpoints/handlers/fieldmanager/admission.go

    func (admit *managedFieldsValidatingAdmissionController) Handles(operation admission.Operation) bool {
    	return admit.wrap.Handles(operation)
    }
    
    // Admit calls the wrapped admission.Interface if applicable and resets the managedFields to their state before admission if they
    // got modified in an invalid way
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Mar 08 21:44:00 UTC 2023
    - 3.7K bytes
    - Viewed (0)
  2. istioctl/pkg/checkinject/checkinject.go

    				return matched, fmt.Sprintf("%s=%s", me.Key, v)
    			}
    		}
    	}
    	return matched, ""
    }
    
    func extractRevision(wh *admitv1.MutatingWebhookConfiguration) string {
    	return wh.GetLabels()[label.IoIstioRev.Name]
    }
    
    func isIstioWebhook(wh *admitv1.MutatingWebhookConfiguration) bool {
    	for _, w := range wh.Webhooks {
    		if strings.HasSuffix(w.Name, "istio.io") {
    			return true
    		}
    	}
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Sat Apr 13 05:23:38 UTC 2024
    - 9.3K bytes
    - Viewed (0)
  3. staging/src/k8s.io/apiserver/pkg/admission/metrics/metrics_test.go

    		err := h.(admission.MutationInterface).Admit(context.TODO(), admission.NewAttributesRecord(nil, nil, schema.GroupVersionKind{}, test.ns, "", schema.GroupVersionResource{}, "", test.operation, test.options, false, nil), nil)
    		if test.admit && err != nil {
    			t.Errorf("expected admit to succeed, but failed: %v", err)
    			continue
    		} else if !test.admit && err == nil {
    			t.Errorf("expected admit to fail, but it succeeded")
    			continue
    		}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jul 14 17:01:37 UTC 2023
    - 16.9K bytes
    - Viewed (0)
  4. istioctl/pkg/tag/revision.go

    			}
    		}
    	}
    
    	return revisions, nil
    }
    
    func Webhooks(ctx context.Context, client kube.CLIClient) ([]admitv1.MutatingWebhookConfiguration, error) {
    	hooks, err := client.Kube().AdmissionregistrationV1().MutatingWebhookConfigurations().List(ctx, metav1.ListOptions{})
    	if err != nil {
    		return []admitv1.MutatingWebhookConfiguration{}, err
    	}
    	return hooks.Items, nil
    }
    
    func renderWithDefault(s, def string) string {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Sat Jan 28 13:16:05 UTC 2023
    - 4.5K bytes
    - Viewed (0)
  5. staging/src/k8s.io/apiserver/pkg/admission/chain_test.go

    )
    
    type FakeHandler struct {
    	*Handler
    	name                     string
    	admit, admitCalled       bool
    	validate, validateCalled bool
    }
    
    func (h *FakeHandler) Admit(ctx context.Context, a Attributes, o ObjectInterfaces) (err error) {
    	h.admitCalled = true
    	if h.admit {
    		return nil
    	}
    	return fmt.Errorf("Don't admit")
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Aug 20 15:11:00 UTC 2019
    - 5.4K bytes
    - Viewed (0)
  6. plugin/pkg/admission/podnodeselector/admission_test.go

    		ignoreTestNamespaceNodeSelector bool
    		admit                           bool
    		testName                        string
    	}{
    		{
    			defaultNodeSelector:             "",
    			podNodeSelector:                 map[string]string{},
    			mergedNodeSelector:              labels.Set{},
    			ignoreTestNamespaceNodeSelector: true,
    			admit:                           true,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Mar 06 00:00:21 UTC 2024
    - 8K bytes
    - Viewed (0)
  7. pkg/kubelet/lifecycle/predicate.go

    		return PodAdmitResult{
    			Admit:   false,
    			Reason:  "PodOSSelectorNodeLabelDoesNotMatch",
    			Message: "Failed to admit pod as the `kubernetes.io/os` label doesn't match node label",
    		}
    	}
    	if rejectPodAdmissionBasedOnOSField(admitPod) {
    		return PodAdmitResult{
    			Admit:   false,
    			Reason:  "PodOSNotSupported",
    			Message: "Failed to admit pod as the OS field doesn't match node OS",
    		}
    	}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Oct 19 00:47:50 UTC 2023
    - 10.9K bytes
    - Viewed (0)
  8. staging/src/k8s.io/apiserver/pkg/admission/audit_test.go

    	"github.com/stretchr/testify/assert"
    	"github.com/stretchr/testify/require"
    )
    
    // fakeHandler implements Interface
    type fakeHandler struct {
    	// return value of Admit()
    	admit error
    	// annotations add to attributesRecord during Admit() phase
    	admitAnnotations map[string]string
    	// return value of Validate()
    	validate error
    	// annotations add to attributesRecord during Validate() phase
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Jul 03 16:16:51 UTC 2023
    - 5.8K bytes
    - Viewed (0)
  9. pkg/kubelet/cm/topologymanager/scope_container.go

    		},
    	}
    }
    
    func (s *containerScope) Admit(pod *v1.Pod) lifecycle.PodAdmitResult {
    	for _, container := range append(pod.Spec.InitContainers, pod.Spec.Containers...) {
    		bestHint, admit := s.calculateAffinity(pod, &container)
    		klog.InfoS("Best TopologyHint", "bestHint", bestHint, "pod", klog.KObj(pod), "containerName", container.Name)
    
    		if !admit {
    			metrics.TopologyManagerAdmissionErrorsTotal.Inc()
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Apr 14 14:44:24 UTC 2023
    - 2.9K bytes
    - Viewed (0)
  10. plugin/pkg/admission/podtolerationrestriction/admission_test.go

    			err = admissiontesting.WithReinvocationTesting(t, handler).Admit(context.TODO(), admission.NewAttributesRecord(pod, nil, api.Kind("Pod").WithVersion("version"), "testNamespace", namespace.ObjectMeta.Name, api.Resource("pods").WithVersion("version"), "", admission.Create, &metav1.CreateOptions{}, false, nil), nil)
    			if test.admit && err != nil {
    				t.Errorf("Test: %s, expected no error but got: %s", test.testName, err)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Mar 06 00:00:21 UTC 2024
    - 16K bytes
    - Viewed (0)
Back to top