Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 23 for admitPV (0.23 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. pkg/kubelet/nodeshutdown/nodeshutdown_manager_linux_test.go

    				assert.NoError(t, manager.ShutdownStatus(), "expected that manager does not return error since shutdown is not active")
    				assert.Equal(t, manager.Admit(nil).Admit, true)
    
    				// Send fake shutdown event
    				select {
    				case fakeShutdownChan <- true:
    				case <-time.After(1 * time.Second):
    					t.Fatal()
    				}
    
    				// Wait for all the pods to be killed
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 29.8K bytes
    - Viewed (0)
  10. android/guava/src/com/google/common/graph/AbstractNetwork.java

     * this class rather than implement {@link Network} directly.
     *
     * <p>The methods implemented in this class should not be overridden unless the subclass admits a
     * more efficient implementation.
     *
     * @author James Sexton
     * @param <N> Node parameter type
     * @param <E> Edge parameter type
     * @since 20.0
     */
    @Beta
    @ElementTypesAreNonnullByDefault
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Wed Mar 13 18:17:09 UTC 2024
    - 10.1K bytes
    - Viewed (0)
Back to top