runner

type ContextKey string

type ExperimentRunner interface {
	// GetTreatmentForRequest is a method that is called by the Turing Router for each request it receives to retrieve
	// an appropriate treatment for it
	GetTreatmentForRequest(
		header http.Header,
		payload []byte,
		options GetTreatmentOptions,
	) (*Treatment, error)
	// RegisterMetricsCollector is a method that should only be called on startup of the experiment runner to register
	// the metrics collector of the Turing Router (to be called just after the experiment runner has been initialised)
	RegisterMetricsCollector(
		collector metrics.Collector,
		metricsRegistrationHelper MetricsRegistrationHelper,
	) error
}

type GetTreatmentOptions struct {
	TuringRequestID string
}

type Interceptor interface {
	BeforeDispatch(ctx context.Context) context.Context
	AfterCompletion(ctx context.Context, err error)
}

type MetricsRegistrationHelper interface {
	// Register is a method that should be called within ExperimentRunner.RegisterMetricsCollector to register
	// additional metrics that the experiment engine requires on the metrics collector of the Turing Router
	Register(metrics []instrumentation.Metric) error
}

type Treatment struct {
	ExperimentName string
	Name           string
	Config         json.RawMessage
}