httputils

type ForcedCacheTransport struct {
	Transport     http.RoundTripper
	CacheDuration time.Duration
}

type MonitoredRoundTripper struct {
	// Transport allows to customize the underneath RoundTripper
	// If not provided, http.DefaultTransport will be used
	Transport    http.RoundTripper
	CallsCounter *prometheus.CounterVec
	Timings      prometheus.HistogramVec
	Labeller     func(req *http.Request, resp *http.Response) prometheus.Labels
}

type RateLimitedRoundTripper struct {
	// Transport allows to customize the underneath RoundTripper
	// If not provided, http.DefaultTransport will be used
	Transport http.RoundTripper
	// KeyFunc allows to group how requests will be grouped for rate limiting
	// the default behaviour returns the request method with full URL
	// ensuring that all calls to a specific endpoint will be serialized
	KeyFunc              func(req *http.Request) string
	ConcurrentCallsLimit int
	// contains filtered or unexported fields
}

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