Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 20 for irate (0.04 sec)

  1. android/guava/src/com/google/common/util/concurrent/RateLimiter.java

     * <p>Rate limiters are often used to restrict the rate at which some physical or logical resource
     * is accessed. This is in contrast to {@link java.util.concurrent.Semaphore} which restricts the
     * number of concurrent accesses instead of the rate (note though that concurrency and rate are
     * closely related, e.g. see <a href="http://en.wikipedia.org/wiki/Little%27s_law">Little's
     * Law</a>).
     *
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:51:36 UTC 2024
    - 21.9K bytes
    - Viewed (0)
  2. guava/src/com/google/common/util/concurrent/RateLimiter.java

     * <p>Rate limiters are often used to restrict the rate at which some physical or logical resource
     * is accessed. This is in contrast to {@link java.util.concurrent.Semaphore} which restricts the
     * number of concurrent accesses instead of the rate (note though that concurrency and rate are
     * closely related, e.g. see <a href="http://en.wikipedia.org/wiki/Little%27s_law">Little's
     * Law</a>).
     *
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:51:36 UTC 2024
    - 21.6K bytes
    - Viewed (0)
  3. android/guava-tests/test/com/google/common/util/concurrent/RateLimiterTest.java

       * we change the rate.
       */
      public void testWeNeverGetABurstMoreThanOneSec() {
        RateLimiter limiter = RateLimiter.create(1.0, stopwatch);
        int[] rates = {1000, 1, 10, 1000000, 10, 1};
        for (int rate : rates) {
          int oneSecWorthOfWork = rate;
          stopwatch.sleepMillis(rate * 1000);
          limiter.setRate(rate);
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Oct 21 14:28:19 UTC 2024
    - 21.8K bytes
    - Viewed (0)
  4. guava-tests/test/com/google/common/util/concurrent/RateLimiterTest.java

       * we change the rate.
       */
      public void testWeNeverGetABurstMoreThanOneSec() {
        RateLimiter limiter = RateLimiter.create(1.0, stopwatch);
        int[] rates = {1000, 1, 10, 1000000, 10, 1};
        for (int rate : rates) {
          int oneSecWorthOfWork = rate;
          stopwatch.sleepMillis(rate * 1000);
          limiter.setRate(rate);
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Oct 21 14:28:19 UTC 2024
    - 21.8K bytes
    - Viewed (0)
  5. cmd/bucket-stats.go

    	BandWidthLimitInBytesPerSecond int64 `json:"limitInBits"`
    	// current bandwidth reported
    	CurrentBandwidthInBytesPerSecond float64 `json:"currentBandwidth"`
    	// transfer rate for large uploads
    	XferRateLrg *XferStats `json:"-" msg:"lt"`
    	// transfer rate for small uploads
    	XferRateSml *XferStats `json:"-" msg:"st"`
    
    	// Deprecated fields
    	// Pending size in bytes
    	PendingSize int64 `json:"pendingReplicationSize"`
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Sep 12 11:39:51 UTC 2024
    - 13.4K bytes
    - Viewed (0)
  6. istioctl/pkg/cli/context.go

    	rc, err := kube.DefaultRestConfig(kubeconfig, configContext, func(config *rest.Config) {
    		// We are running a one-off command locally, so we don't need to worry too much about rate limiting
    		// Bumping this up greatly decreases install time
    		config.QPS = 50
    		config.Burst = 100
    		config.Impersonate = impersonateConfig
    	})
    	if err != nil {
    		return nil, err
    	}
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Oct 23 19:31:32 UTC 2024
    - 8.9K bytes
    - Viewed (0)
  7. SECURITY.md

    we don't consider this as a vulnerability, given that models can exhaust
    resources in many different ways and solutions exist to prevent this from
    happening (e.g., rate limits, ACLs, monitors to restart broken servers).
    
    ### Model sharing
    
    If the multitenant design allows sharing models, make sure that tenants and
    Registered: Tue Nov 05 12:39:12 UTC 2024
    - Last Modified: Wed Oct 16 16:10:43 UTC 2024
    - 9.6K bytes
    - Viewed (0)
  8. guava/src/com/google/common/util/concurrent/AbstractScheduledService.java

     * the life cycle methods.
     *
     * <h3>Usage Example</h3>
     *
     * <p>Here is a sketch of a service which crawls a website and uses the scheduling capabilities to
     * rate limit itself.
     *
     * <pre>{@code
     * class CrawlingService extends AbstractScheduledService {
     *   private Set<Uri> visited;
     *   private Queue<Uri> toCrawl;
     *   protected void startUp() throws Exception {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 25 16:22:21 UTC 2024
    - 27.8K bytes
    - Viewed (0)
  9. src/bytes/buffer.go

    	// we allocate buffers rounded up to the closest size class.
    	c := len(b) + n // ensure enough space for n elements
    	if c < 2*cap(b) {
    		// The growth rate has historically always been 2x. In the future,
    		// we could rely purely on append to determine the growth rate.
    		c = 2 * cap(b)
    	}
    	b2 := append([]byte(nil), make([]byte, c)...)
    	i := copy(b2, b)
    	return b2[:i]
    }
    
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Tue Oct 29 16:47:05 UTC 2024
    - 15.7K bytes
    - Viewed (0)
  10. cmd/api-errors.go

    		Code:           "SlowDownRead",
    		Description:    "Resource requested is unreadable, please reduce your request rate",
    		HTTPStatusCode: http.StatusServiceUnavailable,
    	},
    	ErrSlowDownWrite: {
    		Code:           "SlowDownWrite",
    		Description:    "Resource requested is unwritable, please reduce your request rate",
    		HTTPStatusCode: http.StatusServiceUnavailable,
    	},
    	ErrMaxVersionsExceeded: {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 01 22:13:18 UTC 2024
    - 92.1K bytes
    - Viewed (0)
Back to top