health

Documentation

Index

• type HealthClientSet
• type HealthStatusQuerier
• type HealthStatusUpdater
• type HealthUpdate
• type Listener
  • func NewListener(opts ...ListenerOption) *Listener
  • func (l *Listener) Close()
  • func (l *Listener) HandleAgentConnection(ctx context.Context, clientset agent.ClientSet)
  • func (l *Listener) HandleConnection(ctx context.Context, clientset HealthClientSet)
  • func (l *Listener) HealthC() chan HealthUpdate
  • func (l *Listener) StatusC() chan StatusUpdate
• type ListenerOption
  • func WithMaxConnections(max int64) ListenerOption
  • func WithMaxJitter(duration time.Duration) ListenerOption
  • func WithPollInterval(interval time.Duration) ListenerOption
  • func WithUpdateQueueCap(cap int) ListenerOption
• type ListenerOptions
• type Monitor
  • func NewMonitor(opts ...MonitorOption) *Monitor
  • func (m *Monitor) GetHealthStatus(id string) *corev1.HealthStatus
  • func (m *Monitor) Run(ctx context.Context, updater HealthStatusUpdater)
• type MonitorOption
  • func WithLogger(lg *zap.SugaredLogger) MonitorOption
• type MonitorOptions
• type StatusUpdate

Types

type HealthClientSet

type HealthClientSet interface {
	// rpc GetHealth(emptypb.Empty) returns (core.Health)
	GetHealth(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*corev1.Health, error)
}

type HealthStatusQuerier

type HealthStatusQuerier interface {
	GetHealthStatus(id string) *corev1.HealthStatus
}

type HealthStatusUpdater

type HealthStatusUpdater interface {
	StatusC() chan StatusUpdate
	HealthC() chan HealthUpdate
}

type HealthUpdate

type HealthUpdate struct {
	ID     string         `json:"id"`
	Health *corev1.Health `json:"health"`
}

type Listener

type Listener struct {
	ListenerOptions
	// contains filtered or unexported fields
}

func NewListener

func NewListener(opts ...ListenerOption) *Listener

func (*Listener) Close

func (l *Listener) Close()

func (*Listener) HandleAgentConnection

func (l *Listener) HandleAgentConnection(ctx context.Context, clientset agent.ClientSet)

Implements gateway.ConnectionHandler

func (*Listener) HandleConnection

func (l *Listener) HandleConnection(ctx context.Context, clientset HealthClientSet)

func (*Listener) HealthC

func (l *Listener) HealthC() chan HealthUpdate

func (*Listener) StatusC

func (l *Listener) StatusC() chan StatusUpdate

type ListenerOption

type ListenerOption func(*ListenerOptions)

func WithMaxConnections

func WithMaxConnections(max int64) ListenerOption

Max concurrent connections. Defaults to math.MaxInt64

func WithMaxJitter

func WithMaxJitter(duration time.Duration) ListenerOption

func WithPollInterval

func WithPollInterval(interval time.Duration) ListenerOption

func WithUpdateQueueCap

func WithUpdateQueueCap(cap int) ListenerOption

Max concurrent queued updates before blocking. Defaults to 1000

type ListenerOptions

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

type Monitor

type Monitor struct {
	MonitorOptions
	// contains filtered or unexported fields
}

func NewMonitor

func NewMonitor(opts ...MonitorOption) *Monitor

func (*Monitor) GetHealthStatus

func (m *Monitor) GetHealthStatus(id string) *corev1.HealthStatus

func (*Monitor) Run

func (m *Monitor) Run(ctx context.Context, updater HealthStatusUpdater)

type MonitorOption

type MonitorOption func(*MonitorOptions)

func WithLogger

func WithLogger(lg *zap.SugaredLogger) MonitorOption

type MonitorOptions

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

type StatusUpdate

type StatusUpdate struct {
	ID     string         `json:"id"`
	Status *corev1.Status `json:"status"`
}