Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for eventratelimitapi (0.19 sec)

  1. plugin/pkg/admission/eventratelimit/apis/eventratelimit/validation/validation_test.go

    		expectedResult: true,
    	}, {
    		name: "valid namespace",
    		config: eventratelimitapi.Configuration{
    			Limits: []eventratelimitapi.Limit{{
    				Type:      "Namespace",
    				Burst:     10,
    				QPS:       2,
    				CacheSize: 100,
    			}},
    		},
    		expectedResult: true,
    	}, {
    		name: "valid user",
    		config: eventratelimitapi.Configuration{
    			Limits: []eventratelimitapi.Limit{{
    				Type:      "User",
    				Burst:     10,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 02 07:48:42 UTC 2023
    - 3.5K bytes
    - Viewed (0)
  2. plugin/pkg/admission/eventratelimit/apis/eventratelimit/validation/validation.go

    import (
    	"k8s.io/apimachinery/pkg/util/validation/field"
    
    	eventratelimitapi "k8s.io/kubernetes/plugin/pkg/admission/eventratelimit/apis/eventratelimit"
    )
    
    var limitTypes = map[eventratelimitapi.LimitType]bool{
    	eventratelimitapi.ServerLimitType:          true,
    	eventratelimitapi.NamespaceLimitType:       true,
    	eventratelimitapi.UserLimitType:            true,
    	eventratelimitapi.SourceAndObjectLimitType: true,
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Sep 01 17:38:03 UTC 2017
    - 2.1K bytes
    - Viewed (0)
  3. plugin/pkg/admission/eventratelimit/limitenforcer.go

    		cache:              underlyingCache,
    	}
    
    	var keyFunc func(admission.Attributes) string
    	switch t := config.Type; t {
    	case eventratelimitapi.NamespaceLimitType:
    		keyFunc = getNamespaceKey
    	case eventratelimitapi.UserLimitType:
    		keyFunc = getUserKey
    	case eventratelimitapi.SourceAndObjectLimitType:
    		keyFunc = getSourceAndObjectKey
    	default:
    		return nil, fmt.Errorf("unknown event rate limit type: %v", t)
    	}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Jul 08 02:31:37 UTC 2021
    - 3.8K bytes
    - Viewed (0)
  4. plugin/pkg/admission/eventratelimit/admission_test.go

    			config := &eventratelimitapi.Configuration{}
    			if tc.serverBurst > 0 {
    				serverLimit := eventratelimitapi.Limit{
    					Type:  eventratelimitapi.ServerLimitType,
    					QPS:   qps,
    					Burst: tc.serverBurst,
    				}
    				config.Limits = append(config.Limits, serverLimit)
    			}
    			if tc.namespaceBurst > 0 {
    				namespaceLimit := eventratelimitapi.Limit{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Sep 17 13:19:08 UTC 2021
    - 15.6K bytes
    - Viewed (0)
  5. plugin/pkg/admission/eventratelimit/config.go

    }
    
    // LoadConfiguration loads the provided configuration.
    func LoadConfiguration(config io.Reader) (*eventratelimitapi.Configuration, error) {
    	// if no config is provided, return a default configuration
    	if config == nil {
    		externalConfig := &eventratelimitv1alpha1.Configuration{}
    		scheme.Default(externalConfig)
    		internalConfig := &eventratelimitapi.Configuration{}
    		if err := scheme.Convert(externalConfig, internalConfig, nil); err != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 08 22:33:50 UTC 2018
    - 2K bytes
    - Viewed (0)
  6. plugin/pkg/admission/eventratelimit/admission.go

    	apierrors "k8s.io/apimachinery/pkg/api/errors"
    	utilerrors "k8s.io/apimachinery/pkg/util/errors"
    	"k8s.io/apiserver/pkg/admission"
    	"k8s.io/client-go/util/flowcontrol"
    	api "k8s.io/kubernetes/pkg/apis/core"
    	eventratelimitapi "k8s.io/kubernetes/plugin/pkg/admission/eventratelimit/apis/eventratelimit"
    	"k8s.io/kubernetes/plugin/pkg/admission/eventratelimit/apis/eventratelimit/validation"
    	"k8s.io/utils/clock"
    )
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Sep 14 15:26:57 UTC 2021
    - 3.6K bytes
    - Viewed (0)
Back to top