Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for ExpirationWait (0.07 sec)

  1. internal/config/batch/batch.go

    	KeyRotationWorkersWait time.Duration `json:"keyRotationWorkersWait"`
    	ExpirationWorkersWait  time.Duration `json:"expirationWorkersWait"`
    }
    
    // ExpirationWait returns the duration for which a batch expiration worker
    // would wait before working on next object.
    func (opts Config) ExpirationWait() time.Duration {
    	configMu.RLock()
    	defer configMu.RUnlock()
    
    	return opts.ExpirationWorkersWait
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 4.7K bytes
    - Viewed (0)
  2. cmd/batch-expire.go

    	}
    
    	var i int
    	for toExpire := range expireCh {
    		select {
    		case <-ctx.Done():
    			return
    		default:
    		}
    		if i > 0 {
    			if wait := globalBatchConfig.ExpirationWait(); wait > 0 {
    				time.Sleep(wait)
    			}
    		}
    		i++
    		wk.Take()
    		go func(toExpire []expireObjInfo) {
    			defer wk.Give()
    
    			toExpireAll := make([]ObjectInfo, 0, len(toExpire))
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Sep 18 17:59:03 UTC 2024
    - 21.9K bytes
    - Viewed (0)
Back to top