- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for newExpiryState (0.08 sec)
-
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) -
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) -
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)