Function testIngestionSlack

tempodb/wal/wal_test.go:96–135

(t *testing.T, e encoding.VersionedEncoding)

}

func testIngestionSlack(t *testing.T, e encoding.VersionedEncoding) {
	wal, err := New(&Config{
		Filepath:       t.TempDir(),
		IngestionSlack: time.Minute,
		Version:        encoding.DefaultEncoding().Version(),
	})
	require.NoError(t, err, "unexpected error creating temp wal")

	blockID := uuid.New()
	meta := backend.NewBlockMeta("fake", blockID, e.Version())
	block, err := wal.NewBlock(meta, model.CurrentEncoding)
	require.NoError(t, err, "unexpected error creating block")

	enc := model.MustNewSegmentDecoder(model.CurrentEncoding)

	traceStart := uint32(time.Now().Add(-2 * time.Minute).Unix()) // Outside of range
	traceEnd := uint32(time.Now().Add(-1 * time.Minute).Unix())   // At end of range

	// Append a trace
	id := make([]byte, 16)
	_, err = crand.Read(id)
	require.NoError(t, err)
	obj := test.MakeTrace(rand.Int()%10+1, id)

	b1, err := enc.PrepareForWrite(obj, traceStart, traceEnd)
	require.NoError(t, err)

	b2, err := enc.ToObject([][]byte{b1})
	require.NoError(t, err)

	appendTime := time.Now()
	err = block.Append(id, b2, traceStart, traceEnd, true)
	require.NoError(t, err, "unexpected error writing req")

	blockStart := uint32(block.BlockMeta().StartTime.Unix())
	blockEnd := uint32(block.BlockMeta().EndTime.Unix())

	require.Equal(t, uint32(appendTime.Unix()), blockStart)
	require.Equal(t, uint32(appendTime.Unix()), blockEnd)
}

func TestFindByTraceID(t *testing.T) {
	for _, e := range encoding.AllEncodingsForWrites() {