更新直接发送请求proto

gongshangguo

2022-03-04 b725ecaef15d8d544aa8a6511a1a4f705441843a

更新直接发送请求proto

 aiotProto/aiot/aiot_business.pb.go

@@ -238,18 +238,20 @@

// 集群请求参数
type ClusterReq struct {
    // 请求的topic url
    Topic string `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"`
    // 集群ID
    ClusterId string `protobuf:"bytes,1,opt,name=clusterId,proto3" json:"clusterId,omitempty"`
    ClusterId string `protobuf:"bytes,2,opt,name=clusterId,proto3" json:"clusterId,omitempty"`
    // token
    Authorization string `protobuf:"bytes,2,opt,name=authorization,proto3" json:"authorization,omitempty"`
    Authorization string `protobuf:"bytes,3,opt,name=authorization,proto3" json:"authorization,omitempty"`
    // 请求的同步/异步类型
    SyncType RequestType `protobuf:"varint,3,opt,name=syncType,proto3,enum=aiot.RequestType" json:"syncType,omitempty"`
    SyncType RequestType `protobuf:"varint,4,opt,name=syncType,proto3,enum=aiot.RequestType" json:"syncType,omitempty"`
    // method
    Method RequestMethod `protobuf:"varint,4,opt,name=method,proto3,enum=aiot.RequestMethod" json:"method,omitempty"`
    Method RequestMethod `protobuf:"varint,5,opt,name=method,proto3,enum=aiot.RequestMethod" json:"method,omitempty"`
    // content-type
    ContentType RequestContentType `protobuf:"varint,5,opt,name=contentType,proto3,enum=aiot.RequestContentType" json:"contentType,omitempty"`
    ContentType RequestContentType `protobuf:"varint,6,opt,name=contentType,proto3,enum=aiot.RequestContentType" json:"contentType,omitempty"`
    // 请求业务参数
    Req                  []byte   `protobuf:"bytes,6,opt,name=req,proto3" json:"req,omitempty"`
    Req                  []byte   `protobuf:"bytes,7,opt,name=req,proto3" json:"req,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
@@ -279,6 +281,13 @@
}

var xxx_messageInfo_ClusterReq proto.InternalMessageInfo

func (m *ClusterReq) GetTopic() string {
    if m != nil {
        return m.Topic
    }
    return ""
}

func (m *ClusterReq) GetClusterId() string {
    if m != nil {
@@ -324,18 +333,20 @@

// 设备列表请求参数
type NodesReq struct {
    // 请求的topic url
    Topic string `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"`
    // 设备列表ID
    NodeIds []string `protobuf:"bytes,1,rep,name=nodeIds,proto3" json:"nodeIds,omitempty"`
    NodeIds []string `protobuf:"bytes,2,rep,name=nodeIds,proto3" json:"nodeIds,omitempty"`
    // token
    Authorization string `protobuf:"bytes,2,opt,name=authorization,proto3" json:"authorization,omitempty"`
    Authorization string `protobuf:"bytes,3,opt,name=authorization,proto3" json:"authorization,omitempty"`
    // 请求的同步/异步类型
    SyncType RequestType `protobuf:"varint,3,opt,name=syncType,proto3,enum=aiot.RequestType" json:"syncType,omitempty"`
    SyncType RequestType `protobuf:"varint,4,opt,name=syncType,proto3,enum=aiot.RequestType" json:"syncType,omitempty"`
    // method
    Method RequestMethod `protobuf:"varint,4,opt,name=method,proto3,enum=aiot.RequestMethod" json:"method,omitempty"`
    Method RequestMethod `protobuf:"varint,5,opt,name=method,proto3,enum=aiot.RequestMethod" json:"method,omitempty"`
    // content-type
    ContentType RequestContentType `protobuf:"varint,5,opt,name=contentType,proto3,enum=aiot.RequestContentType" json:"contentType,omitempty"`
    ContentType RequestContentType `protobuf:"varint,6,opt,name=contentType,proto3,enum=aiot.RequestContentType" json:"contentType,omitempty"`
    // 请求业务参数
    Req                  []byte   `protobuf:"bytes,6,opt,name=req,proto3" json:"req,omitempty"`
    Req                  []byte   `protobuf:"bytes,7,opt,name=req,proto3" json:"req,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
@@ -365,6 +376,13 @@
}

var xxx_messageInfo_NodesReq proto.InternalMessageInfo

func (m *NodesReq) GetTopic() string {
    if m != nil {
        return m.Topic
    }
    return ""
}

func (m *NodesReq) GetNodeIds() []string {
    if m != nil {
@@ -492,42 +510,42 @@

var fileDescriptor_29eca6d4b33e7fd8 = []byte{
    // 597 bytes of a gzipped FileDescriptorProto
    0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0xdc, 0x54, 0x4d, 0x6f, 0xd4, 0x30,
    0x10, 0xad, 0x93, 0xec, 0xd7, 0x6c, 0x77, 0xeb, 0x9d, 0x42, 0x65, 0x55, 0x20, 0x2d, 0x2b, 0x0e,
    0xab, 0x22, 0x7a, 0x28, 0x1c, 0x10, 0xb7, 0xd2, 0x0a, 0xd4, 0x4a, 0x45, 0x95, 0x5b, 0x04, 0x37,
    0x94, 0x3a, 0x86, 0x46, 0x4a, 0xe2, 0x34, 0x76, 0xa8, 0x96, 0x3f, 0xc1, 0x0f, 0xe1, 0xa7, 0x71,
    0xe5, 0xc4, 0x09, 0xd9, 0xc9, 0x92, 0xac, 0x4a, 0x0f, 0xe5, 0xc8, 0xed, 0xcd, 0xbc, 0x79, 0x4e,
    0xde, 0xcc, 0xd8, 0xb0, 0x19, 0xc6, 0xca, 0x7c, 0xbc, 0x28, 0x75, 0x9c, 0x49, 0xad, 0x77, 0xf3,
    0x42, 0x19, 0x85, 0x81, 0x4d, 0x6e, 0x4f, 0x1c, 0x25, 0x54, 0x9a, 0xaa, 0xac, 0x22, 0x66, 0xdf,
    0x3d, 0xe8, 0xbd, 0x55, 0x91, 0xe4, 0xf2, 0x0a, 0xef, 0x41, 0xc7, 0xa8, 0x3c, 0x16, 0x8c, 0x4c,
    0xc9, 0x7c, 0xc0, 0xab, 0x00, 0xb7, 0xa0, 0x9b, 0xa9, 0x48, 0x1e, 0x45, 0xcc, 0x73, 0xe9, 0x3a,
    0xc2, 0xc7, 0x30, 0x0a, 0x4b, 0x73, 0xa9, 0x8a, 0xf8, 0x6b, 0x68, 0x62, 0x95, 0x31, 0xdf, 0xd1,
    0xab, 0x49, 0x1c, 0x83, 0x17, 0xe7, 0x2c, 0x70, 0x94, 0x17, 0xe7, 0x88, 0x10, 0xe4, 0xaa, 0x30,
    0xac, 0xe3, 0x32, 0x0e, 0xe3, 0x53, 0xe8, 0xeb, 0x45, 0x26, 0xce, 0x17, 0xb9, 0x64, 0xdd, 0x29,
    0x99, 0x8f, 0xf7, 0x26, 0xbb, 0xf6, 0x4f, 0x77, 0xb9, 0xbc, 0x2a, 0xa5, 0x36, 0x96, 0xe0, 0x7f,
    0x4a, 0xf0, 0x09, 0x74, 0x53, 0x69, 0x2e, 0x55, 0xc4, 0x7a, 0xae, 0x78, 0x73, 0xa5, 0xf8, 0xc4,
    0x51, 0xbc, 0x2e, 0xc1, 0x97, 0x30, 0x14, 0x2a, 0x33, 0x32, 0x73, 0xa7, 0xb0, 0xbe, 0x53, 0xb0,
    0x15, 0xc5, 0x41, 0xc3, 0xf3, 0x76, 0x31, 0x52, 0xf0, 0x0b, 0x79, 0xc5, 0x06, 0x53, 0x32, 0x5f,
    0xe7, 0x16, 0xce, 0x7e, 0x11, 0x80, 0x83, 0xa4, 0xd4, 0x46, 0x16, 0xb6, 0x61, 0x0f, 0x60, 0x20,
    0xaa, 0xe8, 0x28, 0xaa, 0x9b, 0xd6, 0x24, 0x6e, 0x36, 0xc8, 0xfb, 0x5b, 0x83, 0xda, 0xe6, 0xfd,
    0xbb, 0x98, 0x0f, 0xee, 0x6c, 0xbe, 0xf3, 0x0f, 0xe6, 0xbb, 0x8d, 0xf9, 0x9f, 0x04, 0xfa, 0x76,
    0x55, 0xb4, 0xb5, 0xce, 0xa0, 0x57, 0xed, 0x81, 0x66, 0x64, 0xea, 0xcf, 0x07, 0x7c, 0x19, 0xfe,
    0x77, 0xb6, 0x05, 0x8c, 0x5e, 0xd5, 0x97, 0x89, 0xcb, 0x3c, 0x59, 0xd8, 0x15, 0x16, 0x2a, 0x92,
    0x6e, 0xe0, 0x1d, 0xee, 0xb0, 0x95, 0xa5, 0xfa, 0x73, 0x6d, 0xd5, 0x42, 0xdb, 0x20, 0x5d, 0x0a,
    0x21, 0xb5, 0x76, 0xfe, 0xfa, 0x7c, 0x19, 0x5a, 0x7d, 0x14, 0x9a, 0xd0, 0x39, 0x59, 0xe7, 0x0e,
    0xef, 0xcc, 0x60, 0xd8, 0x32, 0x8e, 0x7d, 0x08, 0xac, 0x75, 0xba, 0x86, 0x03, 0xe8, 0xec, 0x3b,
    0x48, 0x76, 0x8e, 0x61, 0xb4, 0xe2, 0x17, 0x27, 0x30, 0xaa, 0xd0, 0xa1, 0xfc, 0x14, 0x96, 0x89,
    0xa1, 0x6b, 0x56, 0x78, 0xaa, 0xb4, 0xa1, 0x04, 0x7b, 0xe0, 0xbf, 0x91, 0x86, 0x7a, 0x16, 0x9c,
    0x96, 0x86, 0xfa, 0x08, 0xd0, 0x3d, 0x94, 0x89, 0x34, 0x92, 0x06, 0x3b, 0xdf, 0x08, 0xe0, 0xcd,
    0x56, 0xe0, 0x16, 0x60, 0x2b, 0x6c, 0x8e, 0xdd, 0x84, 0x8d, 0xfd, 0x3c, 0x4f, 0x62, 0xe1, 0x86,
    0x77, 0xac, 0x55, 0x46, 0x09, 0x3e, 0x82, 0x87, 0xad, 0xe4, 0x87, 0xf7, 0xd7, 0xd7, 0xaf, 0x55,
    0x91, 0xbe, 0x2b, 0x12, 0x99, 0xd9, 0x9e, 0x44, 0xd4, 0xc3, 0xfb, 0x30, 0x39, 0x29, 0x13, 0x13,
    0xe7, 0x61, 0x61, 0x2c, 0x79, 0x18, 0x9a, 0x90, 0xfa, 0x88, 0x30, 0x6e, 0x2b, 0xd3, 0x84, 0x06,
    0x7b, 0x3f, 0x08, 0x0c, 0xf7, 0x63, 0x65, 0xce, 0x64, 0xf1, 0x25, 0x16, 0x12, 0xf7, 0x00, 0xce,
    0x64, 0x16, 0x9d, 0x2b, 0xbb, 0x72, 0x38, 0xaa, 0xa6, 0x57, 0xbf, 0x54, 0xdb, 0xf5, 0xf8, 0x57,
    0xe6, 0x32, 0x5b, 0xc3, 0x17, 0xb0, 0x61, 0x35, 0xee, 0x98, 0x45, 0x26, 0xec, 0x9e, 0x8e, 0xab,
    0xca, 0x53, 0xfb, 0xd8, 0x09, 0x95, 0xdc, 0xae, 0x1c, 0x55, 0x5f, 0xab, 0x6f, 0x37, 0xd2, 0xaa,
    0xae, 0xb9, 0xec, 0xb7, 0x29, 0x9f, 0xc3, 0xb0, 0xf9, 0x4f, 0xbd, 0xfc, 0xde, 0xf2, 0x9e, 0xdc,
    0xa2, 0xba, 0xe8, 0xba, 0xd7, 0xf7, 0xd9, 0xef, 0x00, 0x00, 0x00, 0xff, 0xff, 0x9b, 0xed, 0x33,
    0xac, 0xad, 0x05, 0x00, 0x00,
    0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0xdc, 0x54, 0xcf, 0x6e, 0xd3, 0x4e,
    0x10, 0xae, 0xff, 0xc4, 0x49, 0x26, 0x75, 0xba, 0x99, 0xfe, 0x7e, 0xd5, 0xaa, 0x02, 0x29, 0x44,
    0x1c, 0xa2, 0x22, 0x7a, 0x28, 0x1c, 0x10, 0xb7, 0xd2, 0x0a, 0x44, 0xa5, 0xa2, 0x6a, 0x5b, 0x04,
    0x37, 0xe4, 0xae, 0x17, 0x6a, 0xc9, 0xf6, 0xba, 0xde, 0x35, 0x55, 0x78, 0x04, 0x2e, 0xf0, 0x1e,
    0x3c, 0x1a, 0x2f, 0x81, 0x76, 0xed, 0xd4, 0x8e, 0x50, 0x24, 0xca, 0x91, 0xdb, 0xcc, 0x7c, 0xdf,
    0xb7, 0xf6, 0x7e, 0x33, 0x3b, 0xb0, 0x1d, 0x25, 0x52, 0x7f, 0xb8, 0xac, 0x54, 0x92, 0x0b, 0xa5,
    0xf6, 0x8b, 0x52, 0x6a, 0x89, 0xbe, 0x29, 0xee, 0x4e, 0x2c, 0xc4, 0x65, 0x96, 0xc9, 0xbc, 0x06,
    0x66, 0x3f, 0x5c, 0xe8, 0xbf, 0x91, 0xb1, 0x60, 0xe2, 0x1a, 0xff, 0x83, 0x9e, 0x96, 0x45, 0xc2,
    0xa9, 0x33, 0x75, 0xe6, 0x43, 0x56, 0x27, 0xb8, 0x03, 0x41, 0x2e, 0x63, 0xf1, 0x3a, 0xa6, 0xae,
    0x2d, 0x37, 0x19, 0x3e, 0x84, 0x30, 0xaa, 0xf4, 0x95, 0x2c, 0x93, 0x2f, 0x91, 0x4e, 0x64, 0x4e,
    0x3d, 0x0b, 0xaf, 0x16, 0x71, 0x0c, 0x6e, 0x52, 0x50, 0xdf, 0x42, 0x6e, 0x52, 0x20, 0x82, 0x5f,
    0xc8, 0x52, 0xd3, 0x9e, 0xad, 0xd8, 0x18, 0x1f, 0xc3, 0x40, 0x2d, 0x72, 0x7e, 0xb1, 0x28, 0x04,
    0x0d, 0xa6, 0xce, 0x7c, 0x7c, 0x30, 0xd9, 0x37, 0x7f, 0xba, 0xcf, 0xc4, 0x75, 0x25, 0x94, 0x36,
    0x00, 0xbb, 0xa5, 0xe0, 0x23, 0x08, 0x32, 0xa1, 0xaf, 0x64, 0x4c, 0xfb, 0x96, 0xbc, 0xbd, 0x42,
    0x3e, 0xb5, 0x10, 0x6b, 0x28, 0xf8, 0x1c, 0x46, 0x5c, 0xe6, 0x5a, 0xe4, 0xf6, 0x14, 0x3a, 0xb0,
    0x0a, 0xba, 0xa2, 0x38, 0x6a, 0x71, 0xd6, 0x25, 0x23, 0x01, 0xaf, 0x14, 0xd7, 0x74, 0x38, 0x75,
    0xe6, 0x9b, 0xcc, 0x84, 0xb3, 0xef, 0x2e, 0xc0, 0x51, 0x5a, 0x29, 0x2d, 0xca, 0xf5, 0x86, 0xdd,
    0x83, 0x21, 0xaf, 0x39, 0xb7, 0x9e, 0xb5, 0x85, 0x3f, 0xb4, 0xad, 0x6b, 0x89, 0x7f, 0x17, 0x4b,
    0x7a, 0x77, 0xb6, 0x24, 0xf8, 0x0b, 0x4b, 0xfa, 0xad, 0x25, 0x5f, 0x5d, 0x18, 0x98, 0x01, 0x52,
    0xeb, 0x0d, 0xa1, 0xd0, 0xaf, 0x67, 0x46, 0x51, 0x77, 0xea, 0xcd, 0x87, 0x6c, 0x99, 0xfe, 0x73,
    0x66, 0x70, 0x08, 0x5f, 0x34, 0x0f, 0x8f, 0x89, 0x22, 0x5d, 0x98, 0x71, 0xe7, 0x32, 0x16, 0xd6,
    0x8f, 0x1e, 0xb3, 0xb1, 0x91, 0x65, 0xea, 0x53, 0x33, 0x19, 0x26, 0x34, 0x06, 0xa9, 0x8a, 0x73,
    0xa1, 0x94, 0x35, 0x60, 0xc0, 0x96, 0xa9, 0xd1, 0xc7, 0x91, 0x8e, 0xec, 0xb5, 0x37, 0x99, 0x8d,
    0xf7, 0x66, 0x30, 0xea, 0x5c, 0x1c, 0x07, 0xe0, 0x9b, 0xab, 0x93, 0x0d, 0x1c, 0x42, 0xef, 0xd0,
    0x86, 0xce, 0xde, 0x09, 0x84, 0x2b, 0xf7, 0xc5, 0x09, 0x84, 0x75, 0x74, 0x2c, 0x3e, 0x46, 0x55,
    0xaa, 0xc9, 0x86, 0x11, 0x9e, 0x49, 0xa5, 0x89, 0x83, 0x7d, 0xf0, 0x5e, 0x09, 0x4d, 0x5c, 0x13,
    0x9c, 0x55, 0x9a, 0x78, 0x08, 0x10, 0x1c, 0x8b, 0x54, 0x68, 0x41, 0xfc, 0xbd, 0x6f, 0x0e, 0xe0,
    0xef, 0x56, 0xe0, 0x0e, 0x60, 0x27, 0x6d, 0x8f, 0xdd, 0x86, 0xad, 0xc3, 0xa2, 0x48, 0x13, 0x6e,
    0x9b, 0x77, 0xa2, 0x64, 0x4e, 0x1c, 0x7c, 0x00, 0xf7, 0x3b, 0xc5, 0xf7, 0xef, 0x6e, 0x6e, 0x5e,
    0xca, 0x32, 0x7b, 0x5b, 0xa6, 0x22, 0x37, 0x9e, 0xc4, 0xc4, 0xc5, 0xff, 0x61, 0x72, 0x5a, 0xa5,
    0x3a, 0x29, 0xa2, 0x52, 0x1b, 0xf0, 0x38, 0xd2, 0x11, 0xf1, 0x10, 0x61, 0xdc, 0x55, 0x66, 0x29,
    0xf1, 0x0f, 0x7e, 0x3a, 0x30, 0x3a, 0x4c, 0xa4, 0x3e, 0x17, 0xe5, 0xe7, 0x84, 0x0b, 0x3c, 0x00,
    0x38, 0x17, 0x79, 0x7c, 0x21, 0xcd, 0x20, 0x62, 0x58, 0x77, 0xaf, 0xd9, 0x6a, 0xbb, 0x4d, 0xfb,
    0x57, 0xfa, 0x32, 0xdb, 0xc0, 0x67, 0xb0, 0x65, 0x34, 0xf6, 0x98, 0x45, 0xce, 0xcd, 0xf4, 0x8e,
    0x6b, 0xe6, 0x99, 0x59, 0x8c, 0x5c, 0xa6, 0xeb, 0x95, 0x61, 0xfd, 0xb5, 0x66, 0x13, 0x20, 0xa9,
    0x79, 0xed, 0x62, 0x58, 0xa7, 0x7c, 0x0a, 0xa3, 0xf6, 0x3f, 0xd5, 0xf2, 0x7b, 0xcb, 0xd7, 0xb3,
    0x46, 0x75, 0x19, 0xd8, 0x4d, 0xfd, 0xe4, 0x57, 0x00, 0x00, 0x00, 0xff, 0xff, 0xc8, 0x35, 0xc6,
    0xfc, 0xd9, 0x05, 0x00, 0x00,
}

 aiotProto/aiot/aiot_business.proto

@@ -59,34 +59,38 @@

// 集群请求参数
message ClusterReq{
    // 请求的topic url
    string topic = 1;
    // 集群ID
    string clusterId = 1;
    string clusterId = 2;
    // token
    string authorization = 2;
    string authorization = 3;
    // 请求的同步/异步类型
    RequestType syncType = 3;
    RequestType syncType = 4;
    // method
    RequestMethod method = 4;
    RequestMethod method = 5;
    // content-type
    RequestContentType contentType = 5;
    RequestContentType contentType = 6;
    // 请求业务参数
    bytes req = 6;
    bytes req = 7;
}

// 设备列表请求参数
message NodesReq{
    // 请求的topic url
    string topic = 1;
    // 设备列表ID
    repeated string nodeIds = 1;
    repeated string nodeIds = 2;
    // token
    string authorization = 2;
    string authorization = 3;
    // 请求的同步/异步类型
    RequestType syncType = 3;
    RequestType syncType = 4;
    // method
    RequestMethod method = 4;
    RequestMethod method = 5;
    // content-type
    RequestContentType contentType = 5;
    RequestContentType contentType = 6;
    // 请求业务参数
    bytes req = 6;
    bytes req = 7;
}

// 响应的body体