health

Documentation

Index

• func StartEndpointHealthCheck(endpointAddress string, opts ...Option) chan bool
• type Option
  • func WithFailureThreshold(threshold int) Option
  • func WithInitialDelay(delay time.Duration) Option
  • func WithInterval(interval time.Duration) Option
  • func WithRequestTimeout(timeout time.Duration) Option
  • func WithSuccessStatusCode(code int) Option
• type Server
  • func NewServer(log logger.Logger) Server

Functions

func StartEndpointHealthCheck

func StartEndpointHealthCheck(endpointAddress string, opts ...Option) chan bool

StartEndpointHealthCheck starts a health check on the specified address with the given options. It returns a channel that will emit true if the endpoint is healthy and false if the failure conditions Have been met.

Types

type Option

type Option func(o *healthCheckOptions)

Option is an a function that applies a health check option

func WithFailureThreshold

func WithFailureThreshold(threshold int) Option

WithFailureThreshold sets the failure threshold for the health check

func WithInitialDelay

func WithInitialDelay(delay time.Duration) Option

WithInitialDelay sets the initial delay for the health check

func WithInterval

func WithInterval(interval time.Duration) Option

WithInterval sets the interval for the health check

func WithRequestTimeout

func WithRequestTimeout(timeout time.Duration) Option

WithRequestTimeout sets the request timeout for the health check

func WithSuccessStatusCode

func WithSuccessStatusCode(code int) Option

WithSuccessStatusCode sets the status code for the health check

type Server

type Server interface {
	Run(context.Context, int) error
	Ready()
	NotReady()
}

Server is the interface for the healthz server

func NewServer

func NewServer(log logger.Logger) Server

NewServer returns a new healthz server