Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for queueTransitionTask (0.1 sec)

  1. cmd/bucket-lifecycle.go

    	activeTasks          atomic.Int64
    	missedImmediateTasks atomic.Int64
    
    	lastDayMu    sync.RWMutex
    	lastDayStats map[string]*lastDayTierStats
    }
    
    func (t *transitionState) queueTransitionTask(oi ObjectInfo, event lifecycle.Event, src lcEventSrc) {
    	task := transitionTask{objInfo: oi, event: event, src: src}
    	select {
    	case <-t.ctx.Done():
    	case t.transitionCh <- task:
    	default:
    		switch src {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Oct 23 15:35:37 UTC 2024
    - 33.7K bytes
    - Viewed (0)
  2. cmd/data-scanner.go

    	}
    
    	return event
    }
    
    func applyTransitionRule(event lifecycle.Event, src lcEventSrc, obj ObjectInfo) bool {
    	if obj.DeleteMarker || obj.IsDir {
    		return false
    	}
    	globalTransitionState.queueTransitionTask(obj, event, src)
    	return true
    }
    
    func applyExpiryOnTransitionedObject(ctx context.Context, objLayer ObjectLayer, obj ObjectInfo, lcEvent lifecycle.Event, src lcEventSrc) (ok bool) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 22 21:10:34 UTC 2024
    - 48.4K bytes
    - Viewed (0)
Back to top