- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 322 for bursty (0.1 sec)
-
guava/src/com/google/common/util/concurrent/SmoothRateLimiter.java
} @Override double coolDownIntervalMicros() { return warmupPeriodMicros / maxPermits; } } /** * This implements a "bursty" RateLimiter, where storedPermits are translated to zero throttling. * The maximum number of permits that can be saved (when the RateLimiter is unused) is defined in
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue Apr 04 09:45:04 UTC 2023 - 19.3K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/SmoothRateLimiter.java
} @Override double coolDownIntervalMicros() { return warmupPeriodMicros / maxPermits; } } /** * This implements a "bursty" RateLimiter, where storedPermits are translated to zero throttling. * The maximum number of permits that can be saved (when the RateLimiter is unused) is defined in
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue Apr 04 09:45:04 UTC 2023 - 19.3K bytes - Viewed (0) -
cmd/kubelet/app/options/options.go
fs.Int32Var(&c.RegistryBurst, "registry-burst", c.RegistryBurst, "Maximum size of a bursty pulls, temporarily allows pulls to burst to this number, while still not exceeding registry-qps. Only used if --registry-qps > 0") fs.Int32Var(&c.EventRecordQPS, "event-qps", c.EventRecordQPS, "QPS to limit event creations. The number must be >= 0. If 0 will use DefaultQPS: 5.")
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 18 07:00:05 UTC 2024 - 41.6K bytes - Viewed (0) -
pkg/kubelet/apis/config/types.go
// registryBurst is the maximum size of bursty pulls, temporarily allows // pulls to burst to this number, while still not exceeding registryPullQPS. // Only used if registryPullQPS > 0. RegistryBurst int32 // eventRecordQPS is the maximum event creations per second. If 0, there // is no limit enforced. EventRecordQPS int32 // eventBurst is the maximum size of a burst of event creations, temporarily
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 05 21:10:42 UTC 2024 - 35.1K bytes - Viewed (0) -
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) -
android/guava-tests/test/com/google/common/util/concurrent/RateLimiterTest.java
int oneSecWorthOfWork = rate; stopwatch.sleepMillis(rate * 1000); limiter.setRate(rate); long burst = measureTotalTimeMillis(limiter, oneSecWorthOfWork, new Random()); // we allow one second worth of work to go in a burst (i.e. take less than a second) assertTrue(burst <= 1000); long afterBurst = measureTotalTimeMillis(limiter, oneSecWorthOfWork, new Random());
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Sep 06 17:04:31 UTC 2023 - 21.6K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/RateLimiterTest.java
int oneSecWorthOfWork = rate; stopwatch.sleepMillis(rate * 1000); limiter.setRate(rate); long burst = measureTotalTimeMillis(limiter, oneSecWorthOfWork, new Random()); // we allow one second worth of work to go in a burst (i.e. take less than a second) assertTrue(burst <= 1000); long afterBurst = measureTotalTimeMillis(limiter, oneSecWorthOfWork, new Random());
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Sep 06 17:04:31 UTC 2023 - 21.6K 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)