Add etcd as a service discovery mechanism

2026-04-28 22:39:18 +08:00 · 2024-05-14 12:26:50 +08:00
parent 404cf92ecc
commit c02fd2adc2
1 changed files with 1 additions and 0 deletions
@@ -87,6 +87,7 @@ func (d *DefaultAllNode) GetConnsAndOnlinePush(ctx context.Context, msg *sdkws.M
 	// Online push message
 	for _, conn := range conns {
 		conn := conn // loop var safe
+		ctx := ctx
 		wg.Go(func() error {
 			msgClient := msggateway.NewMsgGatewayClient(conn)
 			reply, err := msgClient.SuperGroupOnlineBatchPushOneMsg(ctx, input)