Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for newExpiryState (0.21 sec)

  1. cmd/data-scanner_test.go

    	}
    	defer removeRoots(disks)
    	setObjectLayer(objAPI)
    	globalBucketMetadataSys = NewBucketMetadataSys()
    	globalBucketObjectLockSys = &BucketObjectLockSys{}
    	globalBucketVersioningSys = &BucketVersioningSys{}
    	es := newExpiryState(context.Background(), objAPI, 0)
    	workers := []chan expiryOp{make(chan expiryOp)}
    	es.workers.Store(&workers)
    	globalExpiryState = es
    	var wg sync.WaitGroup
    	wg.Add(1)
    	expired := make([]ObjectToDelete, 0, 5)
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Sat Mar 02 05:11:03 GMT 2024
    - 3.9K bytes
    - Viewed (0)
  2. cmd/bucket-lifecycle.go

    	}
    }
    
    // globalExpiryState is the per-node instance which manages all ILM expiry tasks.
    var globalExpiryState *expiryState
    
    // newExpiryState creates an expiryState with buffered channels allocated for
    // each ILM expiry task type.
    func newExpiryState(ctx context.Context, objAPI ObjectLayer, n int) *expiryState {
    	es := &expiryState{
    		ctx:    ctx,
    		objAPI: objAPI,
    	}
    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)
Back to top