From 096eeb97ce9f6b0c8b69cd0fbf58d6820229e113 Mon Sep 17 00:00:00 2001 From: Konstantin Lebedev <9497591+kmlebedev@users.noreply.github.com> Date: Mon, 9 Dec 2024 22:59:59 +0200 Subject: [PATCH] fix NewTCClient (#24) Co-authored-by: whitefox --- client/main.go | 4 ++++ proto/connect.pb.go | 7 ++++--- proto/connect.proto | 2 +- proto/connect_grpc.pb.go | 2 +- 4 files changed, 10 insertions(+), 5 deletions(-) diff --git a/client/main.go b/client/main.go index 71712a3..4c99614 100644 --- a/client/main.go +++ b/client/main.go @@ -6,6 +6,8 @@ import ( "fmt" log "github.com/sirupsen/logrus" "google.golang.org/grpc" + "google.golang.org/grpc/connectivity" + "google.golang.org/grpc/credentials/insecure" "io" "os" "strings" @@ -88,12 +90,14 @@ func NewTCClient() (*TCClient, error) { log.Infoln("gRPC client running ...") conn, err := grpc.NewClient( os.Getenv("TC_TARGET"), + grpc.WithTransportCredentials(insecure.NewCredentials()), grpc.WithDefaultCallOptions(grpc.WaitForReady(true)), ) if err != nil { log.Error("grpc.Dial()", err) return nil, err } + conn.WaitForStateChange(context.Background(), connectivity.Ready) client := pb.NewConnectServiceClient(conn) return NewTCClientWithConn(client, conn) } diff --git a/proto/connect.pb.go b/proto/connect.pb.go index decd62d..3e9d155 100644 --- a/proto/connect.pb.go +++ b/proto/connect.pb.go @@ -4,7 +4,7 @@ // protoc v5.29.1 // source: proto/connect.proto -package proto +package transaqConnector import ( protoreflect "google.golang.org/protobuf/reflect/protoreflect" @@ -226,10 +226,11 @@ var file_proto_connect_proto_rawDesc = []byte{ 0x65, 0x6e, 0x64, 0x43, 0x6f, 0x6d, 0x6d, 0x61, 0x6e, 0x64, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x25, 0x2e, 0x74, 0x72, 0x61, 0x6e, 0x73, 0x61, 0x71, 0x43, 0x6f, 0x6e, 0x6e, 0x65, 0x63, 0x74, 0x6f, 0x72, 0x2e, 0x53, 0x65, 0x6e, 0x64, 0x43, 0x6f, 0x6d, 0x6d, 0x61, 0x6e, 0x64, - 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x00, 0x42, 0x2a, 0x5a, 0x28, 0x67, 0x69, + 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x00, 0x42, 0x35, 0x5a, 0x33, 0x67, 0x69, 0x74, 0x68, 0x75, 0x62, 0x2e, 0x63, 0x6f, 0x6d, 0x2f, 0x6b, 0x6d, 0x6c, 0x65, 0x62, 0x65, 0x64, 0x65, 0x76, 0x2f, 0x74, 0x78, 0x6d, 0x6c, 0x63, 0x6f, 0x6e, 0x6e, 0x65, 0x63, 0x74, 0x6f, 0x72, - 0x2f, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x06, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x33, + 0x2f, 0x74, 0x72, 0x61, 0x6e, 0x73, 0x61, 0x71, 0x43, 0x6f, 0x6e, 0x6e, 0x65, 0x63, 0x74, 0x6f, + 0x72, 0x62, 0x06, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x33, } var ( diff --git a/proto/connect.proto b/proto/connect.proto index 66900fe..afbc4d7 100644 --- a/proto/connect.proto +++ b/proto/connect.proto @@ -1,6 +1,6 @@ syntax = "proto3"; -option go_package = "github.com/kmlebedev/txmlconnector/proto"; +option go_package = "github.com/kmlebedev/txmlconnector/transaqConnector"; package transaqConnector; message DataRequest { diff --git a/proto/connect_grpc.pb.go b/proto/connect_grpc.pb.go index 32c2c26..b7bcb04 100644 --- a/proto/connect_grpc.pb.go +++ b/proto/connect_grpc.pb.go @@ -4,7 +4,7 @@ // - protoc v5.29.1 // source: proto/connect.proto -package proto +package transaqConnector import ( context "context"