Skip to content

Commit ea3716e

Browse files
feat: Add print for network develop
1 parent 906c7ec commit ea3716e

File tree

1 file changed

+5
-0
lines changed

1 file changed

+5
-0
lines changed

pkg/liqoctl/network/handler.go

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -16,6 +16,7 @@ package network
1616

1717
import (
1818
"context"
19+
"fmt"
1920
"time"
2021

2122
corev1 "k8s.io/api/core/v1"
@@ -248,18 +249,22 @@ func (o *Options) RunConnect(ctx context.Context) error {
248249
// Wait for Connections on both cluster to be created.
249250
conn2, err := cluster2.waiter.ForConnection(ctx, gwServer.Namespace, cluster1.localClusterID)
250251
if err != nil {
252+
fmt.Print("GeneveTunnel doasn't exists in provider")
251253
return err
252254
}
253255
conn1, err := cluster1.waiter.ForConnection(ctx, gwClient.Namespace, cluster2.localClusterID)
254256
if err != nil {
257+
fmt.Print("GeneveTunnel doasn't exists in consumer")
255258
return err
256259
}
257260

258261
// Wait for Connections on both cluster cluster to be established
259262
if err := cluster1.waiter.ForConnectionEstablished(ctx, conn1); err != nil {
263+
fmt.Printf("Connection failed: port %v on cluster %v is closed or unreachable (IP: %v)\n", gwServer.Spec.Endpoint.Port, gwServer.Name, gwClient.Status.InternalEndpoint.IP)
260264
return err
261265
}
262266
if err := cluster2.waiter.ForConnectionEstablished(ctx, conn2); err != nil {
267+
fmt.Printf("Connection failed: port %v on cluster %v is closed or unreachable (IP: %v)\n", gwClient.Spec.Endpoint.Port, gwClient.Name, gwClient.Status.InternalEndpoint.IP)
263268
return err
264269
}
265270
}

0 commit comments

Comments
 (0)