rancher/rke
1
0
Fork 0
mirror of https://github.com/rancher/rke.git synced 2025-09-17 15:40:07 +00:00
Code Issues Releases Wiki Activity

Update only for pre-pull and log cleanup

Browse Source
This commit is contained in:
moelsayed
2018-03-24 01:45:38 +02:00
parent 0751f86e85
commit 69b629c115
2 changed files with 6 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
cluster/cluster.go
View File

@@ -299,6 +299,9 @@ func (c *Cluster) PrePullK8sImages(ctx context.Context) error {
var errgrp errgroup.Group
hosts := hosts.GetUniqueHostList(c.EtcdHosts, c.ControlPlaneHosts, c.WorkerHosts)
for _, host := range hosts {
if !host.UpdateWorker {
continue
}
runHost := host
errgrp.Go(func() error {
return docker.UseLocalOrPull(ctx, runHost.DClient, runHost.Address, c.SystemImages.Kubernetes, "pre-deploy", c.PrivateRegistriesMap)

3
cluster/logs.go
View File

@@ -19,6 +19,9 @@ func (c *Cluster) CleanDeadLogs(ctx context.Context) error {
var errgrp errgroup.Group
for _, host := range hosts {
if !host.UpdateWorker {
continue
}
runHost := host
errgrp.Go(func() error {
return doRunLogCleaner(ctx, runHost, c.SystemImages.Alpine, c.PrivateRegistriesMap)