Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 1 of 1 for PendingTasks (0.1 sec)

  1. cmd/bucket-lifecycle.go

    	mu      sync.RWMutex
    	workers atomic.Pointer[[]chan expiryOp]
    
    	ctx    context.Context
    	objAPI ObjectLayer
    
    	stats expiryStats
    }
    
    // PendingTasks returns the number of pending ILM expiry tasks.
    func (es *expiryState) PendingTasks() int {
    	w := es.workers.Load()
    	if w == nil || len(*w) == 0 {
    		return 0
    	}
    	var tasks int
    	for _, wrkr := range *w {
    		tasks += len(wrkr)
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Oct 23 15:35:37 UTC 2024
    - 33.7K bytes
    - Viewed (0)
Back to top