prober

Documentation

Index

• type Prober
  • func NewProber(ctx context.Context, cancel context.CancelFunc) Prober
• type Watcher

Types

type Prober

type Prober interface {
	GetServiceHealthy(serviceName string) (*v1.HealthStatus, bool)
	GetCurrentServiceHealthy(serviceName string) (*v1.HealthStatus, error)
	WatchServiceHealthy(serviceName string) Watcher
	CloseWatch(serviceName string, id string) error
	Start()
	AddServices(in []*v1.Service)
	CheckAndAddService(in *v1.Service) bool
	SetServices([]*v1.Service)
	GetServices() []*v1.Service
	GetServiceHealth() map[string]*v1.HealthStatus
	SetAndUpdateServices([]*v1.Service) error
	AddAndUpdateServices([]*v1.Service) error
	UpdateServicesProbe(services []*v1.Service)
	Stop() error
	DisableWatcher(serviceName, watcherID string)
	EnableWatcher(serviceName, watcherID string)
	GetProbe(name string) probe.Probe
	StopProbes(names []string)
}

Prober Prober

func NewProber

func NewProber(ctx context.Context, cancel context.CancelFunc) Prober

NewProber creates a new prober.

type Watcher

type Watcher interface {
	GetID() string
	GetServiceName() string
	Watch() <-chan *v1.HealthStatus
	Close() error
}

Watcher watcher