更新直接发送请求proto

gongshangguo

2022-03-04 c221d929d2ade5fb2f8a4b2d3c10a18455028a4b

 aiotProto/aiot/aiot_business.pb.micro.go

@@ -37,7 +37,7 @@
   // 发送指向单个设备的请求
   SendToNode(ctx context.Context, in *NodeReq, opts ...client.CallOption) (*BusinessReply, error)
   // 直接发送tcp请求
   SendAiotReq(ctx context.Context, in *Protocol, opts ...client.CallOption) (*Protocol, error)
   SendAiotReq(ctx context.Context, in *Protocol, opts ...client.CallOption) (*BusinessReply, error)
   // 发送群组请求
   SendToCluster(ctx context.Context, in *ClusterReq, opts ...client.CallOption) (*BusinessReply, error)
   // 向多个设备同时发起相同参数请求
@@ -72,9 +72,9 @@
   return out, nil
}

func (c *aiotService) SendAiotReq(ctx context.Context, in *Protocol, opts ...client.CallOption) (*Protocol, error) {
func (c *aiotService) SendAiotReq(ctx context.Context, in *Protocol, opts ...client.CallOption) (*BusinessReply, error) {
   req := c.c.NewRequest(c.name, "AiotService.SendAiotReq", in)
   out := new(Protocol)
   out := new(BusinessReply)
   err := c.c.Call(ctx, req, out, opts...)
   if err != nil {
      return nil, err
@@ -108,7 +108,7 @@
   // 发送指向单个设备的请求
   SendToNode(context.Context, *NodeReq, *BusinessReply) error
   // 直接发送tcp请求
   SendAiotReq(context.Context, *Protocol, *Protocol) error
   SendAiotReq(context.Context, *Protocol, *BusinessReply) error
   // 发送群组请求
   SendToCluster(context.Context, *ClusterReq, *BusinessReply) error
   // 向多个设备同时发起相同参数请求
@@ -118,7 +118,7 @@
func RegisterAiotServiceHandler(s server.Server, hdlr AiotServiceHandler, opts ...server.HandlerOption) error {
   type aiotService interface {
      SendToNode(ctx context.Context, in *NodeReq, out *BusinessReply) error
      SendAiotReq(ctx context.Context, in *Protocol, out *Protocol) error
      SendAiotReq(ctx context.Context, in *Protocol, out *BusinessReply) error
      SendToCluster(ctx context.Context, in *ClusterReq, out *BusinessReply) error
      SendToNodes(ctx context.Context, in *NodesReq, out *BusinessReply) error
   }
@@ -137,7 +137,7 @@
   return h.AiotServiceHandler.SendToNode(ctx, in, out)
}

func (h *aiotServiceHandler) SendAiotReq(ctx context.Context, in *Protocol, out *Protocol) error {
func (h *aiotServiceHandler) SendAiotReq(ctx context.Context, in *Protocol, out *BusinessReply) error {
   return h.AiotServiceHandler.SendAiotReq(ctx, in, out)
}