Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for newBatchJobPool (3.4 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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Sep 24 21:50:11 UTC 2024
    - 35.2K bytes
    - Viewed (1)
  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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Oct 18 15:32:09 UTC 2024
    - 62.2K bytes
    - Viewed (0)
Back to top