// Wait until we can connect to each of the Vault cluster Instances
Wait until we can connect to each of the Vault cluster Instances
// Wait until we can connect to each of the Vault cluster Instances
func verifyCanSsh(t *testing.T, cluster *VaultCluster, bastionHost *ssh.Host) {
	for _, host := range cluster.GetSshHosts() {
		if host.Hostname != "" {
			maxRetries := 30
			sleepBetweenRetries := 10 * time.Second
			description := fmt.Sprintf("Attempting SSH connection to %s\n", host.Hostname)
			retry.DoWithRetry(t, description, maxRetries, sleepBetweenRetries, func() (string, error) {
				return runCommand(t, bastionHost, &host, "exit")
			})
		}
	}
}
func verifyCanSsh ( t * testing . T , cluster * VaultCluster , bastionHost * ssh . Host ) { for _ , host := range cluster . GetSshHosts ( ) { if host . Hostname != " " { maxRetries := 30 sleepBetweenRetries := 10 * time . Second description := fmt . Sprintf ( " \n " , host . Hostname ) retry . DoWithRetry ( t , description , maxRetries , sleepBetweenRetries , func ( ) ( string , error ) { return runCommand ( t , bastionHost , & host , " " ) } ) } } }
Wait until we can connect to each of the Vault cluster Instances
Wait until we can connect to each of the Vault cluster Instances