Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for queue_limit (0.04 sec)

  1. docs/bucket/notifications/README.md

    To update the configuration, use `mc admin config get` command to get the current configuration.
    
    ```sh
    $ mc admin config get myminio/ notify_mqtt
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Tue Aug 12 18:20:36 UTC 2025
    - 84.2K bytes
    - Viewed (0)
  2. cmd/testdata/undeleteable-object.tgz

    ion_string","value":""},{"key":"table","value":""},{"key":"queue_dir","value":""},{"key":"queue_limit","value":"0"},{"key":"max_open_connections","value":"2"}]},"notify_redis":{"_":[{"key":"enable","value":"off"},{"key":"format","value":"namespace"},{"key":"address","value":""},{"key":"key","value":""},{"key":"password","value":""},{"key":"user","value":""},{"key":"queue_dir","value":""},{"key":"queue_limit","value":"0"}]},"notify_webhook":{"_":[{"key":"enable","value":"off"},{"key":"endpoint","...
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Apr 26 00:31:12 UTC 2024
    - 8.7M bytes
    - Viewed (0)
  3. samples/crawler/src/main/java/okhttp3/sample/Crawler.java

      private final ConcurrentHashMap<String, AtomicInteger> hostnames = new ConcurrentHashMap<>();
      private final int hostLimit;
    
      public Crawler(OkHttpClient client, int queueLimit, int hostLimit) {
        this.client = client;
        this.queue = new LinkedBlockingQueue<>(queueLimit);
        this.hostLimit = hostLimit;
      }
    
      private void parallelDrainQueue(int threadCount) {
        ExecutorService executor = Executors.newFixedThreadPool(threadCount);
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Wed Jul 23 00:58:06 UTC 2025
    - 5K bytes
    - Viewed (0)
  4. cmd/config-versions.go

    type ConsoleLogger struct {
    	Enable bool `json:"enable"`
    }
    
    // serverConfigV33 is just like version '32', removes clientID from NATS and MQTT, and adds queueDir, queueLimit in all notification targets.
    type serverConfigV33 struct {
    	quick.Config `json:"-"` // ignore interfaces
    
    	Version string `json:"version"`
    
    	// S3 API configuration.
    	Credential auth.Credentials `json:"credential"`
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 2.5K bytes
    - Viewed (0)
Back to top