health

Documentation

Index

• type HealthWatcherService
  • func NewHealthWatcherService(agentConfig *config.Config) *HealthWatcherService
  • func (hw *HealthWatcherService) AddHealthWatcher(instances []*mpi.Instance)
  • func (hw *HealthWatcherService) DeleteHealthWatcher(instances []*mpi.Instance)
  • func (hw *HealthWatcherService) InstancesHealth() []*mpi.InstanceHealth
  • func (hw *HealthWatcherService) UpdateHealthWatcher(instances []*mpi.Instance)
  • func (hw *HealthWatcherService) Watch(ctx context.Context, ch chan<- InstanceHealthMessage)
• type InstanceHealthMessage
• type NginxHealthWatcher
  • func NewNginxHealthWatcher() *NginxHealthWatcher
  • func (nhw *NginxHealthWatcher) Health(ctx context.Context, instance *mpi.Instance) (*mpi.InstanceHealth, error)

Types

type HealthWatcherService

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

func NewHealthWatcherService

func NewHealthWatcherService(agentConfig *config.Config) *HealthWatcherService

func (*HealthWatcherService) AddHealthWatcher

func (hw *HealthWatcherService) AddHealthWatcher(instances []*mpi.Instance)

func (*HealthWatcherService) DeleteHealthWatcher

func (hw *HealthWatcherService) DeleteHealthWatcher(instances []*mpi.Instance)

func (*HealthWatcherService) InstancesHealth

func (hw *HealthWatcherService) InstancesHealth() []*mpi.InstanceHealth

func (*HealthWatcherService) UpdateHealthWatcher

func (hw *HealthWatcherService) UpdateHealthWatcher(instances []*mpi.Instance)

func (*HealthWatcherService) Watch

func (hw *HealthWatcherService) Watch(ctx context.Context, ch chan<- InstanceHealthMessage)

type InstanceHealthMessage

type InstanceHealthMessage struct {
	CorrelationID  slog.Attr
	InstanceHealth []*mpi.InstanceHealth
}

type NginxHealthWatcher

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

func NewNginxHealthWatcher

func NewNginxHealthWatcher() *NginxHealthWatcher

func (*NginxHealthWatcher) Health

func (nhw *NginxHealthWatcher) Health(ctx context.Context, instance *mpi.Instance) (*mpi.InstanceHealth, error)