Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 26 for throttling (0.07 sec)

  1. guava/src/com/google/common/util/concurrent/SmoothRateLimiter.java

      /*
       * How is the RateLimiter designed, and why?
       *
       * The primary feature of a RateLimiter is its "stable rate", the maximum rate that it should
       * allow in normal conditions. This is enforced by "throttling" incoming requests as needed. For
       * example, we could compute the appropriate throttle time for an incoming request, and make the
       * calling thread wait for that time.
       *
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Apr 04 09:45:04 UTC 2023
    - 19.3K bytes
    - Viewed (0)
  2. guava/src/com/google/common/util/concurrent/RateLimiter.java

     * }
     * }</pre>
     *
     * <p>It is important to note that the number of permits requested <i>never</i> affects the
     * throttling of the request itself (an invocation to {@code acquire(1)} and an invocation to {@code
     * acquire(1000)} will result in exactly the same throttling, if any), but it affects the throttling
     * of the <i>next</i> request. I.e., if an expensive task arrives at an idle RateLimiter, it will be
    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. internal/bucket/bandwidth/monitor.go

    type bucketThrottle struct {
    	*rate.Limiter
    	NodeBandwidthPerSec int64
    }
    
    // Monitor holds the state of the global bucket monitor
    type Monitor struct {
    	tlock sync.RWMutex // mutex for bucket throttling
    	mlock sync.RWMutex // mutex for bucket measurement
    
    	bucketsThrottle    map[BucketOptions]*bucketThrottle
    	bucketsMeasurement map[BucketOptions]*bucketMeasurement // Buckets with objects in flight
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Feb 19 22:54:46 UTC 2024
    - 6K bytes
    - Viewed (0)
  4. docs/throttle/README.md

    # MinIO Server Throttling Guide [![Slack](https://slack.min.io/slack?type=svg)](https://slack.min.io) [![Docker Pulls](https://img.shields.io/docker/pulls/minio/minio.svg?maxAge=604800)](https://hub.docker.com/r/minio/minio/)
    
    MinIO server allows to throttle incoming requests:
    
    - limit the number of active requests allowed across the cluster
    - limit the wait duration for each request in the queue
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Aug 16 08:43:49 UTC 2024
    - 1.5K bytes
    - Viewed (1)
  5. android/guava/src/com/google/common/util/concurrent/RateLimiter.java

     * }
     * }</pre>
     *
     * <p>It is important to note that the number of permits requested <i>never</i> affects the
     * throttling of the request itself (an invocation to {@code acquire(1)} and an invocation to {@code
     * acquire(1000)} will result in exactly the same throttling, if any), but it affects the throttling
     * of the <i>next</i> request. I.e., if an expensive task arrives at an idle RateLimiter, it will be
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:51:36 UTC 2024
    - 21.9K bytes
    - Viewed (0)
  6. docs/config/README.md

    ```
    KEY:
    api  manage global HTTP API call specific features, such as throttling, authentication types, etc.
    
    ARGS:
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Aug 16 08:43:49 UTC 2024
    - 17.9K bytes
    - Viewed (1)
  7. android/guava-tests/test/com/google/common/util/concurrent/RateLimiterTest.java

        assertEvents(
            "R0.00, R1.38, R1.13, R0.88, R0.63, R0.50, R0.50, R0.50", // #1
            "U4.50", // #2
            "R0.00, R1.38, R1.13", // #3, after that the rate changes
            "R0.88", // #4, this is what the throttling would be with the old rate
            "R0.34, R0.28, R0.25, R0.25", // #5
            "U4.25", // #6
            "R0.00, R0.72, R0.66, R0.59, R0.53, R0.47, R0.41", // #7
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Oct 21 14:28:19 UTC 2024
    - 21.8K bytes
    - Viewed (0)
  8. guava-tests/test/com/google/common/util/concurrent/RateLimiterTest.java

        assertEvents(
            "R0.00, R1.38, R1.13, R0.88, R0.63, R0.50, R0.50, R0.50", // #1
            "U4.50", // #2
            "R0.00, R1.38, R1.13", // #3, after that the rate changes
            "R0.88", // #4, this is what the throttling would be with the old rate
            "R0.34, R0.28, R0.25, R0.25", // #5
            "U4.25", // #6
            "R0.00, R0.72, R0.66, R0.59, R0.53, R0.47, R0.41", // #7
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Oct 21 14:28:19 UTC 2024
    - 21.8K bytes
    - Viewed (0)
  9. cmd/api-router.go

    	noGZS3HFlag = 1 << iota
    
    	// when provided, enables only tracing of headers. Otherwise, both headers
    	// and body are traced.
    	traceHdrsS3HFlag
    
    	// when provided, disables throttling via the `maxClients` middleware.
    	noThrottleS3HFlag
    )
    
    func (h s3HFlag) has(flag s3HFlag) bool {
    	// Use bitwise-AND and check if the result is non-zero.
    	return h&flag != 0
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Aug 13 15:25:16 UTC 2024
    - 23.1K bytes
    - Viewed (0)
  10. cmd/globals.go

    	globalLifecycleSys       *LifecycleSys
    	globalBucketSSEConfigSys *BucketSSEConfigSys
    	globalBucketTargetSys    *BucketTargetSys
    	// globalAPIConfig controls S3 API requests throttling,
    	// healthCheck readiness deadlines and cors settings.
    	globalAPIConfig = apiConfig{listQuorum: "strict", rootAccess: true}
    
    	globalStorageClass storageclass.Config
    
    	globalAuthNPlugin *idplugin.AuthNPlugin
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Sep 03 18:23:41 UTC 2024
    - 16.2K bytes
    - Viewed (0)
Back to top