From 698ed86c7604c10b616ee9c2733ac57adb74185f Mon Sep 17 00:00:00 2001
From: gongshangguo <gongshangguo@admin.com>
Date: 星期五, 04 三月 2022 16:09:52 +0800
Subject: [PATCH] 更新直接发送请求proto
---
aiotProto/aiot/aiot_business.pb.micro.go | 37 ++++++++++++++++++++++++++++---------
1 files changed, 28 insertions(+), 9 deletions(-)
diff --git a/aiotProto/aiot/aiot_business.pb.micro.go b/aiotProto/aiot/aiot_business.pb.micro.go
index 0df5c72..85ade0b 100644
--- a/aiotProto/aiot/aiot_business.pb.micro.go
+++ b/aiotProto/aiot/aiot_business.pb.micro.go
@@ -36,8 +36,10 @@
type AiotService interface {
// 鍙戦�佹寚鍚戝崟涓澶囩殑璇锋眰
SendToNode(ctx context.Context, in *NodeReq, opts ...client.CallOption) (*BusinessReply, error)
- // 鐩存帴鍙戦�乼cp璇锋眰
- SendAiotReq(ctx context.Context, in *Protocol, opts ...client.CallOption) (*BusinessReply, error)
+ // 鐩存帴鍙戦�佸悓姝cp璇锋眰
+ SendAiotSyncReq(ctx context.Context, in *Protocol, opts ...client.CallOption) (*BusinessReply, error)
+ // 鐩存帴鍙戦�佸紓姝cp璇锋眰
+ SendAiotAsyncReq(ctx context.Context, in *Protocol, opts ...client.CallOption) (*BusinessReply, error)
// 鍙戦�佺兢缁勮姹�
SendToCluster(ctx context.Context, in *ClusterReq, opts ...client.CallOption) (*BusinessReply, error)
// 鍚戝涓澶囧悓鏃跺彂璧风浉鍚屽弬鏁拌姹�
@@ -72,8 +74,18 @@
return out, nil
}
-func (c *aiotService) SendAiotReq(ctx context.Context, in *Protocol, opts ...client.CallOption) (*BusinessReply, error) {
- req := c.c.NewRequest(c.name, "AiotService.SendAiotReq", in)
+func (c *aiotService) SendAiotSyncReq(ctx context.Context, in *Protocol, opts ...client.CallOption) (*BusinessReply, error) {
+ req := c.c.NewRequest(c.name, "AiotService.SendAiotSyncReq", in)
+ out := new(BusinessReply)
+ err := c.c.Call(ctx, req, out, opts...)
+ if err != nil {
+ return nil, err
+ }
+ 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 {
@@ -107,8 +119,10 @@
type AiotServiceHandler interface {
// 鍙戦�佹寚鍚戝崟涓澶囩殑璇锋眰
SendToNode(context.Context, *NodeReq, *BusinessReply) error
- // 鐩存帴鍙戦�乼cp璇锋眰
- SendAiotReq(context.Context, *Protocol, *BusinessReply) error
+ // 鐩存帴鍙戦�佸悓姝cp璇锋眰
+ SendAiotSyncReq(context.Context, *Protocol, *BusinessReply) error
+ // 鐩存帴鍙戦�佸紓姝cp璇锋眰
+ SendAiotAsyncReq(context.Context, *Protocol, *BusinessReply) error
// 鍙戦�佺兢缁勮姹�
SendToCluster(context.Context, *ClusterReq, *BusinessReply) error
// 鍚戝涓澶囧悓鏃跺彂璧风浉鍚屽弬鏁拌姹�
@@ -118,7 +132,8 @@
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 *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
}
@@ -137,8 +152,12 @@
return h.AiotServiceHandler.SendToNode(ctx, in, out)
}
-func (h *aiotServiceHandler) SendAiotReq(ctx context.Context, in *Protocol, out *BusinessReply) error {
- return h.AiotServiceHandler.SendAiotReq(ctx, in, out)
+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 {
--
Gitblit v1.8.0