proxymw

Jul 18, 2025

Changes in this version

+ const DefaultRangeStep

Jul 14, 2025

Changes in this version

+ func DupRequest(req *http.Request) (*http.Request, error)

Jul 14, 2025

Changes in this version

+ const ObjectStorageThreshold

+ func LowCostRequest(rr Request) (bool, error)

+ func QueryCost(rr Request) (int, error)

type BackpressureConfig

+ EnableLowCostBypass bool

Jan 9, 2025

Changes in this version

+ const BlockerProxyType

+ func ValidateBlockPatterns(patterns []string) error

+ func ValueFromPromQL(ctx context.Context, client *http.Client, endpoint, query string) (float64, error)

type BackpressureQuery

+ func ParseBackpressureQueries(bpQueries, bpQueryNames []string, ...) ([]BackpressureQuery, error)

+ type Blocker struct

+ func NewBlocker(client ProxyClient, cfg BlockerConfig) *Blocker

+ func (b *Blocker) Init(ctx context.Context)

+ func (b *Blocker) Next(rr Request) error

+ type BlockerConfig struct

+ BlockPatterns []string

+ EnableBlocker bool

+ func (q BlockerConfig) Validate() error

Dec 29, 2024

Changes in this version

+ func NewServeFuncFromConfig(cfg Config, next http.HandlerFunc) http.HandlerFunc

type ServeEntry

+ func (se *ServeEntry) ServeHTTP(w http.ResponseWriter, r *http.Request)

Dec 17, 2024

Changes in this version

+ const CriticalityCritical

+ const CriticalityCriticalPlus

+ const CriticalityDefault

+ const NoJitter

+ var HeaderDefaults = map[HeaderKey]string

+ func ParseHeaderKey(rr Request, key HeaderKey) string

type Config

+ EnableCriticality bool

+ type HeaderKey string

+ const HeaderCanWait

+ const HeaderCriticality

Dec 16, 2024

Changes in this version

+ func NewRoutes(ctx context.Context, cfg Config, proxyPaths, passthroughPaths []string, ...) (http.Handler, error)

Dec 14, 2024

Changes in this version

type Mocker

+ RequestFunc func() *http.Request

+ func (m *Mocker) Request() *http.Request

Dec 14, 2024

Changes in this version

type BackpressureQuery

+ Name string

Dec 11, 2024

Changes in this version

+ var ErrExtraQueryQuotes = errors.New("backpressure PromQL cannot be wrapped in quotes")

type Config

+ ClientTimeout time.Duration

Nov 19, 2024

Changes in this version

+ const DefaultIdleConnTimeout

+ const DefaultMaxIdleConns

+ const DefaultPercentileWindow

+ const DefaultThrottleCurve

+ const InstantQueryEndpoint

+ const LatencyProxyType

+ var ErrEmergencyBelowWarnThreshold = errors.New("emergency threshold must be > warn threshold")

+ var ErrLatencyBackoff = BlockErr(LatencyProxyType, "congestion window closed, backoff from slow queries")

+ var ErrNegativeQueryThresholds = errors.New("backpressure query thresholds cannot be negative")

+ var ErrNegativeThrottleCurve = errors.New("throttle curve cannot be negative")

+ var ErrNilRequest = errors.New("nil *http.Request")

+ var ErrNilResponse = errors.New("nil *http.Response")

+ var ErrNilResponseWriter = errors.New("nil http.ResponseWriter")

type Backpressure

+ func (bp *Backpressure) Next(rr Request) error

+ type BackpressureQuery struct

+ EmergencyThreshold float64

+ Query string

+ ThrottlingCurve float64

+ WarningThreshold float64

+ func (q BackpressureQuery) Validate() error

type Config

+ EnableLatency bool

type Jitterer

+ func (j *Jitterer) Next(rr Request) error

+ type LatencyTracker struct

+ func NewLatencyTracker(client ProxyClient, minWindow, maxWindow int) *LatencyTracker

+ func (l *LatencyTracker) AddValue(latency float64)

+ func (l *LatencyTracker) Init(ctx context.Context)

+ func (l *LatencyTracker) Next(rr Request) error

+ func (l *LatencyTracker) P90() float64

type Mocker

+ InitFunc func(context.Context)

+ NextFunc func(Request) error

+ RoundTripFunc func(r *http.Request) (*http.Response, error)

+ func (m *Mocker) Init(ctx context.Context)

+ func (m *Mocker) Next(rr Request) error

+ func (m *Mocker) RoundTrip(r *http.Request) (*http.Response, error)

type Observer

+ func (o *Observer) Next(rr Request) error

type ProxyClient

+ Next func(Request) error

+ type Request interface

