- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 125 for walkers (0.2 sec)
-
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 Oct 27 07:19:11 UTC 2024 - Last Modified: Wed Sep 18 16:09:57 UTC 2024 - 28.5K bytes - Viewed (0) -
docs/config/README.md
replication_priority (string) set replication priority (default: 'auto') replication_max_workers (number) set the maximum number of replication workers (default: '500') transition_workers (number) set the number of transition workers (default: '100') stale_uploads_expiry (duration) set to expire stale multipart uploads older than this values (default: '24h')
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Fri Aug 16 08:43:49 UTC 2024 - 17.9K bytes - Viewed (0) -
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 Oct 27 19:28:09 UTC 2024 - Last Modified: Wed Oct 23 15:35:37 UTC 2024 - 33.7K 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 Oct 27 19:28:09 UTC 2024 - Last Modified: Wed Sep 11 22:20:42 UTC 2024 - 15.6K bytes - Viewed (0) -
internal/s3select/json/preader.go
current []jstream.KVS // current block of results to be returned recordsRead int // number of records read in current slice input chan *queueItem // input for workers queue chan *queueItem // output from workers in order err error // global error state, only touched by Reader.Read bufferPool sync.Pool // pool of []byte objects for input
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Mon Sep 23 19:35:41 UTC 2024 - 6.5K bytes - Viewed (0) -
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 Oct 27 19:28:09 UTC 2024 - Last Modified: Sat Oct 26 09:58:27 UTC 2024 - 16.3K bytes - Viewed (0) -
docs/distributed/DECOMMISSION.md
## NOTE - Empty delete markers (such as for objects with no other successor versions) do not transition to the new pool to avoid creating empty metadata on the other pool(s). If you believe transitioning empty delete markers is required, open a GitHub issue. ## TODO
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Mon Jul 11 14:59:49 UTC 2022 - 8.3K bytes - Viewed (0) -
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 Oct 27 19:28:09 UTC 2024 - Last Modified: Mon Sep 09 16:58:30 UTC 2024 - 46.2K bytes - Viewed (0) -
docs/en/docs/deployment/concepts.md
Here are some possible combinations and strategies: * **Uvicorn** with `--workers` * One Uvicorn **process manager** would listen on the **IP** and **port**, and it would start **multiple Uvicorn worker processes**.
Registered: Sun Oct 27 07:19:11 UTC 2024 - Last Modified: Wed Sep 18 16:09:57 UTC 2024 - 17.8K bytes - Viewed (0) -
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 Oct 27 19:28:09 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 9.2K bytes - Viewed (0)