github/kubernetes
1
0
Fork 0
mirror of https://github.com/k3s-io/kubernetes.git synced 2025-07-23 11:50:44 +00:00
Code Issues Projects Releases Wiki Activity

added healthz check to the proxy with configurable port

Browse Source
This commit is contained in:
Mike Danese 2014-11-21 09:06:36 -08:00
parent 162e4983b9
commit 5bda95f9fe
2 changed files with 16 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
cmd/kube-proxy/proxy.go
View File

@ -19,10 +19,13 @@ package main
import ( import (
"flag" "flag"
"net" "net"
"net/http"
"strconv"
"time" "time"
"github.com/GoogleCloudPlatform/kubernetes/pkg/api" "github.com/GoogleCloudPlatform/kubernetes/pkg/api"
"github.com/GoogleCloudPlatform/kubernetes/pkg/client" "github.com/GoogleCloudPlatform/kubernetes/pkg/client"
_ "github.com/GoogleCloudPlatform/kubernetes/pkg/healthz"
"github.com/GoogleCloudPlatform/kubernetes/pkg/proxy" "github.com/GoogleCloudPlatform/kubernetes/pkg/proxy"
"github.com/GoogleCloudPlatform/kubernetes/pkg/proxy/config" "github.com/GoogleCloudPlatform/kubernetes/pkg/proxy/config"
"github.com/GoogleCloudPlatform/kubernetes/pkg/util" "github.com/GoogleCloudPlatform/kubernetes/pkg/util"
@ -38,6 +41,7 @@ var (
etcdConfigFile = flag.String("etcd_config", "", "The config file for the etcd client. Mutually exclusive with -etcd_servers") etcdConfigFile = flag.String("etcd_config", "", "The config file for the etcd client. Mutually exclusive with -etcd_servers")
bindAddress = util.IP(net.ParseIP("0.0.0.0")) bindAddress = util.IP(net.ParseIP("0.0.0.0"))
clientConfig = &client.Config{} clientConfig = &client.Config{}
healthz_port = flag.Int("healthz_port", 10249, "The port to bind the health check server. Use 0 to disable.")
) )
func init() { func init() {
@ -100,6 +104,15 @@ func main() {
} }
} }
if *healthz_port > 0 {
go util.Forever(func() {
err := http.ListenAndServe(bindAddress.String()+":"+strconv.Itoa(*healthz_port), nil)
if err != nil {
glog.Errorf("Starting health server failed: %v", err)
}
}, 5*time.Second)
}
protocol := iptables.ProtocolIpv4 protocol := iptables.ProtocolIpv4
if net.IP(bindAddress).To4() == nil { if net.IP(bindAddress).To4() == nil {
protocol = iptables.ProtocolIpv6 protocol = iptables.ProtocolIpv6

3
pkg/master/ports/ports.go
View File

@ -26,4 +26,7 @@ const (
// ControllerManagerPort is the default port for the controller manager status server. // ControllerManagerPort is the default port for the controller manager status server.
// May be overridden by a flag at startup. // May be overridden by a flag at startup.
ControllerManagerPort = 10252 ControllerManagerPort = 10252
// ProxyPort is the default port for the proxy status server.
// May be overriden by a flag at startup.
ProxyPort = 10249
) )