middleware

type Middleware interface {
	// Called before the request is going to be proxied to the endpoint selected by the load balancer.
	// If it returns an error, request will be treated as erorrneous (e.g. failover will be initated).
	// If it returns a non nil response, proxy will return the response without proxying to the endpoint.
	// If it returns nil response and nil error request will be proxied to the upstream.
	// It's ok to modify request headers and body as a side effect of the funciton call.
	ProcessRequest(r Request) (*http.Response, error)

	// If request has been completed or intercepted by middleware and response has been received
	// attempt would contain non nil response or non nil error.
	ProcessResponse(r Request, a Attempt)
}

type MiddlewareChain struct {
	// contains filtered or unexported fields
}

type MiddlewareIter struct {
	// contains filtered or unexported fields
}

type MiddlewareWrapper struct {
	OnRequest  ProcessRequestFn
	OnResponse ProcessResponseFn
}

type ObserveRequestFn func(r Request)

type ObserveResponseFn func(r Request, a Attempt)

type Observer interface {
	// Will be called before every request to the endpoint
	ObserveRequest(r Request)

	// Will be called after every request to the endpoint
	ObserveResponse(r Request, a Attempt)
}

type ObserverChain struct {
	// contains filtered or unexported fields
}

type ObserverWrapper struct {
	OnRequest  ObserveRequestFn
	OnResponse ObserveResponseFn
}

type ProcessRequestFn func(r Request) (*http.Response, error)

type ProcessResponseFn func(r Request, a Attempt)