return error if unable to connect
All checks were successful
Build and Publish / BuildAndDeploy (push) Successful in 1m54s

This commit is contained in:
matst80
2024-11-10 22:37:39 +01:00
parent c12d40ec81
commit e8643b5899
2 changed files with 2 additions and 1 deletions

View File

@@ -101,7 +101,7 @@ func main() {
var config *rest.Config var config *rest.Config
var kerr error var kerr error
if podIp == "" { if podIp == "" {
config, kerr = clientcmd.BuildConfigFromFlags("", "/home/mats/.kube/config") config, kerr = clientcmd.BuildConfigFromFlags("", "/Users/mats/.kube/config")
} else { } else {
config, kerr = rest.InClusterConfig() config, kerr = rest.InClusterConfig()
} }

View File

@@ -378,6 +378,7 @@ func (p *SyncedPool) AddRemote(host string) error {
client, err := Dial(fmt.Sprintf("%s:1338", host)) client, err := Dial(fmt.Sprintf("%s:1338", host))
if err != nil { if err != nil {
log.Printf("Error connecting to remote %s: %v\n", host, err) log.Printf("Error connecting to remote %s: %v\n", host, err)
return err
} }
_, err = client.Call(Ping, Pong, []byte{}) _, err = client.Call(Ping, Pong, []byte{})