diff --git a/cluster/state.go b/cluster/state.go index 06decc6e9..69680b85d 100644 --- a/cluster/state.go +++ b/cluster/state.go @@ -52,6 +52,9 @@ func (c *Cluster) GetClusterState() (*Cluster, error) { if err != nil { return nil, fmt.Errorf("Failed to Get Kubernetes certificates: %v", err) } + // setting cluster defaults for the fetched cluster as well + currentCluster.setClusterDefaults() + if err := currentCluster.InvertIndexHosts(); err != nil { return nil, fmt.Errorf("Failed to classify hosts from fetched cluster: %v", err) } diff --git a/services/proxy.go b/services/proxy.go index 61de7f611..9d966e1c6 100644 --- a/services/proxy.go +++ b/services/proxy.go @@ -17,7 +17,9 @@ func RollingUpdateNginxProxy(cpHosts []hosts.Host, workerHosts []hosts.Host) err nginxProxyEnv := buildProxyEnv(cpHosts) for _, host := range workerHosts { imageCfg, hostCfg := buildNginxProxyConfig(host, nginxProxyEnv) - return docker.DoRollingUpdateContainer(host.DClient, imageCfg, hostCfg, NginxProxyContainerName, host.Address, WorkerRole) + if err := docker.DoRollingUpdateContainer(host.DClient, imageCfg, hostCfg, NginxProxyContainerName, host.Address, WorkerRole); err != nil { + return err + } } return nil }