nodeprobe

Documentation

Index

• type Node
• type Prober
  • func NewProber(logger *zap.Logger, unhealthyHandler func(), nodes map[string]Node) *Prober
  • func (p *Prober) AddNode(name string, node Node)
  • func (p *Prober) Healthy(context.Context) (bool, error)
  • func (p *Prober) Run(ctx context.Context) error
  • func (p *Prober) Start(ctx context.Context)
  • func (p *Prober) Wait()

Types

type Node

type Node interface {
	Healthy(ctx context.Context) error
}

type Prober

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

func NewProber

func NewProber(logger *zap.Logger, unhealthyHandler func(), nodes map[string]Node) *Prober

func (*Prober) AddNode

func (p *Prober) AddNode(name string, node Node)

func (*Prober) Healthy

func (p *Prober) Healthy(context.Context) (bool, error)

func (*Prober) Run

func (p *Prober) Run(ctx context.Context) error

func (*Prober) Start

func (p *Prober) Start(ctx context.Context)

func (*Prober) Wait

func (p *Prober) Wait()