Skip to content

Commit

Permalink
fix(main): sync cert for cert cmd (#3891)
Browse files Browse the repository at this point in the history
Signed-off-by: cuisongliu <cuisongliu@qq.com>
  • Loading branch information
cuisongliu committed Sep 18, 2023
1 parent c6ce931 commit cbaf975
Showing 1 changed file with 23 additions and 1 deletion.
24 changes: 23 additions & 1 deletion pkg/runtime/kubernetes/certs.go
Expand Up @@ -60,6 +60,7 @@ func (k *KubeadmRuntime) UpdateCertSANs(certSans []string) error {
k.initCert,
k.saveNewKubeadmConfig,
k.uploadConfigFromKubeadm,
k.syncCert,
k.deleteAPIServer,
k.showKubeadmCert,
}
Expand Down Expand Up @@ -136,7 +137,28 @@ func (k *KubeadmRuntime) InitCertsAndKubeConfigs() error {
}

func (k *KubeadmRuntime) initCert() error {
return k.runPipelines("init cert", k.GenerateCert, k.SendNewCertAndKeyToMasters)
return k.runPipelines("init cert", k.GenerateCert, func() error {
return k.sendNewCertAndKey([]string{k.getMaster0IPAndPort()})
})
}

func (k *KubeadmRuntime) syncCert() error {
return k.runPipelines("sync all masters cert", func() error {
for _, master := range k.getMasterIPList()[1:] {
logger.Debug("start to generate cert for master %s", master)
err := k.execCert(master)
if err != nil {
return fmt.Errorf("failed to create cert for master %s: %v", master, err)
}

err = k.copyMasterKubeConfig(master)
if err != nil {
return err
}
logger.Info("succeeded generate cert %s as master", master)
}
return nil
})
}

func (k *KubeadmRuntime) showKubeadmCert() error {
Expand Down

0 comments on commit cbaf975

Please sign in to comment.