frontend

Documentation

Index

• Constants
• func NewRoundTripper(next http.RoundTripper, middlewares ...Middleware) http.RoundTripper
• func NewTripperware(cfg Config, logger log.Logger, registerer prometheus.Registerer) (queryrange.Tripperware, error)
• type Config
  • func (cfg *Config) RegisterFlagsAndApplyDefaults(prefix string, f *flag.FlagSet)
• type CortexNoQuerierLimits
  • func (CortexNoQuerierLimits) MaxQueriersPerUser(user string) int
• type Handler
• type Middleware
  • func Deduper(logger log.Logger) Middleware
  • func MergeMiddlewares(middleware ...Middleware) Middleware
  • func RetryWare(maxRetries int, registerer prometheus.Registerer) Middleware
  • func ShardingWare(queryShards int, logger log.Logger) Middleware
• type MiddlewareFunc
  • func (q MiddlewareFunc) Wrap(h Handler) Handler
• type RequestResponse

Constants

const (
	MinQueryShards = 2
	MaxQueryShards = 256
)

Functions

func NewRoundTripper

func NewRoundTripper(next http.RoundTripper, middlewares ...Middleware) http.RoundTripper

NewRoundTripper merges a set of middlewares into an handler, then inject it into the `next` roundtripper

func NewTripperware

func NewTripperware(cfg Config, logger log.Logger, registerer prometheus.Registerer) (queryrange.Tripperware, error)

NewTripperware returns a Tripperware configured with a middleware to split requests

Types

type Config

type Config struct {
	Config      frontend.CombinedFrontendConfig `yaml:",inline"`
	MaxRetries  int                             `yaml:"max_retries,omitempty"`
	QueryShards int                             `yaml:"query_shards,omitempty"`
}

func (*Config) RegisterFlagsAndApplyDefaults

func (cfg *Config) RegisterFlagsAndApplyDefaults(prefix string, f *flag.FlagSet)

type CortexNoQuerierLimits

type CortexNoQuerierLimits struct{}

func (CortexNoQuerierLimits) MaxQueriersPerUser

func (CortexNoQuerierLimits) MaxQueriersPerUser(user string) int

type Handler

type Handler interface {
	Do(*http.Request) (*http.Response, error)
}

type Middleware

type Middleware interface {
	Wrap(Handler) Handler
}

func Deduper

func Deduper(logger log.Logger) Middleware

func MergeMiddlewares

func MergeMiddlewares(middleware ...Middleware) Middleware

func RetryWare

func RetryWare(maxRetries int, registerer prometheus.Registerer) Middleware

func ShardingWare

func ShardingWare(queryShards int, logger log.Logger) Middleware

type MiddlewareFunc

type MiddlewareFunc func(Handler) Handler

MiddlewareFunc is like http.HandlerFunc, but for Middleware.

func (MiddlewareFunc) Wrap

func (q MiddlewareFunc) Wrap(h Handler) Handler

Wrap implements Middleware.

type RequestResponse

type RequestResponse struct {
	Request  *http.Request
	Response *http.Response
}

RequestResponse contains a request response and the respective request that was used.