diff --git a/internal/client/vault.go b/internal/client/vault.go index c9d5fef9..08f67338 100644 --- a/internal/client/vault.go +++ b/internal/client/vault.go @@ -181,6 +181,7 @@ func (vc *VaultClient) DeleteCredential(ctx context.Context, mountPath, secretPa func (vc *VaultClient) JoinRaftCluster(podip string) error { var req *api.RaftJoinRequest address := fmt.Sprintf("http://%s:8200", podip) + err := vc.c.SetAddress(address) if err != nil { vc.log.Errorf("Error while setting address") @@ -188,10 +189,11 @@ func (vc *VaultClient) JoinRaftCluster(podip string) error { vc.log.Debug("Address", address) leaderInfo, err := vc.c.Sys().Leader() + vc.log.Debug("Leader address",leaderInfo.LeaderAddress) if err != nil { - vc.log.Debugf("Failed to retrieve leader information: %v", err) return err + } if leaderInfo.LeaderAddress == "" { diff --git a/internal/job/vault_seal_watcher.go b/internal/job/vault_seal_watcher.go index e8a74151..4abc67ed 100644 --- a/internal/job/vault_seal_watcher.go +++ b/internal/job/vault_seal_watcher.go @@ -119,7 +119,12 @@ func (v *VaultSealWatcher) Run() { v.log.Errorf("failed to retrieve pod ip, %s", err) return } + err = vc.JoinRaftCluster(podip) + if err != nil { + v.log.Errorf("Failed to join the HA cluster: %v\n", err) + return + } _, unsealKeys, err := vc.GetVaultSecretValuesforMultiInstance() v.log.Debug("Unseal Keys", unsealKeys) if err != nil { @@ -133,12 +138,6 @@ func (v *VaultSealWatcher) Run() { v.log.Errorf("failed to unseal vault, %s", err) return } - err = vc.JoinRaftCluster(podip) - if err != nil { - v.log.Errorf("Failed to join the HA cluster: %v\n", err) - return - - } }