nodeprobe

package

v1.2.0 Latest Latest Go to latest Published: Nov 22, 2023 License: GPL-3.0 Imports: 6 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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

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

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()