Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for enqueueByNewerNoncurrent (0.36 sec)

  1. cmd/bucket-lifecycle.go

    	}
    	select {
    	case <-GlobalContext.Done():
    	case wrkr <- task:
    	default:
    		es.stats.missedExpiryTasks.Add(1)
    	}
    }
    
    // enqueueByNewerNoncurrent enqueues object versions expired by
    // NewerNoncurrentVersions limit for expiry.
    func (es *expiryState) enqueueByNewerNoncurrent(bucket string, versions []ObjectToDelete, lcEvent lifecycle.Event) {
    	if len(versions) == 0 {
    		return
    	}
    
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Wed Apr 17 05:09:58 GMT 2024
    - 33.1K bytes
    - Viewed (0)
  2. cmd/data-scanner.go

    		}
    
    		toDel = append(toDel, ObjectToDelete{
    			ObjectV: ObjectV{
    				ObjectName: obj.Name,
    				VersionID:  obj.VersionID,
    			},
    		})
    	}
    
    	if len(toDel) > 0 {
    		expState.enqueueByNewerNoncurrent(i.bucket, toDel, event)
    	}
    	return objectInfos, nil
    }
    
    // applyVersionActions will apply lifecycle checks on all versions of a scanned item. Returns versions that remain
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Mon Apr 22 17:49:30 GMT 2024
    - 47.4K bytes
    - Viewed (0)
Back to top