traefik/healthcheck/healthcheck.go

package healthcheck

import (
	"context"
	"github.com/containous/traefik/log"
	"github.com/vulcand/oxy/roundrobin"
	"net/http"
	"net/url"
	"sync"
	"time"
)

var singleton *HealthCheck
var once sync.Once

// GetHealthCheck Get HealtchCheck Singleton
func GetHealthCheck() *HealthCheck {
	once.Do(func() {
		singleton = newHealthCheck()
	})
	return singleton
}

// BackendHealthCheck HealthCheck configuration for a backend
type BackendHealthCheck struct {
	URL          string
	DisabledURLs []*url.URL
	lb           loadBalancer
}

var launch = false

//HealthCheck struct
type HealthCheck struct {
	Backends map[string]*BackendHealthCheck
	cancel   context.CancelFunc
}

type loadBalancer interface {
	RemoveServer(u *url.URL) error
	UpsertServer(u *url.URL, options ...roundrobin.ServerOption) error
	Servers() []*url.URL
}

func newHealthCheck() *HealthCheck {
	return &HealthCheck{make(map[string]*BackendHealthCheck), nil}
}

// NewBackendHealthCheck Instantiate a new BackendHealthCheck
func NewBackendHealthCheck(URL string, lb loadBalancer) *BackendHealthCheck {
	return &BackendHealthCheck{URL, nil, lb}
}

//SetBackendsConfiguration set backends configuration
func (hc *HealthCheck) SetBackendsConfiguration(backends map[string]*BackendHealthCheck) {
	hc.Backends = backends
	if hc.cancel != nil {
		hc.cancel()
	}
	ctx, cancel := context.WithCancel(context.Background())
	hc.cancel = cancel
	hc.execute(ctx)
}

func (hc *HealthCheck) execute(ctx context.Context) {
	for backendID, backend := range hc.Backends {
		go func(backendID string, backend *BackendHealthCheck) {
			for {
				ticker := time.NewTicker(time.Second * 30)
				select {
				case <-ctx.Done():
					log.Debugf("Refreshing All Healthcheck goroutines")
					return
				case <-ticker.C:
					log.Debugf("Refreshing Healthcheck for backend %s ", backendID)
					enabledURLs := backend.lb.Servers()
					var newDisabledURLs []*url.URL
					for _, url := range backend.DisabledURLs {
						if testHealth(url, backend.URL) {
							log.Debugf("Upsert %s", url.String())
							backend.lb.UpsertServer(url, roundrobin.Weight(1))
						} else {
							newDisabledURLs = append(newDisabledURLs, url)
						}
					}
					backend.DisabledURLs = newDisabledURLs

					for _, url := range enabledURLs {
						if !testHealth(url, backend.URL) {
							log.Debugf("Remove %s", url.String())
							backend.lb.RemoveServer(url)
							backend.DisabledURLs = append(backend.DisabledURLs, url)
						}
					}

				}
			}
		}(backendID, backend)
	}
}

func testHealth(serverURL *url.URL, checkURL string) bool {
	timeout := time.Duration(5 * time.Second)
	client := http.Client{
		Timeout: timeout,
	}
	resp, err := client.Get(serverURL.String() + checkURL)
	if err != nil || resp.StatusCode != 200 {
		return false
	}
	return true
}