proxymw

type APIErrorResponse struct {
	Status    string `json:"status"`
	ErrorType string `json:"errorType"`
	Error     string `json:"error"`
}

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

type BackpressureConfig struct {
	EnableBackpressure        bool                `yaml:"enable_backpressure"`
	BackpressureMonitoringURL string              `yaml:"backpressure_monitoring_url"`
	BackpressureQueries       []BackpressureQuery `yaml:"backpressure_queries"`
	CongestionWindowMin       int                 `yaml:"congestion_window_min"`
	CongestionWindowMax       int                 `yaml:"congestion_window_max"`
}

type BackpressureQuery struct {
	// Name is an optional human readable field used to emit tagged metrics.
	// When unset, operational metrics are omitted.
	// When set, read warn_threshold as proxymw_bp_warn_threshold{query_name="<name>"}
	Name string `yaml:"name,omitempty"`
	// Query is the PromQL to monitor system load or usage
	Query string `yaml:"query"`
	// WarningThreshold is the load value at which throttling begins (e.g., 80% capacity)
	WarningThreshold float64 `yaml:"warning_threshold"`
	// EmergencyThreshold is the load value at which the max num of requests are blocked (e.g., 100% capacity). Still lets through CongestionWindowMin
	EmergencyThreshold float64 `yaml:"emergency_threshold"`
	// ThrottlingCurve is a constant controlling the aggressiveness of throttling (e.g., default 4.0 for steep growth)
	ThrottlingCurve float64 `yaml:"throttling_curve"`
}

type Config struct {
	BackpressureConfig `yaml:"backpressure_config"`
	EnableJitter       bool          `yaml:"enable_jitter"`
	JitterDelay        time.Duration `yaml:"jitter_delay"`
	EnableObserver     bool          `yaml:"enable_observer"`
	ClientTimeout      time.Duration `yaml:"client_timeout"`
	EnableCriticality  bool          `yaml:"enable_criticality"`
}

type HeaderKey string

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

type Mocker struct {
	ServeHTTPFunc func(w http.ResponseWriter, r *http.Request)
	RoundTripFunc func(r *http.Request) (*http.Response, error)
	InitFunc      func(context.Context)
	NextFunc      func(Request) error
	RequestFunc   func() *http.Request
}

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

type PrometheusResponse struct {
	Data struct {
		Result model.Vector `json:"result"`
	} `json:"data"`
}

type ProxyClient interface {
	Init(context.Context)
	Next(Request) error
}

type Request interface {
	Request() *http.Request
}

type RequestBlockedError struct {
	Err  error
	Type string
}

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

type Response interface {
	Response() *http.Response
	SetResponse(*http.Response)
}

type ResponseWriter interface {
	ResponseWriter() http.ResponseWriter
}

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

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

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

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