Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 98 for nWorkers (0.05 sec)

  1. cmd/global-heal.go

    	}
    	// allow overriding this value as well..
    	if v := globalHealConfig.GetWorkers(); v > 0 {
    		numHealers = uint64(v)
    	}
    
    	healingLogEvent(ctx, "Healing drive '%s' - use %d parallel workers.", tracker.disk.String(), numHealers)
    
    	jt, _ := workers.New(int(numHealers))
    
    	healEntryDone := func(name string) healEntryResult {
    		return healEntryResult{
    			entryDone: true,
    			name:      name,
    		}
    	}
    
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Apr 04 13:49:12 UTC 2025
    - 16.2K bytes
    - Viewed (0)
  2. 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 Dec 28 07:19:09 UTC 2025
    - Last Modified: Sun Aug 31 09:15:41 UTC 2025
    - 18.6K bytes
    - Viewed (1)
  3. docs/es/docs/deployment/concepts.md

    Pero en muchos casos, querrás ejecutar varios worker processes al mismo tiempo.
    
    ### Múltiples Procesos - Workers { #multiple-processes-workers }
    
    Registered: Sun Dec 28 07:19:09 UTC 2025
    - Last Modified: Tue Dec 16 16:33:45 UTC 2025
    - 20.1K bytes
    - Viewed (0)
  4. cmd/notification.go

    type NotificationGroup struct {
    	workers    *workers.Workers
    	errs       []NotificationPeerErr
    	retryCount int
    }
    
    // WithNPeers returns a new NotificationGroup with length of errs slice upto nerrs,
    // upon Wait() errors are returned collected from all tasks.
    func WithNPeers(nerrs int) *NotificationGroup {
    	if nerrs <= 0 {
    		nerrs = 1
    	}
    	wk, _ := workers.New(nerrs)
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 46K bytes
    - Viewed (0)
  5. internal/event/targetlist.go

    					return
    				}
    			}
    		}()
    	}
    	wk.Wait()
    }
    
    var startOnce sync.Once
    
    // Init initialize target send workers.
    func (list *TargetList) Init(workers int) *TargetList {
    	startOnce.Do(func() {
    		go list.startSendWorkers(workers)
    	})
    	return list
    }
    
    // NewTargetList - creates TargetList.
    func NewTargetList(ctx context.Context) *TargetList {
    	list := &TargetList{
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 9.2K bytes
    - Viewed (0)
  6. 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)
  7. 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)
  8. internal/config/api/api.go

    	if err != nil {
    		return cfg, err
    	}
    	if replicationMaxWorkers <= 0 || replicationMaxWorkers > 500 {
    		return cfg, config.ErrInvalidReplicationWorkersValue(nil).Msg("Number of replication workers should be between 1 and 500")
    	}
    	cfg.ReplicationMaxWorkers = replicationMaxWorkers
    
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 11.5K bytes
    - Viewed (1)
  9. 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)
  10. 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)
Back to top