Search Options

Results per page
Sort
Preferred Languages
Advance

Results 31 - 40 of 46 for admitPV (0.25 sec)

  1. plugin/pkg/admission/serviceaccount/admission.go

    		return fmt.Errorf("missing client")
    	}
    	if s.serviceAccountLister == nil {
    		return fmt.Errorf("missing serviceAccountLister")
    	}
    	return nil
    }
    
    // Admit verifies if the pod should be admitted
    func (s *Plugin) Admit(ctx context.Context, a admission.Attributes, o admission.ObjectInterfaces) (err error) {
    	if shouldIgnore(a) {
    		return nil
    	}
    	if a.GetOperation() != admission.Create {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Apr 12 17:49:30 UTC 2024
    - 18.6K bytes
    - Viewed (0)
  2. staging/src/k8s.io/apiserver/pkg/registry/rest/rest.go

    // if the hook cannot be completed. A ValidateObjectFunc may NOT transform the provided
    // object.
    type ValidateObjectFunc func(ctx context.Context, obj runtime.Object) error
    
    // ValidateAllObjectFunc is a "admit everything" instance of ValidateObjectFunc.
    func ValidateAllObjectFunc(ctx context.Context, obj runtime.Object) error {
    	return nil
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Mar 20 14:29:25 UTC 2023
    - 18.6K bytes
    - Viewed (0)
  3. docs/es/docs/async.md

    La mayoría de los framework populares de Python existentes (incluidos Flask y Django) se crearon antes de que existieran las nuevas funciones asíncronas en Python. Por lo tanto, las formas en que pueden implementarse admiten la ejecución paralela y una forma más antigua de ejecución asíncrona que no es tan potente como la actual.
    
    Registered: Mon Jun 17 08:32:26 UTC 2024
    - Last Modified: Thu Apr 18 19:53:19 UTC 2024
    - 24.9K bytes
    - Viewed (0)
  4. pkg/kubelet/metrics/metrics.go

    			StabilityLevel: metrics.ALPHA,
    		},
    		[]string{"static"},
    	)
    	// ActivePodCount tracks the count of pods the Kubelet considers as active when deciding to admit a new pod
    	ActivePodCount = metrics.NewGaugeVec(
    		&metrics.GaugeOpts{
    			Subsystem:      KubeletSubsystem,
    			Name:           ActivePodCountKey,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Feb 22 15:13:25 UTC 2024
    - 45.6K bytes
    - Viewed (0)
  5. staging/src/k8s.io/apiserver/pkg/admission/plugin/webhook/validating/plugin_test.go

    				}
    				return
    			}
    			if !test.InitContext {
    				t.Errorf("expected webhook duration to not be initialized")
    				return
    			}
    			if wd.MutatingWebhookTracker.GetLatency() != 0 {
    				t.Errorf("expected admit duration to be equal to 0 got %q", wd.MutatingWebhookTracker.GetLatency())
    			}
    			if wd.ValidatingWebhookTracker.GetLatency() < test.ExpectedDurationMax {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Mar 01 06:06:52 UTC 2024
    - 11.9K bytes
    - Viewed (0)
  6. plugin/pkg/admission/noderestriction/admission.go

    	leaseResource         = coordapi.Resource("leases")
    	csiNodeResource       = storage.Resource("csinodes")
    	resourceSliceResource = resource.Resource("resourceslices")
    )
    
    // Admit checks the admission policy and triggers corresponding actions
    func (p *Plugin) Admit(ctx context.Context, a admission.Attributes, o admission.ObjectInterfaces) error {
    	nodeName, isNode := p.nodeIdentifier.NodeIdentity(a.GetUserInfo())
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Mar 07 21:22:55 UTC 2024
    - 23.6K bytes
    - Viewed (0)
  7. plugin/pkg/admission/runtimeclass/admission_test.go

    			expectError:  true,
    			runtimeClass: newRuntimeClassForTest(true, nil, true, nil),
    		},
    	}
    
    	for _, tc := range tests {
    		t.Run(tc.name, func(t *testing.T) {
    			err := tc.runtimeClass.Admit(context.TODO(), attributes, nil)
    			if tc.expectError {
    				assert.NotEmpty(t, err)
    			} else {
    				assert.Empty(t, err)
    			}
    		})
    	}
    }
    
    func TestValidate(t *testing.T) {
    	tests := []struct {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Mar 17 01:30:14 UTC 2022
    - 17.5K bytes
    - Viewed (0)
  8. staging/src/k8s.io/apiextensions-apiserver/pkg/apiserver/schema/validation.go

    	return ValidateStructuralWithOptions(fldPath, s, ValidationOptions{
    		// This would widen the schema for CRD if set to true, so first few releases will still
    		// not admit any. But it can still be used by libraries and
    		// declarative validation for native types
    		AllowNestedAdditionalProperties:                   false,
    		AllowNestedXValidations:                           false,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon May 20 18:21:31 UTC 2024
    - 14.9K bytes
    - Viewed (0)
  9. staging/src/k8s.io/apiserver/pkg/storage/interfaces.go

    // if the hook cannot be completed. The function may NOT transform the provided
    // object.
    type ValidateObjectFunc func(ctx context.Context, obj runtime.Object) error
    
    // ValidateAllObjectFunc is a "admit everything" instance of ValidateObjectFunc.
    func ValidateAllObjectFunc(ctx context.Context, obj runtime.Object) error {
    	return nil
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Apr 29 07:53:48 UTC 2024
    - 14.8K bytes
    - Viewed (0)
  10. plugin/pkg/admission/priority/admission_test.go

    			"",
    			api.Resource("pods").WithVersion("version"),
    			"",
    			admission.Create,
    			&metav1.CreateOptions{},
    			false,
    			nil,
    		)
    		err := admissiontesting.WithReinvocationTesting(t, ctrl).Admit(context.TODO(), attrs, nil)
    		klog.Infof("Got %v", err)
    
    		if !test.expectError {
    			if err != nil {
    				t.Errorf("Test %q: unexpected error received: %v", test.name, err)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Mar 03 18:43:48 UTC 2022
    - 21.2K bytes
    - Viewed (0)
Back to top