mirror of
https://github.com/rancher/rke.git
synced 2025-09-19 18:30:38 +00:00
Remove check for control plane to etcd plane on port 2380
This commit is contained in:
committed by
Alena Prokharchyk
parent
b6ba732816
commit
f6d391b664
@@ -102,6 +102,10 @@ var WorkerPortList = []string{
|
|||||||
KubeletPort,
|
KubeletPort,
|
||||||
}
|
}
|
||||||
|
|
||||||
|
var EtcdClientPortList = []string{
|
||||||
|
EtcdPort1,
|
||||||
|
}
|
||||||
|
|
||||||
func (c *Cluster) deployNetworkPlugin(ctx context.Context) error {
|
func (c *Cluster) deployNetworkPlugin(ctx context.Context) error {
|
||||||
log.Infof(ctx, "[network] Setting up network plugin: %s", c.Network.Plugin)
|
log.Infof(ctx, "[network] Setting up network plugin: %s", c.Network.Plugin)
|
||||||
switch c.Network.Plugin {
|
switch c.Network.Plugin {
|
||||||
@@ -365,12 +369,12 @@ func (c *Cluster) runServicePortChecks(ctx context.Context) error {
|
|||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
// check all -> etcd connectivity
|
// check control -> etcd connectivity
|
||||||
log.Infof(ctx, "[network] Running control plane -> etcd port checks")
|
log.Infof(ctx, "[network] Running control plane -> etcd port checks")
|
||||||
for _, host := range c.ControlPlaneHosts {
|
for _, host := range c.ControlPlaneHosts {
|
||||||
runHost := host
|
runHost := host
|
||||||
errgrp.Go(func() error {
|
errgrp.Go(func() error {
|
||||||
return checkPlaneTCPPortsFromHost(ctx, runHost, EtcdPortList, c.EtcdHosts, c.SystemImages.Alpine, c.PrivateRegistriesMap)
|
return checkPlaneTCPPortsFromHost(ctx, runHost, EtcdClientPortList, c.EtcdHosts, c.SystemImages.Alpine, c.PrivateRegistriesMap)
|
||||||
})
|
})
|
||||||
}
|
}
|
||||||
if err := errgrp.Wait(); err != nil {
|
if err := errgrp.Wait(); err != nil {
|
||||||
|
Reference in New Issue
Block a user