mirror of
https://github.com/k3s-io/kubernetes.git
synced 2025-08-05 10:19:50 +00:00
select one api endpoint at random instead of erroneously using all of them
This commit is contained in:
parent
7b841fe77e
commit
6002481524
@ -15,6 +15,7 @@
|
|||||||
# limitations under the License.
|
# limitations under the License.
|
||||||
|
|
||||||
import os
|
import os
|
||||||
|
import random
|
||||||
import shutil
|
import shutil
|
||||||
|
|
||||||
from shlex import split
|
from shlex import split
|
||||||
@ -319,7 +320,7 @@ def start_worker(kube_api, kube_control, cni):
|
|||||||
# set --allow-privileged flag for kubelet
|
# set --allow-privileged flag for kubelet
|
||||||
set_privileged()
|
set_privileged()
|
||||||
|
|
||||||
create_config(servers[0])
|
create_config(random.choice(servers))
|
||||||
configure_worker_services(servers, dns, cluster_cidr)
|
configure_worker_services(servers, dns, cluster_cidr)
|
||||||
set_state('kubernetes-worker.config.created')
|
set_state('kubernetes-worker.config.created')
|
||||||
restart_unit_services()
|
restart_unit_services()
|
||||||
@ -475,7 +476,7 @@ def configure_worker_services(api_servers, dns, cluster_cidr):
|
|||||||
kube_proxy_opts.add('kubeconfig', kubeconfig_path)
|
kube_proxy_opts.add('kubeconfig', kubeconfig_path)
|
||||||
kube_proxy_opts.add('logtostderr', 'true')
|
kube_proxy_opts.add('logtostderr', 'true')
|
||||||
kube_proxy_opts.add('v', '0')
|
kube_proxy_opts.add('v', '0')
|
||||||
kube_proxy_opts.add('master', ','.join(api_servers), strict=True)
|
kube_proxy_opts.add('master', random.choice(api_servers), strict=True)
|
||||||
|
|
||||||
cmd = ['snap', 'set', 'kubelet'] + kubelet_opts.to_s().split(' ')
|
cmd = ['snap', 'set', 'kubelet'] + kubelet_opts.to_s().split(' ')
|
||||||
check_call(cmd)
|
check_call(cmd)
|
||||||
|
Loading…
Reference in New Issue
Block a user