Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for newBatchJobPool (1.31 sec)

  1. 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)
  2. 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)
Back to top