root := t.TempDir()
clock := newTestClock()
random := rand.New(rand.NewPCG(1, 2))
- memory, err := openMemory(t.Context(), root, clock.Now, newFakeSummarizer())
+ memory, err := openMemory(t.Context(), root, clock.Now, newFakeSummarizer(), discardLog())
require.NoError(t, err)
defer func() {
memory = replayRequireRestart(t, memory, root, clock)
require.Equal(t, messages, memory.log.Len())
- require.Greater(t, batches, 0)
+ require.Positive(t, batches)
require.NoError(t, memory.Wait(t.Context()))
t.Logf("%d messages, %d nodes, %d batches in %s", messages, memory.tree.Count(), batches, time.Since(start).Round(time.Second))
require.NoError(t, err)
require.NoError(t, memory.Close())
- memory, err = openMemory(t.Context(), root, clock.Now, newFakeSummarizer())
+ memory, err = openMemory(t.Context(), root, clock.Now, newFakeSummarizer(), discardLog())
require.NoError(t, err)
require.NoError(t, memory.Wait(t.Context()))
require.Equal(t, view, memory.View())