+ Request func() *http.Request

+ type RequestResponseWrapper struct

+ func (c *RequestResponseWrapper) Request() *http.Request

+ func (c *RequestResponseWrapper) Response() *http.Response

+ func (c *RequestResponseWrapper) ResponseWriter() http.ResponseWriter

+ func (c *RequestResponseWrapper) SetResponse(res *http.Response)

+ type Response interface

+ Response func() *http.Response

+ SetResponse func(*http.Response)

+ type ResponseWriter interface

+ ResponseWriter func() http.ResponseWriter

+ type RoundTripperEntry struct

+ func NewRoundTripperFromConfig(cfg Config, rt http.RoundTripper) (*RoundTripperEntry, error)

+ func (rte *RoundTripperEntry) Init(ctx context.Context)

+ func (rte *RoundTripperEntry) RoundTrip(req *http.Request) (*http.Response, error)

+ type RoundTripperExit struct

+ func (rte *RoundTripperExit) Init(_ context.Context)

+ func (rte *RoundTripperExit) Next(r Request) error

+ type ServeEntry struct

+ func NewServeFromConfig(cfg Config, next http.HandlerFunc) (*ServeEntry, error)

+ func (se *ServeEntry) Init(ctx context.Context)

+ func (se *ServeEntry) Proxy() http.Handler

+ type ServeExit struct

+ func (se *ServeExit) Init(_ context.Context)

+ func (se *ServeExit) Next(rr Request) error

Nov 16, 2024

Changes in this version

+ const ContentTypeJSON

+ const ErrorTypeProxyQuery

+ type APIErrorResponse struct

+ Error string

+ ErrorType string

+ Status string

+ type PrometheusResponse struct

+ Data struct{ ... }

Nov 15, 2024

Changes in this version

+ const BackpressureProxyType

+ const BackpressureUpdateCadence

+ const MonitorQueryTimeout

+ var ErrBackpressureBackoff = BlockErr(BackpressureProxyType, "congestion window closed, backoff from backpressure")

+ var ErrBackpressureQueryRequired = errors.New("must provide at least one backpressure query when backpressure is enabled")

+ var ErrCongestionWindowMaxBelowMin = errors.New("backpressure max window <= min window")

+ var ErrCongestionWindowMinBelowOne = errors.New("backpressure min window < 1")

+ var ErrJitterDelayRequired = errors.New("delay must be non-empty when jitter is enabled")

+ var ErrRegistryRequired = errors.New("prometheus registry is required when observer is enabled")

+ func BlockErr(t string, format string, a ...any) error

+ type Backpressure struct

+ func NewBackpressure(querier ProxyClient, minWindow, maxWindow int, queries []string, ...) *Backpressure

+ func (bp *Backpressure) Init(ctx context.Context)

+ func (bp *Backpressure) ServeHTTP(w http.ResponseWriter, r *http.Request) error

+ type BackpressureConfig struct

+ BackpressureMonitoringURL string

+ BackpressureQueries []string

+ CongestionWindowMax int

+ CongestionWindowMin int

+ EnableBackpressure bool

+ func (c BackpressureConfig) Validate() error

+ type Config struct

+ EnableJitter bool

+ EnableObserver bool

+ JitterDelay time.Duration

+ ObserverRegistry *prometheus.Registry

+ func (c Config) Validate() error

+ type Entry struct

+ func NewFromConfig(cfg Config, next http.HandlerFunc) (*Entry, error)

+ func (e *Entry) Init(ctx context.Context)

+ func (e *Entry) Proxy() http.Handler

+ type Exit struct

+ func (e *Exit) Init(_ context.Context)

+ func (e *Exit) ServeHTTP(w http.ResponseWriter, r *http.Request) error

+ type Jitterer struct

+ func NewJitterer(querier ProxyClient, delay time.Duration) *Jitterer

+ func (j *Jitterer) Init(ctx context.Context)

+ func (j *Jitterer) ServeHTTP(w http.ResponseWriter, r *http.Request) error

+ type Mocker struct

+ ServeHTTPFunc func(w http.ResponseWriter, r *http.Request)

+ func (m *Mocker) ServeHTTP(w http.ResponseWriter, r *http.Request)

+ type Observer struct

+ func NewObserver(querier ProxyClient, reg *prometheus.Registry) *Observer

+ func (o *Observer) Init(ctx context.Context)

+ func (o *Observer) ServeHTTP(w http.ResponseWriter, r *http.Request) error

+ type ProxyClient interface

+ Init func(context.Context)

+ ServeHTTP func(http.ResponseWriter, *http.Request) error

+ type RequestBlockedError struct

+ Err error

+ Type string

+ func (e *RequestBlockedError) Error() string