prober

Documentation

Index

• type HealthOption
  • func (ho *HealthOption) Equal(h HealthOption) bool
• type Manager
  • func NewManager(ctx context.Context, handler updateCondition) *Manager
  • func (m *Manager) AddWorker(uid string, address string, option HealthOption) error
  • func (m *Manager) GetWorkerHealthOptionMap(uid string) (map[string]HealthOption, error)
  • func (m *Manager) RemoveWorker(uid, address string) (int, error)
  • func (m *Manager) RemoveWorkersByUid(uid string) (int, error)
• type Prober
• type Worker
• type WorkerMap

Types

type HealthOption

type HealthOption struct {
	Address          string
	SuccessThreshold uint
	FailureThreshold uint
	Timeout          time.Duration
	Period           time.Duration
	InitialCondition bool
}

func (*HealthOption) Equal

func (ho *HealthOption) Equal(h HealthOption) bool

type Manager

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

func NewManager

func NewManager(ctx context.Context, handler updateCondition) *Manager

func (*Manager) AddWorker

func (m *Manager) AddWorker(uid string, address string, option HealthOption) error

func (*Manager) GetWorkerHealthOptionMap

func (m *Manager) GetWorkerHealthOptionMap(uid string) (map[string]HealthOption, error)

func (*Manager) RemoveWorker

func (m *Manager) RemoveWorker(uid, address string) (int, error)

func (*Manager) RemoveWorkersByUid

func (m *Manager) RemoveWorkersByUid(uid string) (int, error)

type Prober

type Prober interface {
	Probe(address string, timeout time.Duration) error
}

type Worker

type Worker struct {
	HealthOption
	// contains filtered or unexported fields
}

type WorkerMap

type WorkerMap map[string]*Worker