(t *testing.T, tmpDir string)
| 42 | } |
| 43 | |
| 44 | func newTestStore(t *testing.T, tmpDir string) storage.Store { |
| 45 | t.Helper() |
| 46 | |
| 47 | s, err := storage.NewStore(storage.Config{ |
| 48 | Trace: tempodb.Config{ |
| 49 | Backend: backend.Local, |
| 50 | Local: &local.Config{ |
| 51 | Path: tmpDir + "/traces", |
| 52 | }, |
| 53 | Block: &common.BlockConfig{ |
| 54 | BloomFP: 0.01, |
| 55 | BloomShardSizeBytes: 100_000, |
| 56 | Version: encoding.LatestEncoding().Version(), |
| 57 | }, |
| 58 | WAL: &wal.Config{ |
| 59 | Filepath: tmpDir + "/wal", |
| 60 | }, |
| 61 | BlocklistPoll: 100 * time.Millisecond, |
| 62 | }, |
| 63 | }, nil, log.NewNopLogger()) |
| 64 | require.NoError(t, err) |
| 65 | |
| 66 | return s |
| 67 | } |
| 68 | |
| 69 | func TestConfigureGenerator(t *testing.T) { |
| 70 | t.Run("single binary does not consume from kafka", func(t *testing.T) { |
no test coverage detected