Add etcd as a service discovery mechanism

This commit is contained in:
skiffer-git
2024-05-13 15:04:59 +08:00
parent d786d6984c
commit 3ab01a56f4
3 changed files with 4 additions and 1 deletions
+1
View File
@@ -81,6 +81,7 @@ 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)
conn := conn // loop var safe
wg.Go(func() error {
msgClient := msggateway.NewMsgGatewayClient(conn)