Function createTestEntry

merge_v2_test.go:464–485

(bucketID core.BucketId, key, value []byte, flag uint16, status uint16, ttl uint32, ts uint64, txID uint64, ds core.DataStructure)

func (r *recordingHintWriter) Close() error { return nil }

func createTestEntry(bucketID core.BucketId, key, value []byte, flag uint16, status uint16, ttl uint32, ts uint64, txID uint64, ds core.DataStructure) *core.Entry {
	meta := core.NewMetaData().
		WithBucketId(uint64(bucketID)).
		WithKeySize(uint32(len(key))).
		WithValueSize(uint32(len(value))).
		WithFlag(flag).
		WithStatus(status).
		WithTTL(ttl).
		WithTimeStamp(ts).
		WithTxID(txID).
		WithDs(uint16(ds))

	entry := &core.Entry{
		Key:   append([]byte(nil), key...),
		Value: append([]byte(nil), value...),
		Meta:  meta,
	}

	// Encode once to populate CRC and ensure the entry is well-formed.
	entry.Encode()
	return entry
}

func TestMergeV2PrepareWhileAlreadyMerging(t *testing.T) {
	dir := t.TempDir()