(t *testing.T)
| 300 | } |
| 301 | |
| 302 | func TestLiveStoreReplaysTraceInLiveTraces(t *testing.T) { |
| 303 | tmpDir := t.TempDir() |
| 304 | |
| 305 | liveStore, err := defaultLiveStore(t, tmpDir) |
| 306 | require.NoError(t, err) |
| 307 | require.NotNil(t, liveStore) |
| 308 | |
| 309 | // push data |
| 310 | expectedID, expectedTrace := pushToLiveStore(t, liveStore) |
| 311 | |
| 312 | // stop the live store and then create a new one to simulate a restart and replay the data on disk |
| 313 | err = services.StopAndAwaitTerminated(t.Context(), liveStore) |
| 314 | require.NoError(t, err) |
| 315 | |
| 316 | liveStore, err = defaultLiveStore(t, tmpDir) |
| 317 | require.NoError(t, err) |
| 318 | |
| 319 | requireTraceInLiveStore(t, liveStore, expectedID, expectedTrace) |
| 320 | requireInstanceState(t, liveStore.instances[testTenantID], instanceState{liveTraces: 0, walBlocks: 1, completeBlocks: 0}) |
| 321 | } |
| 322 | |
| 323 | func TestLiveStoreReplaysTraceInHeadBlock(t *testing.T) { |
| 324 | tmpDir := t.TempDir() |
nothing calls this directly
no test coverage detected