- Sort Score
- Result 10 results
- Languages All
Results 1 - 2 of 2 for newBatchJobPool (1.31 sec)
-
cmd/server-main.go
bootstrapTrace("go initFederatorBackend", func() { go initFederatorBackend(buckets, newObject) }) } // Initialize batch job pool. bootstrapTrace("newBatchJobPool", func() { globalBatchJobPool = newBatchJobPool(GlobalContext, newObject, 100) globalBatchJobsMetrics = batchJobMetrics{ metrics: make(map[string]*batchJobInfo), } go globalBatchJobsMetrics.init(GlobalContext, newObject)
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Tue May 27 15:18:36 UTC 2025 - 35.9K bytes - Viewed (4) -
cmd/batch-handlers.go
jobCancelers map[string]context.CancelFunc workerKillCh chan struct{} workerSize int } var globalBatchJobPool *BatchJobPool // newBatchJobPool creates a pool of job manifest workers of specified size func newBatchJobPool(ctx context.Context, o ObjectLayer, workers int) *BatchJobPool { jpool := &BatchJobPool{ ctx: ctx, objLayer: o,
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 63.5K bytes - Viewed (0)