Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 198 for limiter (0.21 sec)

  1. android/guava-tests/test/com/google/common/util/concurrent/RateLimiterTest.java

        limiter.acquire(Integer.MAX_VALUE / 4);
        limiter.acquire(Integer.MAX_VALUE / 2);
        limiter.acquire(Integer.MAX_VALUE);
        assertEvents("R0.00", "R0.00", "R0.00");
    
        limiter.setRate(1.0);
        limiter.acquire();
        limiter.acquire();
        limiter.acquire();
        assertEvents("R0.00", "R1.00", "R1.00");
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Oct 21 14:28:19 UTC 2024
    - 21.8K bytes
    - Viewed (0)
  2. guava-tests/test/com/google/common/util/concurrent/RateLimiterTest.java

        limiter.acquire(Integer.MAX_VALUE / 4);
        limiter.acquire(Integer.MAX_VALUE / 2);
        limiter.acquire(Integer.MAX_VALUE);
        assertEvents("R0.00", "R0.00", "R0.00");
    
        limiter.setRate(1.0);
        limiter.acquire();
        limiter.acquire();
        limiter.acquire();
        assertEvents("R0.00", "R1.00", "R1.00");
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Oct 21 14:28:19 UTC 2024
    - 21.8K bytes
    - Viewed (0)
  3. cni/pkg/install/install.go

    		// Setup the limiter to once every 5s. We don't actually limit to only 1/5, this is just to use it to keep track
    		// of whether we got a lot of requests
    		limiter: rate.NewLimiter(rate.Limit(0.2), 1),
    		hits:    0,
    		in:      in,
    	}
    }
    
    func (i *installationThrottle) Throttle(ctx context.Context) {
    	res := i.limiter.Reserve()
    	// Slightly weird usage of the limiter, as we are not strictly using it for limiting
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Fri Aug 09 21:33:51 UTC 2024
    - 13.5K bytes
    - Viewed (0)
  4. guava/src/com/google/common/util/concurrent/RateLimiter.java

       * spread over each second. When the incoming request rate exceeds {@code permitsPerSecond} the
       * rate limiter will release one permit every {@code (1.0 / permitsPerSecond)} seconds. When the
       * rate limiter is unused, bursts of up to {@code permitsPerSecond} permits will be allowed, with
       * subsequent requests being smoothly limited at the stable rate of {@code permitsPerSecond}.
       *
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:51:36 UTC 2024
    - 21.6K bytes
    - Viewed (0)
  5. android/guava/src/com/google/common/util/concurrent/RateLimiter.java

       * spread over each second. When the incoming request rate exceeds {@code permitsPerSecond} the
       * rate limiter will release one permit every {@code (1.0 / permitsPerSecond)} seconds. When the
       * rate limiter is unused, bursts of up to {@code permitsPerSecond} permits will be allowed, with
       * subsequent requests being smoothly limited at the stable rate of {@code permitsPerSecond}.
       *
    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/fr/docs/advanced/path-operation-advanced-configuration.md

    ```Python hl_lines="6"
    {!../../docs_src/path_operation_advanced_configuration/tutorial003.py!}
    ```
    
    ## Description avancée de docstring
    
    Vous pouvez limiter le texte utilisé de la docstring d'une *fonction de chemin* qui sera affiché sur OpenAPI.
    
    L'ajout d'un `\f` (un caractère d'échappement "form feed") va permettre à **FastAPI** de tronquer la sortie utilisée pour OpenAPI à ce stade.
    
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Sun Oct 06 20:36:54 UTC 2024
    - 8K bytes
    - Viewed (0)
  7. docs/fr/README.md

    .org/14.17/admin/fileconfig-guide.html), ou un [Data Store](https://fess.codelibs.org/14.17/admin/dataconfig-guide.html) (comme un fichier CSV ou une base de données). De nombreux formats de fichiers sont pris en charge, y compris (mais sans s'y limiter) : Microsoft Office, PDF, et zip.
    
    *[Fess Site Search](https://github.com/codelibs/fess-site-search)* est une alternative gratuite à [Google Site Search](https://enterprise.google.com/search/products/gss.html). Pour plus de détails, consultez...
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Sat Oct 12 07:19:47 UTC 2024
    - 7.9K bytes
    - Viewed (0)
  8. CHANGELOG/CHANGELOG-1.27.md

    - The mount-utils mounter now provides an option to limit the number of concurrent format operations. ([#115379](https://github.com/kubernetes/...
    Registered: Fri Nov 01 09:05:11 UTC 2024
    - Last Modified: Wed Jul 17 07:48:22 UTC 2024
    - 466.3K bytes
    - Viewed (1)
  9. cmd/erasure-server-pool.go

    		}
    
    		// Default is recursive, if delimiter is set then list non recursive.
    		objects := merged.fileInfos(bucket, prefix, delimiter)
    		loi.IsTruncated = err == nil && len(objects) > 0
    		if limitTo > 0 && len(objects) > limitTo {
    			objects = objects[:limitTo]
    			loi.IsTruncated = true
    		}
    		for _, obj := range objects {
    			if obj.IsDir && obj.ModTime.IsZero() && delimiter != "" {
    				// Only add each once.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Sep 29 22:40:36 UTC 2024
    - 89.8K bytes
    - Viewed (0)
  10. cmd/generic-handlers.go

    				usersize += length
    				break
    			}
    		}
    		if usersize > maxUserDataSize || size > maxHeaderSize {
    			return true
    		}
    	}
    	return false
    }
    
    // Limits body and header to specific allowed maximum limits as per S3/MinIO API requirements.
    func setRequestLimitMiddleware(h http.Handler) http.Handler {
    	return http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 29 18:10:04 UTC 2024
    - 20.5K bytes
    - Viewed (0)
Back to top