healthcheck

type ServiceHealthChecker ¶

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

func NewServiceHealthChecker(ctx context.Context, metrics metricsHealthCheck, config *dynamic.ServerHealthCheck, service StatusSetter, info *runtime.ServiceInfo, transport http.RoundTripper, targets map[string]*url.URL) *ServiceHealthChecker

func (shc *ServiceHealthChecker) Launch(ctx context.Context)

type StatusSetter ¶

type StatusSetter interface {
	SetStatus(ctx context.Context, childName string, up bool)
}

StatusSetter should be implemented by a service that, when the status of a registered target change, needs to be notified of that change.

type StatusUpdater ¶

type StatusUpdater interface {
	RegisterStatusUpdater(fn func(up bool)) error
}

StatusUpdater should be implemented by a service that, when its status changes (e.g. all if its children are down), needs to propagate upwards (to their parent(s)) that change.