- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 215 for brokers (0.13 sec)
-
internal/config/ilm/help.go
transitionWorkers = "transition_workers" expirationWorkers = "expiration_workers" // EnvILMTransitionWorkers env variable to configure number of transition workers EnvILMTransitionWorkers = "MINIO_ILM_TRANSITION_WORKERS" // EnvILMExpirationWorkers env variable to configure number of expiration workers EnvILMExpirationWorkers = "MINIO_ILM_EXPIRATION_WORKERS" ) var ( defaultHelpPostfix = func(key string) string {
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Thu May 30 08:14:58 UTC 2024 - 1.8K bytes - Viewed (0) -
docs/pt/docs/deployment/docker.md
E se você precisar ter múltiplos workers, você pode simplesmente usar a opção de linha de comando `--workers`. /// note | Detalhes Técnicos A imagem Docker foi criada quando o Uvicorn não suportava gerenciar e reiniciar workers mortos, então era necessário usar o Gunicorn com o Uvicorn, o que adicionava bastante complexidade, apenas para que o Gunicorn gerenciasse e reiniciasse os processos workers do Uvicorn.
Registered: Sun Dec 28 07:19:09 UTC 2025 - Last Modified: Wed Nov 12 16:23:57 UTC 2025 - 32.1K bytes - Viewed (0) -
internal/config/errors.go
"Invalid value for replication workers", "", "MINIO_API_REPLICATION_WORKERS: should be > 0", ) ErrInvalidTransitionWorkersValue = newErrFn( "Invalid value for transition workers", "", "MINIO_API_TRANSITION_WORKERS: should be >= GOMAXPROCS/2", ) ErrInvalidBatchKeyRotationWorkersWait = newErrFn( "Invalid value for batch key rotation workers wait", "Please input a non-negative duration",
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Tue Aug 12 18:20:36 UTC 2025 - 9.4K bytes - Viewed (0) -
cmd/data-scanner_test.go
t.Run(fmt.Sprintf("TestApplyNewerNoncurrentVersionsLimit-%d", i), func(t *testing.T) { workers := []chan expiryOp{make(chan expiryOp)} es.workers.Store(&workers) workerReady := make(chan struct{}) var wg sync.WaitGroup wg.Add(1) var gotExpired []ObjectToDelete go expiryWorker(&wg, workerReady, workers[0], &gotExpired) <-workerReady item := scannerItem{ Path: obj,
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 12K bytes - Viewed (0) -
docs/config/README.md
replication_max_workers (number) set the maximum number of replication workers (default: '500') replication_max_lrg_workers (number) set the maximum number of replication workers MinIO uses to replicate large objects between sites. (default: '10') transition_workers (number) set the number of transition workers (default: '100')
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Tue Aug 12 18:20:36 UTC 2025 - 18.1K bytes - Viewed (1) -
docs/en/docs/deployment/docker.md
So, in this case, you **would not** want to have a multiple workers in the container, for example with the `--workers` command line option. You would want to have just a **single Uvicorn process** per container (but probably multiple containers).
Registered: Sun Dec 28 07:19:09 UTC 2025 - Last Modified: Sat Sep 20 12:58:04 UTC 2025 - 29.5K bytes - Viewed (1) -
cmd/bucket-lifecycle.go
es.mu.Lock() defer es.mu.Unlock() var workers []chan expiryOp if v := es.workers.Load(); v != nil { // Copy to new array. workers = append(workers, *v...) } if n == len(workers) || n < 1 { return } for len(workers) < n { input := make(chan expiryOp, 10000) workers = append(workers, input) go es.Worker(input) es.stats.workers.Add(1) } for len(workers) > n {
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 33.7K bytes - Viewed (0) -
cmd/metrics-v3-replication.go
replicationRecentBacklogCount = "recent_backlog_count" ) var ( replicationAverageActiveWorkersMD = NewGaugeMD(replicationAverageActiveWorkers, "Average number of active replication workers") replicationAverageQueuedBytesMD = NewGaugeMD(replicationAverageQueuedBytes, "Average number of bytes queued for replication since server start") replicationAverageQueuedCountMD = NewGaugeMD(replicationAverageQueuedCount,
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Thu Aug 15 12:04:40 UTC 2024 - 4.6K bytes - Viewed (0) -
okhttp/src/jvmTest/kotlin/okhttp3/FormBodyTest.kt
assertThat(formEncode(8)).isEqualTo("%08") assertThat(formEncode(9)).isEqualTo("%09") // Browsers convert '\n' to '\r\n' assertThat(formEncode(10)).isEqualTo("%0A") assertThat(formEncode(11)).isEqualTo("%0B") assertThat(formEncode(12)).isEqualTo("%0C") // Browsers convert '\r' to '\r\n' assertThat(formEncode(13)).isEqualTo("%0D") assertThat(formEncode(14)).isEqualTo("%0E")
Registered: Fri Dec 26 11:42:13 UTC 2025 - Last Modified: Wed Mar 19 19:25:20 UTC 2025 - 7.9K bytes - Viewed (0) -
internal/logger/target/http/http.go
retry: // If the channel reaches above half capacity // we spawn more workers. The workers spawned // from this main worker routine will exit // once the channel drops below half capacity // and when it's been at least 30 seconds since // we launched a new worker. if mainWorker && len(h.logCh) > cap(h.logCh)/2 { nWorkers := h.workers.Load() if nWorkers < h.maxWorkers {
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 15.6K bytes - Viewed (0)