middleware

type Factory func(*configv1.Middleware) (Middleware, error)

type FactoryV2 func(*configv1.Middleware) (MiddlewareV2, error)

type MetaStreamChunk struct {
	Tag  string
	Data []byte
	Err  error
}

type MetaStreamContext struct {
	Request    *http.Request
	Response   *http.Response
	OnResponse []func(req *http.Request, reply *http.Response)
	OnFinish   []func(req *http.Request, reply *http.Response)
	OnChunk    []func(req *http.Request, reply *http.Response, chunk *MetaStreamChunk)
	// contains filtered or unexported fields
}

type MetaStreamContextKey struct{}

type MetricsLabels interface {
	Protocol() string
	Method() string
	Path() string
	Service() string
	BasePath() string
}

type Middleware func(http.RoundTripper) http.RoundTripper

type MiddlewareV2 interface {
	Process(http.RoundTripper) http.RoundTripper
	io.Closer
}

type Registry interface {
	Register(name string, factory Factory)
	RegisterV2(name string, factory FactoryV2)
	Create(cfg *configv1.Middleware) (MiddlewareV2, error)
}

type RequestOptions struct {
	Endpoint             *config.Endpoint
	Filters              []selector.NodeFilter
	Backends             []string
	Metadata             map[string]string
	UpstreamStatusCode   []int
	UpstreamResponseTime []float64
	CurrentNode          selector.Node
	DoneFunc             selector.DoneFunc
	LastAttempt          bool
	Values               RequestValues
}

type RequestValues interface {
	Get(key any) (any, bool)
	Set(key, val any)
}

type RoundTripperFunc func(*http.Request) (*http.Response, error)

type StreamBody interface {
	CloseNotify() <-chan bool
}