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