2018-03-01 07:10:04 +00:00
|
|
|
package healthcheck
|
2017-11-09 16:08:03 +00:00
|
|
|
|
|
|
|
import (
|
2017-11-23 15:10:04 +00:00
|
|
|
"errors"
|
2017-11-09 16:08:03 +00:00
|
|
|
"fmt"
|
|
|
|
"net/http"
|
|
|
|
"os"
|
|
|
|
"time"
|
|
|
|
|
2020-08-17 16:04:03 +00:00
|
|
|
"github.com/traefik/paerser/cli"
|
2020-09-16 13:46:04 +00:00
|
|
|
"github.com/traefik/traefik/v2/pkg/config/static"
|
2017-11-09 16:08:03 +00:00
|
|
|
)
|
|
|
|
|
2019-06-17 09:48:05 +00:00
|
|
|
// NewCmd builds a new HealthCheck command.
|
|
|
|
func NewCmd(traefikConfiguration *static.Configuration, loaders []cli.ResourceLoader) *cli.Command {
|
|
|
|
return &cli.Command{
|
|
|
|
Name: "healthcheck",
|
2019-10-07 13:12:05 +00:00
|
|
|
Description: `Calls Traefik /ping endpoint (disabled by default) to check the health of Traefik.`,
|
2019-06-17 09:48:05 +00:00
|
|
|
Configuration: traefikConfiguration,
|
|
|
|
Run: runCmd(traefikConfiguration),
|
|
|
|
Resources: loaders,
|
2017-11-09 16:08:03 +00:00
|
|
|
}
|
|
|
|
}
|
|
|
|
|
2019-06-17 09:48:05 +00:00
|
|
|
func runCmd(traefikConfiguration *static.Configuration) func(_ []string) error {
|
|
|
|
return func(_ []string) error {
|
2019-07-15 08:22:03 +00:00
|
|
|
traefikConfiguration.SetEffectiveConfiguration()
|
2017-11-09 16:08:03 +00:00
|
|
|
|
2019-06-17 09:48:05 +00:00
|
|
|
resp, errPing := Do(*traefikConfiguration)
|
|
|
|
if resp != nil {
|
|
|
|
resp.Body.Close()
|
|
|
|
}
|
2017-11-09 16:08:03 +00:00
|
|
|
if errPing != nil {
|
|
|
|
fmt.Printf("Error calling healthcheck: %s\n", errPing)
|
|
|
|
os.Exit(1)
|
|
|
|
}
|
2019-06-17 09:48:05 +00:00
|
|
|
|
2017-11-09 16:08:03 +00:00
|
|
|
if resp.StatusCode != http.StatusOK {
|
|
|
|
fmt.Printf("Bad healthcheck status: %s\n", resp.Status)
|
|
|
|
os.Exit(1)
|
|
|
|
}
|
|
|
|
fmt.Printf("OK: %s\n", resp.Request.URL)
|
|
|
|
os.Exit(0)
|
|
|
|
return nil
|
|
|
|
}
|
|
|
|
}
|
2017-11-23 15:10:04 +00:00
|
|
|
|
2020-05-11 10:06:07 +00:00
|
|
|
// Do try to do a healthcheck.
|
2018-11-27 16:42:04 +00:00
|
|
|
func Do(staticConfiguration static.Configuration) (*http.Response, error) {
|
|
|
|
if staticConfiguration.Ping == nil {
|
2018-02-13 22:42:03 +00:00
|
|
|
return nil, errors.New("please enable `ping` to use health check")
|
|
|
|
}
|
2019-06-17 09:48:05 +00:00
|
|
|
|
2019-11-20 17:34:05 +00:00
|
|
|
ep := staticConfiguration.Ping.EntryPoint
|
|
|
|
if ep == "" {
|
|
|
|
ep = "traefik"
|
|
|
|
}
|
|
|
|
|
|
|
|
pingEntryPoint, ok := staticConfiguration.EntryPoints[ep]
|
2017-11-23 15:10:04 +00:00
|
|
|
if !ok {
|
2019-11-20 17:34:05 +00:00
|
|
|
return nil, fmt.Errorf("ping: missing %s entry point", ep)
|
2017-11-23 15:10:04 +00:00
|
|
|
}
|
|
|
|
|
|
|
|
client := &http.Client{Timeout: 5 * time.Second}
|
|
|
|
protocol := "http"
|
2018-11-27 16:42:04 +00:00
|
|
|
|
2019-03-14 08:30:04 +00:00
|
|
|
// FIXME Handle TLS on ping etc...
|
|
|
|
// if pingEntryPoint.TLS != nil {
|
|
|
|
// protocol = "https"
|
|
|
|
// tr := &http.Transport{
|
|
|
|
// TLSClientConfig: &tls.Config{InsecureSkipVerify: true},
|
|
|
|
// }
|
|
|
|
// client.Transport = tr
|
|
|
|
// }
|
2018-11-27 16:42:04 +00:00
|
|
|
|
2017-12-06 10:20:03 +00:00
|
|
|
path := "/"
|
2018-07-31 17:28:03 +00:00
|
|
|
|
2020-02-11 00:26:04 +00:00
|
|
|
return client.Head(protocol + "://" + pingEntryPoint.GetAddress() + path + "ping")
|
2017-11-23 15:10:04 +00:00
|
|
|
}
|