Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 215 for brokers (0.04 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top