Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 25 for admitPV (0.19 sec)

  1. istioctl/pkg/tag/generate_test.go

    			Name:   "istio-sidecar-injector",
    			Labels: map[string]string{label.IoIstioRev.Name: "default"},
    		},
    		Webhooks: []admitv1.MutatingWebhook{
    			{
    				Name: fmt.Sprintf("namespace.%s", istioInjectionWebhookSuffix),
    				ClientConfig: admitv1.WebhookClientConfig{
    					Service: &admitv1.ServiceReference{
    						Namespace: "default",
    						Name:      "istiod",
    					},
    					CABundle: []byte("ca"),
    				},
    			},
    			{
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue Jan 16 17:43:49 UTC 2024
    - 12.1K bytes
    - Viewed (0)
  2. plugin/pkg/admission/serviceaccount/admission_test.go

    	err := admissiontesting.WithReinvocationTesting(t, admit).Admit(context.TODO(), attrs, nil)
    	if err == nil {
    		t.Errorf("Expected error for missing service account, got none")
    	}
    }
    
    func TestAutomountsAPIToken(t *testing.T) {
    
    	admit := NewServiceAccount()
    	informerFactory := informers.NewSharedInformerFactory(nil, controller.NoResyncPeriodFunc())
    	admit.SetExternalKubeInformerFactory(informerFactory)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Apr 12 17:49:30 UTC 2024
    - 36.9K bytes
    - Viewed (0)
  3. istioctl/pkg/tag/generate.go

    		return nil, err
    	}
    	if vwh == nil {
    		return whConfig, nil
    	}
    	if whConfig.FailurePolicy == nil {
    		whConfig.FailurePolicy = map[string]*admitv1.FailurePolicyType{}
    	}
    	for _, wh := range vwh.Webhooks {
    		if wh.FailurePolicy != nil && *wh.FailurePolicy == admitv1.Fail {
    			whConfig.FailurePolicy[wh.Name] = nil
    		} else {
    			whConfig.FailurePolicy[wh.Name] = wh.FailurePolicy
    		}
    	}
    	return whConfig, nil
    }
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue Jan 16 17:43:49 UTC 2024
    - 13.2K bytes
    - Viewed (0)
  4. 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)
  5. staging/src/k8s.io/apiserver/pkg/admission/plugin/namespace/lifecycle/admission_test.go

    	if err != nil {
    		t.Errorf("unexpected error initializing handler: %v", err)
    	}
    
    	stopCh := make(chan struct{})
    	defer close(stopCh)
    
    	informerFactory.Start(stopCh)
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Mar 06 00:00:21 UTC 2024
    - 14.2K bytes
    - Viewed (0)
  6. staging/src/k8s.io/apiserver/pkg/admission/plugin/webhook/mutating/plugin_test.go

    			}
    
    			b.ResetTimer()
    			b.RunParallel(func(pb *testing.PB) {
    				for pb.Next() {
    					wh.Admit(context.TODO(), attr, objectInterfaces)
    				}
    			})
    		})
    	}
    }
    
    // TestAdmit tests that MutatingWebhook#Admit works as expected
    func TestAdmit(t *testing.T) {
    	testServer := webhooktesting.NewTestServer(t)
    	testServer.StartTLS()
    	defer testServer.Close()
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Mar 01 06:06:52 UTC 2024
    - 11K bytes
    - Viewed (0)
  7. pkg/kubelet/eviction/eviction_manager.go

    	}
    	return manager, manager
    }
    
    // Admit rejects a pod if its not safe to admit for node stability.
    func (m *managerImpl) Admit(attrs *lifecycle.PodAdmitAttributes) lifecycle.PodAdmitResult {
    	m.RLock()
    	defer m.RUnlock()
    	if len(m.nodeConditions) == 0 {
    		return lifecycle.PodAdmitResult{Admit: true}
    	}
    	// Admit Critical pods even under resource pressure since they are required for system stability.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Mar 27 18:55:56 UTC 2024
    - 24.6K bytes
    - Viewed (0)
  8. 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)
  9. staging/src/k8s.io/apiserver/pkg/endpoints/handlers/patch.go

    			scope.Resource,
    			scope.Subresource,
    			admission.Update,
    			patchToUpdateOptions(options),
    			dryrun.IsDryRun(options.DryRun),
    			userInfo,
    		)
    
    		admit = fieldmanager.NewManagedFieldsValidatingAdmissionController(admit)
    
    		mutatingAdmission, _ := admit.(admission.MutationInterface)
    		createAuthorizerAttributes := authorizer.AttributesRecord{
    			User:            userInfo,
    			ResourceRequest: true,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 28 08:48:22 UTC 2024
    - 28.5K bytes
    - Viewed (0)
  10. staging/src/k8s.io/apiserver/pkg/admission/plugin/webhook/accessors.go

    	// GetValidatingWebhook if the accessor contains a ValidatingWebhook, returns it and true, else returns false.
    	GetValidatingWebhook() (*v1.ValidatingWebhook, bool)
    
    	// GetType returns the type of the accessor (validate or admit)
    	GetType() string
    }
    
    // NewMutatingWebhookAccessor creates an accessor for a MutatingWebhook.
    func NewMutatingWebhookAccessor(uid, configurationName string, h *v1.MutatingWebhook) WebhookAccessor {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 10 22:07:40 UTC 2024
    - 12.4K bytes
    - Viewed (0)
Back to top