Function TestTracePushMiddlewareFailsOpen

modules/distributor/distributor_test.go:2158–2191

(t *testing.T)

}

func TestTracePushMiddlewareFailsOpen(t *testing.T) {
	limits := overrides.Config{}
	limitCfg := &flag.FlagSet{}
	limits.RegisterFlagsAndApplyDefaults(limitCfg)

	distributorCfg, overridesSvc, loggingLevel, middleware := setupDependencies(t, limits)

	// Create a middleware that returns an error
	expectedErr := errors.New("middleware error")
	errorMiddleware := func(_ context.Context, _ ptrace.Traces) error {
		return expectedErr
	}

	distributorCfg.TracePushMiddlewares = []TracePushMiddleware{errorMiddleware}

	d, err := New(
		distributorCfg,
		LocalPushTargets{},
		nil,
		overridesSvc,
		middleware,
		kitlog.NewLogfmtLogger(os.Stdout),
		loggingLevel,
		prometheus.NewRegistry(),
	)
	require.NoError(t, err)

	// Create test traces
	traces := batchesToTraces(t, []*v1.ResourceSpans{test.MakeBatch(10, nil)})

	// Call PushTraces - should succeed despite middleware error (fail open)
	_, err = d.PushTraces(ctx, traces)
	require.NoError(t, err, "PushTraces should succeed even when middleware returns an error")
}