nodeprobe

Documentation

Index

• type Prober
  • func NewProber(logger *zap.Logger, nodes ...StatusChecker) *Prober
  • func (p *Prober) IsReady(context.Context) (bool, error)
  • func (p *Prober) Run(ctx context.Context) error
  • func (p *Prober) SetUnreadyHandler(h func())
  • func (p *Prober) Start(ctx context.Context)
  • func (p *Prober) Wait()
• type StatusChecker

Types

type Prober

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

func NewProber

func NewProber(logger *zap.Logger, nodes ...StatusChecker) *Prober

func (*Prober) IsReady

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

func (*Prober) Run

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

func (*Prober) SetUnreadyHandler

func (p *Prober) SetUnreadyHandler(h func())

func (*Prober) Start

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

func (*Prober) Wait

func (p *Prober) Wait()

type StatusChecker

type StatusChecker interface {
	IsReady(ctx context.Context) (bool, error)
}