Function Test_readEntry

recovery_reader_test.go:13–37

(t *testing.T)

)

func Test_readEntry(t *testing.T) {
	path := filepath.Join(t.TempDir(), "test_read_entry")

	fd, err := os.OpenFile(path, os.O_TRUNC|os.O_CREATE|os.O_RDWR, os.ModePerm)
	require.NoError(t, err)
	meta := core.NewMetaData().WithKeySize(uint32(len("key"))).
		WithValueSize(uint32(len("val"))).WithTimeStamp(1547707905).
		WithTTL(Persistent).WithFlag(DataSetFlag).WithBucketId(1)

	expect := core.NewEntry().WithKey([]byte("key")).WithMeta(meta).WithValue([]byte("val"))

	_, err = fd.Write(expect.Encode())
	require.NoError(t, err)

	f, err := newFileRecovery(path, 4096)
	require.NoError(t, err)

	entry, err := f.readEntry(0)
	require.NoError(t, err)

	assert.Equal(t, expect.Encode(), entry.Encode())

	require.NoError(t, f.release())
	require.NoError(t, fd.Close())
}

func Test_fileRecovery_readBucket(t *testing.T) {
	filePath := filepath.Join(t.TempDir(), "bucket_test_data")