- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 215 for brokers (0.06 sec)
-
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) -
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) -
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) -
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) -
docs/ru/docs/deployment/docker.md
Registered: Sun Dec 28 07:19:09 UTC 2025 - Last Modified: Tue Sep 30 11:24:39 UTC 2025 - 44.7K bytes - Viewed (0) -
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) -
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) -
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) -
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) -
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)