更新直接发送请求proto

gongshangguo

2022-03-04 413b3bd67675b07d933e7c479269da22453712d3

 aiotProto/aiot/aiot_business.pb.micro.go

@@ -38,8 +38,6 @@
   SendToNode(ctx context.Context, in *NodeReq, opts ...client.CallOption) (*BusinessReply, error)
   // 直接发送同步tcp请求
   SendAiotSyncReq(ctx context.Context, in *Protocol, opts ...client.CallOption) (*BusinessReply, error)
   // 直接发送异步tcp请求
   SendAiotAsyncReq(ctx context.Context, in *Protocol, opts ...client.CallOption) (*BusinessReply, error)
   // 发送群组请求
   SendToCluster(ctx context.Context, in *ClusterReq, opts ...client.CallOption) (*BusinessReply, error)
   // 向多个设备同时发起相同参数请求
@@ -84,16 +82,6 @@
   return out, nil
}

func (c *aiotService) SendAiotAsyncReq(ctx context.Context, in *Protocol, opts ...client.CallOption) (*BusinessReply, error) {
   req := c.c.NewRequest(c.name, "AiotService.SendAiotAsyncReq", in)
   out := new(BusinessReply)
   err := c.c.Call(ctx, req, out, opts...)
   if err != nil {
      return nil, err
   }
   return out, nil
}

func (c *aiotService) SendToCluster(ctx context.Context, in *ClusterReq, opts ...client.CallOption) (*BusinessReply, error) {
   req := c.c.NewRequest(c.name, "AiotService.SendToCluster", in)
   out := new(BusinessReply)
@@ -121,8 +109,6 @@
   SendToNode(context.Context, *NodeReq, *BusinessReply) error
   // 直接发送同步tcp请求
   SendAiotSyncReq(context.Context, *Protocol, *BusinessReply) error
   // 直接发送异步tcp请求
   SendAiotAsyncReq(context.Context, *Protocol, *BusinessReply) error
   // 发送群组请求
   SendToCluster(context.Context, *ClusterReq, *BusinessReply) error
   // 向多个设备同时发起相同参数请求
@@ -133,7 +119,6 @@
   type aiotService interface {
      SendToNode(ctx context.Context, in *NodeReq, out *BusinessReply) error
      SendAiotSyncReq(ctx context.Context, in *Protocol, out *BusinessReply) error
      SendAiotAsyncReq(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
   }
@@ -154,10 +139,6 @@

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

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

func (h *aiotServiceHandler) SendToCluster(ctx context.Context, in *ClusterReq, out *BusinessReply) error {