Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for newExpiryState (0.08 sec)

  1. cmd/data-scanner_test.go

    		LifecycleConfigUpdatedAt:  now,
    		lifecycleConfig:           lc,
    		versioningConfig:          &vcfg,
    	}
    	globalBucketMetadataSys.Set(bucket, meta)
    	// Prepare lifecycle expiration workers
    	es := newExpiryState(t.Context(), objAPI, 0)
    	globalExpiryState = es
    
    	// Prepare object versions
    	obj := "obj-1"
    	// Simulate objects uploaded 30 hours ago
    	modTime := now.Add(-48 * time.Hour)
    	uuids := make([]uuid.UUID, 5)
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 12K 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,
    	}
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 33.7K bytes
    - Viewed (0)
  3. cmd/object-api-listobjects_test.go

    	ExecObjectLayerTest(t, testListObjectsWithILM)
    }
    
    func testListObjectsWithILM(obj ObjectLayer, instanceType string, t1 TestErrHandler) {
    	// Prepare lifecycle expiration workers
    	es := newExpiryState(t1.Context(), obj, 0)
    	globalExpiryState = es
    
    	t, _ := t1.(*testing.T)
    
    	objContent := "test-content"
    	objMd5 := md5.Sum([]byte(objContent))
    
    	uploads := []struct {
    		bucket     string
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 76.1K bytes
    - Viewed (0)
Back to top