Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 322 for bursty (0.1 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top