Function liveStoreWithConfig

modules/livestore/instance_search_test.go:644–663

(t testing.TB, cfg Config)

}

func liveStoreWithConfig(t testing.TB, cfg Config) (*LiveStore, error) {
	// Create overrides
	limits, err := overrides.NewOverrides(overrides.Config{}, nil, prometheus.DefaultRegisterer)
	if err != nil {
		return nil, err
	}

	// Create metrics
	reg := prometheus.NewRegistry()

	logger := test.NewTestingLogger(t)

	// Use fake Kafka cluster for testing
	liveStore, err := New(cfg, limits, noopCompleteBlockFlusher{}, logger, reg)
	if err != nil {
		return nil, err
	}

	return liveStore, services.StartAndAwaitRunning(t.Context(), liveStore)
}

func pushTracesToInstance(t *testing.T, i *instance, numTraces int) ([]*tempopb.Trace, [][]byte) {
	var ids [][]byte