Compare commits
2 Commits
Author | SHA1 | Date |
---|---|---|
|
cf1e0d30eb | |
|
2313df0bca |
|
@ -9,9 +9,11 @@ import (
|
||||||
"net/http"
|
"net/http"
|
||||||
"os"
|
"os"
|
||||||
"strings"
|
"strings"
|
||||||
|
"time"
|
||||||
{import}
|
{import}
|
||||||
"git.apinb.com/bsm-sdk/core/vars"
|
"git.apinb.com/bsm-sdk/core/vars"
|
||||||
"google.golang.org/grpc"
|
"google.golang.org/grpc"
|
||||||
|
"google.golang.org/grpc/credentials/insecure"
|
||||||
"google.golang.org/grpc/reflection"
|
"google.golang.org/grpc/reflection"
|
||||||
"google.golang.org/protobuf/proto"
|
"google.golang.org/protobuf/proto"
|
||||||
gwRuntime "github.com/grpc-ecosystem/grpc-gateway/v2/runtime"
|
gwRuntime "github.com/grpc-ecosystem/grpc-gateway/v2/runtime"
|
||||||
|
@ -41,7 +43,7 @@ func New(addr string) *Server {
|
||||||
conn, ok := srv.grpcConns[addr]
|
conn, ok := srv.grpcConns[addr]
|
||||||
if !ok {
|
if !ok {
|
||||||
var err error
|
var err error
|
||||||
conn, err = grpc.Dial(addr, grpc.WithInsecure())
|
conn, err = grpc.NewClient(addr, grpc.WithTransportCredentials(insecure.NewCredentials()))
|
||||||
if err != nil {
|
if err != nil {
|
||||||
panic("failed to dial grpc server: " + err.Error())
|
panic("failed to dial grpc server: " + err.Error())
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in New Issue