Search Options

Results per page
Sort
Preferred Languages
Advance

Results 41 - 50 of 215 for brokers (0.06 sec)

  1. cmd/bucket-replication-stats.go

    	sync.RWMutex                 // mutex for Cache
    	mostRecentStatsMu sync.Mutex // mutex for mostRecentStats
    
    	wlock sync.RWMutex // mutex for active workers
    
    	movingAvgTicker *time.Ticker // Ticker for calculating moving averages
    	wTimer          *time.Ticker // ticker for calculating active workers
    	qTimer          *time.Ticker // ticker for calculating queue stats
    }
    
    func (r *ReplicationStats) trackEWMA() {
    	for {
    		select {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Tue Feb 18 16:25:55 UTC 2025
    - 13.6K bytes
    - Viewed (0)
  2. internal/config/heal/help.go

    			Optional:    true,
    			Type:        "int",
    		},
    		config.HelpKV{
    			Key:         DriveWorkers,
    			Description: `the number of workers per drive to heal a new disk replacement` + defaultHelpPostfix(DriveWorkers),
    			Optional:    true,
    			Type:        "int",
    		},
    	}
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Mon Sep 11 21:48:54 UTC 2023
    - 1.8K bytes
    - Viewed (0)
  3. guava/src/com/google/common/collect/AbstractBiMap.java

        inverse.delegate.clear();
        Entry<K, V> broken = null;
        Iterator<Entry<K, V>> itr = this.delegate.entrySet().iterator();
        while (itr.hasNext()) {
          Entry<K, V> entry = itr.next();
          K k = entry.getKey();
          V v = entry.getValue();
          K conflict = inverse.delegate.putIfAbsent(v, k);
          if (conflict != null) {
            broken = entry;
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Mon Sep 22 15:50:50 UTC 2025
    - 14.3K bytes
    - Viewed (0)
  4. docs/es/docs/deployment/docker.md

    Así que, en este caso, **no** querrías tener múltiples workers en el contenedor, por ejemplo, con la opción de línea de comandos `--workers`. Querrías tener solo un **proceso Uvicorn por contenedor** (pero probablemente múltiples contenedores).
    
    Registered: Sun Dec 28 07:19:09 UTC 2025
    - Last Modified: Tue Dec 16 16:33:45 UTC 2025
    - 32K bytes
    - Viewed (0)
  5. docs/ru/docs/deployment/docker.md

    ```{ .dockerfile .annotate }
    FROM python:3.9
    
    WORKDIR /code
    
    COPY ./requirements.txt /code/requirements.txt
    
    RUN pip install --no-cache-dir --upgrade -r /code/requirements.txt
    
    COPY ./app /code/app
    
    # (1)!
    CMD ["fastapi", "run", "app/main.py", "--port", "80", "--workers", "4"]
    ```
    
    Registered: Sun Dec 28 07:19:09 UTC 2025
    - Last Modified: Tue Sep 30 11:24:39 UTC 2025
    - 44.7K bytes
    - Viewed (0)
  6. internal/config/api/help.go

    		config.HelpKV{
    			Key:         apiReplicationMaxWorkers,
    			Description: `set the maximum number of replication workers` + defaultHelpPostfix(apiReplicationMaxWorkers),
    			Optional:    true,
    			Type:        "number",
    		},
    		config.HelpKV{
    			Key:         apiTransitionWorkers,
    			Description: `set the number of transition workers` + defaultHelpPostfix(apiTransitionWorkers),
    			Optional:    true,
    			Type:        "number",
    		},
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 16 08:43:49 UTC 2024
    - 4.4K bytes
    - Viewed (0)
  7. docs/en/docs/tutorial/cookie-params.md

    ///
    
    /// info
    
    To declare cookies, you need to use `Cookie`, because otherwise the parameters would be interpreted as query parameters.
    
    ///
    
    /// info
    
    Have in mind that, as **browsers handle cookies** in special ways and behind the scenes, they **don't** easily allow **JavaScript** to touch them.
    
    Registered: Sun Dec 28 07:19:09 UTC 2025
    - Last Modified: Sat Sep 20 17:49:27 UTC 2025
    - 1.6K bytes
    - Viewed (0)
  8. internal/logger/help.go

    			Optional:    true,
    			Type:        "sentence",
    		},
    	}
    
    	HelpKafka = config.HelpKVS{
    		config.HelpKV{
    			Key:         KafkaBrokers,
    			Description: "comma separated list of Kafka broker addresses",
    			Type:        "csv",
    		},
    		config.HelpKV{
    			Key:         KafkaTopic,
    			Description: "Kafka topic used for bucket notifications",
    			Optional:    true,
    			Type:        "string",
    		},
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Wed Sep 11 22:20:42 UTC 2024
    - 7.4K bytes
    - Viewed (0)
  9. android/guava-testlib/test/com/google/common/testing/EqualsTesterTest.java

        } catch (AssertionFailedError e) {
          assertErrorMessage(e, "bar [group 1, item 2] must be Object#equals to foo [group 1, item 1]");
          return;
        }
        fail("should failed because symmetry is broken");
      }
    
      public void testTransitivityBrokenInEqualityGroup() {
        EqualsTester tester =
            new EqualsTester()
                .addEqualityGroup(
                    named("foo").addPeers("bar", "baz"),
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Wed May 14 19:40:47 UTC 2025
    - 13.1K bytes
    - Viewed (0)
  10. android/guava/src/com/google/common/util/concurrent/AggregateFutureState.java

        // Log after all static init is finished; if an installed logger uses any Futures methods, it
        // shouldn't break in cases where reflection is missing/broken.
        if (thrownReflectionFailure != null) {
          log.get().log(Level.SEVERE, "SafeAtomicHelper is broken!", thrownReflectionFailure);
        }
      }
    
      AggregateFutureState(int remainingFutures) {
        this.remainingField = remainingFutures;
      }
    
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 8.5K bytes
    - Viewed (0)
Back to top