Function newQueue

db/journal/journal_test.go:13–19

(ctx context.Context, t *testing.T)

)

func newQueue(ctx context.Context, t *testing.T) *Queue {
	path := storage.MustParseURI(t.TempDir())
	engine := storage.NewLocalEngine()
	q, err := Create(ctx, engine, path, 0)
	require.NoError(t, err)
	return q
}

func TestJournalConcurrent(t *testing.T) {
	ctx := t.Context()