mirror of
https://github.com/openimsdk/open-im-server.git
synced 2025-04-06 04:15:46 +08:00
Add etcd as a service discovery mechanism
This commit is contained in:
parent
5a976e3ef7
commit
8176867543
@ -2,6 +2,7 @@ package push
|
||||
|
||||
import (
|
||||
"context"
|
||||
"fmt"
|
||||
"github.com/openimsdk/protocol/msggateway"
|
||||
"github.com/openimsdk/protocol/sdkws"
|
||||
"github.com/openimsdk/tools/discovery"
|
||||
@ -86,7 +87,8 @@ func (d *DefaultAllNode) GetConnsAndOnlinePush(ctx context.Context, msg *sdkws.M
|
||||
|
||||
// Online push message
|
||||
for _, conn := range conns {
|
||||
log.ZDebug(ctx, "get gateway conn detail ", "conn ", *conn)
|
||||
fmt.Println(ctx, "get gateway conn detail ", "conn ", *conn)
|
||||
|
||||
conn := conn // loop var safe
|
||||
ctx := ctx
|
||||
wg.Go(func() error {
|
||||
|
Loading…
x
Reference in New Issue
Block a user