Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 1 of 1 for brokers (0.15 sec)

  1. cmd/batch-expire.go

    	oi, ok := oiCache[fmt.Sprintf("%s-%s", toDel.ObjectName, toDel.VersionID)]
    	return oi, ok
    }
    
    func batchObjsForDelete(ctx context.Context, r *BatchJobExpire, ri *batchJobInfo, job BatchJobRequest, api ObjectLayer, wk *workers.Workers, expireCh <-chan []expireObjInfo) {
    	vc, _ := globalBucketVersioningSys.Get(r.Bucket)
    	retryAttempts := r.Retry.Attempts
    	delay := job.Expire.Retry.Delay
    	if delay == 0 {
    		delay = batchExpireJobDefaultRetryDelay
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 21K bytes
    - Viewed (1)
Back to top