Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 2 of 2 for newBatchJobPool (0.05 seconds)

  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)
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Tue May 27 15:18:36 GMT 2025
    - 35.9K bytes
    - Click Count (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,
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 63.5K bytes
    - Click Count (1)
Back to Top