blackteay/open-im-server
1
0
Fork 0
mirror of https://github.com/openimsdk/open-im-server.git synced 2025-04-06 04:15:46 +08:00
Code Issues Packages Projects Releases Wiki Activity

config

Browse Source
This commit is contained in:
wenxu12345 2022-04-29 16:33:01 +08:00
parent 03320e8644
commit 3c2e8dcf87
1 changed files with 9 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
pkg/grpc-etcdv3/getcdv3/resolver.go
View File

@ -44,12 +44,16 @@ func NewResolver(schema, etcdAddr, serviceName string) (*Resolver, error) {
r.etcdAddr = etcdAddr r.etcdAddr = etcdAddr
resolver.Register(&r) resolver.Register(&r)
conn, err := grpc.Dial( ctx, _ := context.WithTimeout(context.TODO(), time.Second*5)
GetPrefix(schema, serviceName), conn, err := grpc.DialContext(ctx, GetPrefix(schema, serviceName),
grpc.WithDefaultServiceConfig(fmt.Sprintf(`{"LoadBalancingPolicy": "%s"}`, roundrobin.Name)), grpc.WithDefaultServiceConfig(fmt.Sprintf(`{"LoadBalancingPolicy": "%s"}`, roundrobin.Name)),
grpc.WithInsecure(), grpc.WithInsecure())
grpc.WithTimeout(time.Duration(5)*time.Second), //conn, err := grpc.Dial(
) // GetPrefix(schema, serviceName),
// grpc.WithDefaultServiceConfig(fmt.Sprintf(`{"LoadBalancingPolicy": "%s"}`, roundrobin.Name)),
// grpc.WithInsecure(),
// grpc.WithTimeout(time.Duration(5)*time.Second),
//)
if err == nil { if err == nil {
r.grpcClientConn = conn r.grpcClientConn = conn
} }