healthcheck

package

v0.9.2 Latest Latest Go to latest Published: Feb 24, 2026 License: MIT Imports: 6 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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

HealthChecker is responsible for checking the health of upstream caches.

func New() *HealthChecker

New creates a new HealthChecker.

func (hc *HealthChecker) AddUpstreams(upstreams []*upstream.Cache)

AddUpstream adds a new upstream cache to monitor.

func (hc *HealthChecker) RemoveUpstream(upstream *upstream.Cache)

RemoveUpstream removes an upstream cache from monitoring.

func (hc *HealthChecker) SetHealthChangeNotifier(ch chan<- HealthStatusChange)

SetHealthChangeNotifier sets the channel to notify about health status changes.

func (hc *HealthChecker) Start(ctx context.Context)

Start starts the health checker.

func (hc *HealthChecker) Trigger() chan struct{}

Trigger forces the health check to run now.

type HealthStatusChange struct {
	Upstream  *upstream.Cache
	IsHealthy bool
}

HealthStatusChange represents a change in upstream health status.