| | |
| | | ) |
| | | |
| | | var ( |
| | | ApsConn *grpc.ClientConn |
| | | CrmConn *grpc.ClientConn |
| | | SrmConn *grpc.ClientConn |
| | | AdminConn *grpc.ClientConn |
| | | ApsConn *grpc.ClientConn |
| | | CrmConn *grpc.ClientConn |
| | | SrmConn *grpc.ClientConn |
| | | ) |
| | | |
| | | func InitClient() { |
| | |
| | | logx.Errorf("grpc dial product service error: %v", err.Error()) |
| | | return |
| | | } |
| | | if len(conf.GrpcServerConf.AdminAddr) > 0 { |
| | | AdminConn, err = grpc.Dial(conf.GrpcServerConf.AdminAddr, grpc.WithTransportCredentials(insecure.NewCredentials())) |
| | | if err != nil { |
| | | logx.Errorf("grpc dial product service error: %v", err.Error()) |
| | | return |
| | | } |
| | | } |
| | | } |
| | | |
| | | func CloseClient() { |
| | | if AdminConn != nil { |
| | | AdminConn.Close() |
| | | } |
| | | if ApsConn != nil { |
| | | ApsConn.Close() |
| | | } |