MCPcopy Create free account
hub / github.com/nutsdb/nutsdb / TestTx_ExpireList

Function TestTx_ExpireList

tx_list_test.go:462–488  ·  view source on GitHub ↗
(t *testing.T)

Source from the content-addressed store, hash-verified

460}
461
462func TestTx_ExpireList(t *testing.T) {
463 bucket := "bucket"
464
465 // Verify that the list with expiration time expires normally
466 runNutsDBTest(t, nil, func(t *testing.T, db *DB) {
467 txCreateBucket(t, db, DataStructureList, bucket, nil)
468 pushDataByStartEnd(t, db, bucket, 0, 0, 3, false)
469 txLRange(t, db, bucket, testutils.GetTestBytes(0), 0, -1, 4, [][]byte{
470 testutils.GetTestBytes(0), testutils.GetTestBytes(1), testutils.GetTestBytes(2), testutils.GetTestBytes(3),
471 }, nil)
472
473 txExpireList(t, db, bucket, testutils.GetTestBytes(0), 1, nil)
474 time.Sleep(time.Second)
475 txLRange(t, db, bucket, testutils.GetTestBytes(0), 0, -1, 0, nil, ErrListNotFound)
476 })
477
478 // Verify that the list with persistent time
479 runNutsDBTest(t, nil, func(t *testing.T, db *DB) {
480 txCreateBucket(t, db, DataStructureList, bucket, nil)
481 pushDataByStartEnd(t, db, bucket, 0, 0, 3, false)
482 txExpireList(t, db, bucket, testutils.GetTestBytes(0), Persistent, nil)
483 time.Sleep(time.Second)
484 txLRange(t, db, bucket, testutils.GetTestBytes(0), 0, -1, 4, [][]byte{
485 testutils.GetTestBytes(0), testutils.GetTestBytes(1), testutils.GetTestBytes(2), testutils.GetTestBytes(3),
486 }, nil)
487 })
488}
489
490func TestTx_LKeys(t *testing.T) {
491 bucket := "bucket"

Callers

nothing calls this directly

Calls 6

GetTestBytesFunction · 0.92
runNutsDBTestFunction · 0.85
txCreateBucketFunction · 0.85
pushDataByStartEndFunction · 0.85
txLRangeFunction · 0.85
txExpireListFunction · 0.85

Tested by

no test coverage detected