Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for ExpirationWait (0.43 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
    }
    
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Wed Dec 06 09:09:22 GMT 2023
    - 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))
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 21K bytes
    - Viewed (1)
Back to top