| | |
|---|
| | | package client |
|---|
| | | |
|---|
| | | import ( |
|---|
| | | "google.golang.org/grpc" |
|---|
| | | "google.golang.org/grpc/credentials/insecure" |
|---|
| | | "wms/conf" |
|---|
| | | "wms/pkg/logx" |
|---|
| | | ) |
|---|
| | | |
|---|
| | | var ( |
|---|
| | | ClientConn *grpc.ClientConn |
|---|
| | | ) |
|---|
| | | |
|---|
| | | func InitConn() { |
|---|
| | | var err error |
|---|
| | | ClientConn, err = grpc.Dial(conf.GrpcServerConf.CrmAddr, grpc.WithTransportCredentials(insecure.NewCredentials())) |
|---|
| | | if err != nil { |
|---|
| | | logx.Errorf("grpc dial product service error: %v", err.Error()) |
|---|
| | | return |
|---|
| | | } |
|---|
| | | } |
|---|
| | | |
|---|
| | | func CloseConn() { |
|---|
| | | if ClientConn != nil { |
|---|
| | | ClientConn.Close() |
|---|
| | | } |
|---|
| | | } |
|---|
| | | //var ( |
|---|
| | | // ClientConn *grpc.ClientConn |
|---|
| | | //) |
|---|
| | | // |
|---|
| | | //func InitConn() { |
|---|
| | | // var err error |
|---|
| | | // ClientConn, err = grpc.Dial(conf.GrpcServerConf.CrmAddr, grpc.WithTransportCredentials(insecure.NewCredentials())) |
|---|
| | | // if err != nil { |
|---|
| | | // logx.Errorf("grpc dial product service error: %v", err.Error()) |
|---|
| | | // return |
|---|
| | | // } |
|---|
| | | //} |
|---|
| | | // |
|---|
| | | //func CloseConn() { |
|---|
| | | // if ClientConn != nil { |
|---|
| | | // ClientConn.Close() |
|---|
| | | // } |
|---|
| | | //} |
|---|
