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() {
}()
batches := 0
+
low := viewChatHigh
long := make([]bool, messages)
for id := range messages {
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))
runtime.GC()
var stats runtime.MemStats
+
runtime.ReadMemStats(&stats)
t.Logf("heap in use: %d KB", stats.HeapInuse/1024)
}
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())
}
require.Equal(t, head+strings.ReplaceAll(node.Text, "\n", " "), rendered[n+1])
+
if line.level == 0 && long[line.index] {
require.True(t, strings.HasPrefix(node.Text, "summary "), "message %d", line.index)
}