loadbalancer

type HTTPHealthCheckConfig struct {
	// Health check path, e.g, /healthz.
	Path string `json:"path" yaml:"path"`
	// Health check method. Default to GET
	Method string `json:"method,omitempty" yaml:"method,omitempty" jsonschema:"default=GET,enum=GET,enum=POST"`
	// Request body is used if the method is POST.
	Body any `json:"body,omitempty" yaml:"body,omitempty"`
	// Request headers to be sent to health check requests.
	Headers map[string]goenvconf.EnvString `json:"headers,omitempty" yaml:"headers,omitempty"`
	// Health check interval in seconds. Disabled if the interval is negative or equals 0. Default to 60 seconds
	Interval *int `json:"interval,omitempty" yaml:"interval,omitempty" jsonschema:"default=60,min=0"`
	// Timeout in seconds. Disabled if the timeout is negative or equals 0. Default to 5 seconds
	Timeout *int `json:"timeout,omitempty" yaml:"timeout,omitempty" jsonschema:"default=5,min=0"`
	// SuccessStatus is expected successful HTTP status. Default to HTTP 200 OK.
	SuccessStatus *int `json:"successStatus,omitempty" yaml:"successStatus,omitempty" jsonschema:"default=200,enum=200,enum=201,enum=204"`
	// SuccessThreshold is the minimum consecutive successes for the probe to be considered successful after having failed. Defaults to 1. Minimum value is 1.
	SuccessThreshold *int `json:"successThreshold,omitempty" yaml:"successThreshold,omitempty" jsonschema:"default=1,min=1"`
	// Failure threshold. After a probe fails threshold times in a row, the HTTP client considers that the overall check has failed. Default to 5. Minimum value is 1
	FailureThreshold *int `json:"failureThreshold,omitempty" yaml:"failureThreshold,omitempty" jsonschema:"default=3,min=1"`
}

type HTTPHealthCheckPolicy struct {
	circuitbreaker.CircuitBreaker[int]
	// contains filtered or unexported fields
}

type HTTPHealthCheckPolicyBuilder struct {
	*HTTPHealthCheckPolicy
	// contains filtered or unexported fields
}

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

type HostOption func(*hostOptions)

type LoadBalancer interface {
	Hosts() []*Host
	Next() (*Host, error)
	// StartHealthCheck starts a ticker to run health checking for servers in the background.
	StartHealthCheck(ctx context.Context)
	Close() error
}

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

type ServerMetrics struct {
	// Executions returns the number of executions recorded in the current state when the state is ClosedState or
	// HalfOpenState. When the state is OpenState, this returns the executions recorded during the previous ClosedState.
	//
	// For count based thresholding, the max number of executions is limited to the execution threshold. For time based
	// thresholds, the number of executions may vary within the thresholding period.
	Executions uint `json:"executions"`

	// Failures returns the number of failures recorded in the current state when in a ClosedState or HalfOpenState. When
	// in OpenState, this returns the failures recorded during the previous ClosedState.
	//
	// For count based thresholds, the max number of failures is based on the failure threshold. For time based thresholds,
	// the number of failures may vary within the failure thresholding period.
	Failures uint `json:"failures"`

	// FailureRate returns the rate of failed executions in the current state when in a ClosedState or HalfOpenState. When
	// in OpenState, this returns the rate recorded during the previous ClosedState.
	//
	// The rate is based on the configured failure thresholding capacity.
	FailureRate float64 `json:"failure_rate"`

	// Successes returns the number of successes recorded in the current state when in a ClosedState or HalfOpenState.
	// When in OpenState, this returns the successes recorded during the previous ClosedState.
	//
	// The max number of successes is based on the success threshold.
	Successes uint `json:"successes"`

	// SuccessRate returns rate of successful executions in the current state when in a ClosedState or HalfOpenState. When
	// in OpenState, this returns the successes recorded during the previous ClosedState.
	//
	// The rate is based on the configured success thresholding capacity.
	SuccessRate float64 `json:"success_rate"`
}