lb

type ErrorOptions struct {
	Handle *vhttp.Subhandler `yaml:"handle,omitempty"` // The error handler.
	Limit  rate.Limit        `yaml:"limit,omitempty"`  // The rate limit.
}

type LoadBalancer struct {
	Options `yaml:",inline"`
	// contains filtered or unexported fields
}

type LoadBalancerMetrics struct {
	Upstreams []UpstreamMetrics `json:"upstreams,omitempty"`
}

type Options struct {
	Retry    retry.Policy  `yaml:",inline"`         // The retry policy.
	Strategy Strategy      `yaml:"strat,omitempty"` // The load balancing strategy.
	State    StateType     `yaml:"state,omitempty"` // The session kind.
	Error4xx *ErrorOptions `yaml:"4xx,omitempty"`   // The error handler for 4xx responses.
	Error5xx *ErrorOptions `yaml:"5xx,omitempty"`   // The error handler for 5xx responses.
	Error404 *ErrorOptions `yaml:"404,omitempty"`   // The error handler for 404 responses.
}

type StateType uint8

type Strategy uint8

type SuppressedHttpError struct {
	http.Handler
}

type Upstream struct {
	Address      string
	Healthy      atomic.Bool
	LoadFactor   atomic.Int32
	ReverseProxy httputil.ReverseProxy

	// Metrics
	RequestCount     atomic.Uint32
	ErrorCount       atomic.Uint32
	ServerErrorCount atomic.Uint32
	ClientErrorCount atomic.Uint32
}

type UpstreamMetrics struct {
	Address          string `json:"address,omitempty"`
	Healthy          bool   `json:"healthy,omitempty"`
	LoadFactor       int32  `json:"load_factor,omitempty"`
	RequestCount     uint32 `json:"request_count,omitempty"`
	ErrorCount       uint32 `json:"error_count,omitempty"`
	ServerErrorCount uint32 `json:"server_error_count,omitempty"`
	ClientErrorCount uint32 `json:"client_error_count,omitempty"`
}