- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 101 for bursty (0.11 sec)
-
pkg/util/async/bounded_frequency_runner.go
// take them internally. // // Runs of the function will have at least minInterval between them (from // completion to next start), except that up to bursts may be allowed. Burst // runs are "accumulated" over time, one per minInterval up to burstRuns total. // This can be used, for example, to mitigate the impact of expensive operations
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Nov 15 09:36:26 UTC 2022 - 9.4K bytes - Viewed (0) -
plugin/pkg/admission/eventratelimit/apis/eventratelimit/validation/validation_test.go
config: eventratelimitapi.Configuration{ Limits: []eventratelimitapi.Limit{{ Type: "Server", Burst: 5, QPS: 1, }, { Type: "Namespace", Burst: 10, QPS: 2, CacheSize: 100, }, { Type: "SourceAndObject", Burst: 25, QPS: 10, CacheSize: 1000, }}, }, expectedResult: true, }, {
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/types.go
// type of limit. The qps and burst fields are used together to determine if // a particular event query is accepted. The qps determines how many queries // are accepted once the burst amount of queries has been exhausted. QPS int32 `json:"qps"` // burst is the burst number of event queries that are allowed for this type // of limit. The qps and burst fields are used together to determine if a
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Sep 01 17:38:03 UTC 2017 - 3.4K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/pkg/client/clientset/clientset/clientset.go
// If config's RateLimiter is not set and QPS and Burst are acceptable, // NewForConfigAndClient will generate a rate-limiter in configShallowCopy. func NewForConfigAndClient(c *rest.Config, httpClient *http.Client) (*Clientset, error) { configShallowCopy := *c if configShallowCopy.RateLimiter == nil && configShallowCopy.QPS > 0 { if configShallowCopy.Burst <= 0 {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 08 21:36:26 UTC 2023 - 4.4K bytes - Viewed (0) -
plugin/pkg/admission/eventratelimit/apis/eventratelimit/validation/validation.go
allowedValues[i] = string(limitType) i++ } allErrs = append(allErrs, field.NotSupported(idxPath.Child("type"), limit.Type, allowedValues)) } if limit.Burst <= 0 { allErrs = append(allErrs, field.Invalid(idxPath.Child("burst"), limit.Burst, "must be positive")) } if limit.QPS <= 0 { allErrs = append(allErrs, field.Invalid(idxPath.Child("qps"), limit.QPS, "must be positive")) }
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/apis/eventratelimit/v1alpha1/zz_generated.conversion.go
} func autoConvert_v1alpha1_Limit_To_eventratelimit_Limit(in *Limit, out *eventratelimit.Limit, s conversion.Scope) error { out.Type = eventratelimit.LimitType(in.Type) out.QPS = in.QPS out.Burst = in.Burst out.CacheSize = in.CacheSize return nil } // Convert_v1alpha1_Limit_To_eventratelimit_Limit is an autogenerated conversion function.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Aug 24 19:47:49 UTC 2021 - 4.5K bytes - Viewed (0) -
plugin/pkg/admission/eventratelimit/apis/eventratelimit/v1alpha1/types.go
// type of limit. The qps and burst fields are used together to determine if // a particular event query is accepted. The qps determines how many queries // are accepted once the burst amount of queries has been exhausted. QPS int32 `json:"qps"` // burst is the burst number of event queries that are allowed for this type // of limit. The qps and burst fields are used together to determine if a
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Sep 01 17:38:03 UTC 2017 - 3.4K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/examples/client-go/pkg/client/clientset/versioned/clientset.go
// If config's RateLimiter is not set and QPS and Burst are acceptable, // NewForConfigAndClient will generate a rate-limiter in configShallowCopy. func NewForConfigAndClient(c *rest.Config, httpClient *http.Client) (*Clientset, error) { configShallowCopy := *c if configShallowCopy.RateLimiter == nil && configShallowCopy.QPS > 0 { if configShallowCopy.Burst <= 0 {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Sep 23 18:26:20 UTC 2022 - 3.6K bytes - Viewed (0) -
pkg/kubelet/images/helpers.go
// pulling based on the given QPS and burst limits. If QPS is zero, defaults // to no throttling. func throttleImagePulling(imageService kubecontainer.ImageService, qps float32, burst int) kubecontainer.ImageService { if qps == 0.0 { return imageService } return &throttledImageService{ ImageService: imageService, limiter: flowcontrol.NewTokenBucketRateLimiter(qps, burst), } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Nov 05 13:02:13 UTC 2022 - 1.6K bytes - Viewed (0) -
staging/src/k8s.io/cli-runtime/pkg/resource/kustomizevisitor.go
yml []byte } // Visit passes the result of a kustomize build to a StreamVisitor. func (v *KustomizeVisitor) Visit(fn VisitorFunc) error { kOpts := krusty.MakeDefaultOptions() kOpts.Reorder = krusty.ReorderOptionLegacy k := krusty.MakeKustomizer(kOpts) m, err := k.Run(v.fSys, v.dirPath) if err != nil { return err } v.yml, err = m.AsYaml() if err != nil { return err }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 14 16:40:28 UTC 2023 - 1.5K bytes - Viewed (0)