Function newTestIngester

pkg/ingester/pushstream_security_test.go:68–81

newTestIngester creates an ingester instance for PushStream security tests.

(t *testing.T)

// newTestIngester creates an ingester instance for PushStream security tests.
func newTestIngester(t *testing.T) *Ingester {
	t.Helper()
	cfg := defaultIngesterTestConfig(t)
	ing, err := prepareIngesterWithBlocksStorage(t, cfg, prometheus.NewRegistry())
	require.NoError(t, err)
	require.NoError(t, services.StartAndAwaitRunning(context.Background(), ing))
	t.Cleanup(func() {
		_ = services.StopAndAwaitTerminated(context.Background(), ing)
	})
	test.Poll(t, time.Second, ring.ACTIVE, func() any {
		return ing.lifecycler.GetState()
	})
	return ing
}

// TestPushStream_TenantImpersonation reproduces the tenant impersonation vulnerability
// and verifies it is blocked after the fix is applied.