diff --git a/cluster/plan.go b/cluster/plan.go index 9f4a0ec0..92d077e5 100644 --- a/cluster/plan.go +++ b/cluster/plan.go @@ -578,9 +578,8 @@ func (c *Cluster) BuildEtcdProcess(host *hosts.Host, etcdHosts []*hosts.Host, pr } Binds = append(Binds, c.Services.Etcd.ExtraBinds...) - healthCheck := v3.HealthCheck{ - URL: services.EtcdHealthCheckURL, + URL: fmt.Sprintf("https://%s:2379/health", host.InternalAddress), } registryAuthConfig, _, _ := docker.GetImageRegistryConfig(c.Services.Etcd.Image, c.PrivateRegistriesMap) diff --git a/services/etcd.go b/services/etcd.go index d2aa09f2..10370666 100644 --- a/services/etcd.go +++ b/services/etcd.go @@ -16,10 +16,6 @@ import ( "github.com/sirupsen/logrus" ) -const ( - EtcdHealthCheckURL = "https://127.0.0.1:2379/health" -) - func RunEtcdPlane(ctx context.Context, etcdHosts []*hosts.Host, etcdNodePlanMap map[string]v3.RKEConfigNodePlan, localConnDialerFactory hosts.DialerFactory, prsMap map[string]v3.PrivateRegistry, updateWorkersOnly bool, alpineImage string) error { log.Infof(ctx, "[%s] Building up etcd plane..", ETCDRole) for _, host := range etcdHosts { diff --git a/services/etcd_util.go b/services/etcd_util.go index 96398b66..04c74bc0 100644 --- a/services/etcd_util.go +++ b/services/etcd_util.go @@ -32,7 +32,7 @@ func getEtcdClient(ctx context.Context, etcdHost *hosts.Host, localConnDialerFac } cfg := etcdclient.Config{ - Endpoints: []string{"https://127.0.0.1:2379"}, + Endpoints: []string{"https://" + etcdHost.InternalAddress + ":2379"}, Transport: DefaultEtcdTransport, }