mirror of
https://github.com/openimsdk/open-im-server.git
synced 2025-04-26 19:46:57 +08:00
update orgnization after update user
This commit is contained in:
parent
ad94857351
commit
eb0a8132d5
@ -99,6 +99,16 @@ func GetConn(schema, etcdaddr, serviceName string) *grpc.ClientConn {
|
|||||||
return r.grpcClientConn
|
return r.grpcClientConn
|
||||||
}
|
}
|
||||||
|
|
||||||
|
func GetDefaultConn(schema, etcdaddr, serviceName string, operationID string) *grpc.ClientConn {
|
||||||
|
conn := GetConn(schema, etcdaddr, serviceName, operationID)
|
||||||
|
if conn != nil {
|
||||||
|
log.NewWarn(operationID, utils.GetSelfFuncName(), schema, etcdaddr, serviceName, "conn is nil")
|
||||||
|
return conn
|
||||||
|
}
|
||||||
|
conn = GetConfigConn(serviceName, operationID)
|
||||||
|
return conn
|
||||||
|
}
|
||||||
|
|
||||||
func (r *Resolver) Build(target resolver.Target, cc resolver.ClientConn, opts resolver.BuildOptions) (resolver.Resolver, error) {
|
func (r *Resolver) Build(target resolver.Target, cc resolver.ClientConn, opts resolver.BuildOptions) (resolver.Resolver, error) {
|
||||||
if r.cli == nil {
|
if r.cli == nil {
|
||||||
return nil, fmt.Errorf("etcd clientv3 client failed, etcd:%s", target)
|
return nil, fmt.Errorf("etcd clientv3 client failed, etcd:%s", target)
|
||||||
|
Loading…
x
Reference in New Issue
Block a user