- Sort Score
- Result 10 results
- Languages All
Results 1 - 6 of 6 for eventratelimitapi (0.19 sec)
-
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) -
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) -
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) -
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) -
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) -
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)