Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 186 for brokers (0.04 sec)

  1. docs/en/docs/deployment/concepts.md

    But in many cases, you will want to run several worker processes at the same time.
    
    ### Multiple Processes - Workers { #multiple-processes-workers }
    
    Registered: Sun Sep 07 07:19:17 UTC 2025
    - Last Modified: Sun Aug 31 09:15:41 UTC 2025
    - 18.6K bytes
    - Viewed (0)
  2. cmd/background-heal-ops.go

    }
    
    func newHealRoutine() *healRoutine {
    	workers := runtime.GOMAXPROCS(0) / 2
    
    	if envHealWorkers := env.Get("_MINIO_HEAL_WORKERS", ""); envHealWorkers != "" {
    		if numHealers, err := strconv.Atoi(envHealWorkers); err != nil {
    			bugLogIf(context.Background(), fmt.Errorf("invalid _MINIO_HEAL_WORKERS value: %w", err))
    		} else {
    			workers = numHealers
    		}
    	}
    
    	if workers == 0 {
    		workers = 4
    	}
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Tue May 27 15:19:03 UTC 2025
    - 4.6K bytes
    - Viewed (0)
  3. CHANGELOG/CHANGELOG-1.12.md

    ### SIG-service-catalog
    - The Originating Identity feature, which lets the broker know which user that performed an action, is now GA.
    - [Namespaced Brokers](https://svc-cat.io/docs/namespaced-broker-resources/), which enable operators to install a broker into a namespace instead of the cluster level, reached GA.
    Registered: Fri Sep 05 09:05:11 UTC 2025
    - Last Modified: Thu Feb 06 06:04:15 UTC 2020
    - 293.8K bytes
    - Viewed (0)
  4. 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 Sep 07 19:28:11 UTC 2025
    - Last Modified: Tue Aug 12 18:20:36 UTC 2025
    - 18.1K bytes
    - Viewed (1)
  5. 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 Sep 07 19:28:11 UTC 2025
    - Last Modified: Thu Aug 15 12:04:40 UTC 2024
    - 4.6K bytes
    - Viewed (0)
  6. 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 Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 12K bytes
    - Viewed (0)
  7. 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 Sep 05 11:42:10 UTC 2025
    - Last Modified: Wed Mar 19 19:25:20 UTC 2025
    - 7.9K bytes
    - Viewed (0)
  8. 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 Sep 07 07:19:17 UTC 2025
    - Last Modified: Sun Aug 31 09:15:41 UTC 2025
    - 29.5K bytes
    - Viewed (1)
  9. android/guava-tests/test/com/google/common/collect/AbstractSequentialIteratorTest.java

      }
    
      public void testBroken() {
        Iterator<Object> broken = new BrokenAbstractSequentialIterator();
        assertTrue(broken.hasNext());
        // We can't retrieve even the known first element:
        assertThrows(SomeUncheckedException.class, broken::next);
        assertThrows(SomeUncheckedException.class, broken::next);
      }
    
      private static Iterator<Integer> newDoubler(int first, int last) {
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 4.7K bytes
    - Viewed (0)
  10. 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 Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 33.7K bytes
    - Viewed (0)
Back to top