|
@@ -9,7 +9,7 @@ package pb
|
|
|
import (
|
|
|
protoreflect "google.golang.org/protobuf/reflect/protoreflect"
|
|
|
protoimpl "google.golang.org/protobuf/runtime/protoimpl"
|
|
|
- structpb "google.golang.org/protobuf/types/known/structpb"
|
|
|
+ _ "google.golang.org/protobuf/types/known/structpb"
|
|
|
reflect "reflect"
|
|
|
sync "sync"
|
|
|
)
|
|
@@ -81,9 +81,9 @@ type CommandResp struct {
|
|
|
sizeCache protoimpl.SizeCache
|
|
|
unknownFields protoimpl.UnknownFields
|
|
|
|
|
|
- Code int64 `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"`
|
|
|
- Msg string `protobuf:"bytes,2,opt,name=msg,proto3" json:"msg,omitempty"`
|
|
|
- Data *structpb.Struct `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"`
|
|
|
+ Code int64 `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"`
|
|
|
+ Msg string `protobuf:"bytes,2,opt,name=msg,proto3" json:"msg,omitempty"`
|
|
|
+ Data []byte `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"`
|
|
|
}
|
|
|
|
|
|
func (x *CommandResp) Reset() {
|
|
@@ -132,7 +132,7 @@ func (x *CommandResp) GetMsg() string {
|
|
|
return ""
|
|
|
}
|
|
|
|
|
|
-func (x *CommandResp) GetData() *structpb.Struct {
|
|
|
+func (x *CommandResp) GetData() []byte {
|
|
|
if x != nil {
|
|
|
return x.Data
|
|
|
}
|
|
@@ -149,21 +149,19 @@ var file_pb_flowsrv_proto_rawDesc = []byte{
|
|
|
0x65, 0x71, 0x12, 0x12, 0x0a, 0x04, 0x74, 0x79, 0x70, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x03,
|
|
|
0x52, 0x04, 0x74, 0x79, 0x70, 0x65, 0x12, 0x21, 0x0a, 0x0c, 0x61, 0x63, 0x63, 0x65, 0x73, 0x73,
|
|
|
0x5f, 0x74, 0x6f, 0x6b, 0x65, 0x6e, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0b, 0x61, 0x63,
|
|
|
- 0x63, 0x65, 0x73, 0x73, 0x54, 0x6f, 0x6b, 0x65, 0x6e, 0x22, 0x60, 0x0a, 0x0b, 0x43, 0x6f, 0x6d,
|
|
|
+ 0x63, 0x65, 0x73, 0x73, 0x54, 0x6f, 0x6b, 0x65, 0x6e, 0x22, 0x47, 0x0a, 0x0b, 0x43, 0x6f, 0x6d,
|
|
|
0x6d, 0x61, 0x6e, 0x64, 0x52, 0x65, 0x73, 0x70, 0x12, 0x12, 0x0a, 0x04, 0x63, 0x6f, 0x64, 0x65,
|
|
|
0x18, 0x01, 0x20, 0x01, 0x28, 0x03, 0x52, 0x04, 0x63, 0x6f, 0x64, 0x65, 0x12, 0x10, 0x0a, 0x03,
|
|
|
- 0x6d, 0x73, 0x67, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x03, 0x6d, 0x73, 0x67, 0x12, 0x2b,
|
|
|
- 0x0a, 0x04, 0x64, 0x61, 0x74, 0x61, 0x18, 0x03, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x17, 0x2e, 0x67,
|
|
|
- 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75, 0x66, 0x2e, 0x53,
|
|
|
- 0x74, 0x72, 0x75, 0x63, 0x74, 0x52, 0x04, 0x64, 0x61, 0x74, 0x61, 0x32, 0x66, 0x0a, 0x07, 0x46,
|
|
|
- 0x6c, 0x6f, 0x77, 0x73, 0x72, 0x76, 0x12, 0x2c, 0x0a, 0x07, 0x63, 0x6f, 0x6e, 0x6e, 0x65, 0x63,
|
|
|
- 0x74, 0x12, 0x0e, 0x2e, 0x70, 0x62, 0x2e, 0x43, 0x6f, 0x6d, 0x6d, 0x61, 0x6e, 0x64, 0x52, 0x65,
|
|
|
- 0x71, 0x1a, 0x0f, 0x2e, 0x70, 0x62, 0x2e, 0x43, 0x6f, 0x6d, 0x6d, 0x61, 0x6e, 0x64, 0x52, 0x65,
|
|
|
- 0x73, 0x70, 0x30, 0x01, 0x12, 0x2d, 0x0a, 0x0a, 0x64, 0x69, 0x73, 0x63, 0x6f, 0x6e, 0x6e, 0x65,
|
|
|
- 0x63, 0x74, 0x12, 0x0e, 0x2e, 0x70, 0x62, 0x2e, 0x43, 0x6f, 0x6d, 0x6d, 0x61, 0x6e, 0x64, 0x52,
|
|
|
- 0x65, 0x71, 0x1a, 0x0f, 0x2e, 0x70, 0x62, 0x2e, 0x43, 0x6f, 0x6d, 0x6d, 0x61, 0x6e, 0x64, 0x52,
|
|
|
- 0x65, 0x73, 0x70, 0x42, 0x06, 0x5a, 0x04, 0x2e, 0x2f, 0x70, 0x62, 0x62, 0x06, 0x70, 0x72, 0x6f,
|
|
|
- 0x74, 0x6f, 0x33,
|
|
|
+ 0x6d, 0x73, 0x67, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x03, 0x6d, 0x73, 0x67, 0x12, 0x12,
|
|
|
+ 0x0a, 0x04, 0x64, 0x61, 0x74, 0x61, 0x18, 0x03, 0x20, 0x01, 0x28, 0x0c, 0x52, 0x04, 0x64, 0x61,
|
|
|
+ 0x74, 0x61, 0x32, 0x66, 0x0a, 0x07, 0x46, 0x6c, 0x6f, 0x77, 0x73, 0x72, 0x76, 0x12, 0x2c, 0x0a,
|
|
|
+ 0x07, 0x63, 0x6f, 0x6e, 0x6e, 0x65, 0x63, 0x74, 0x12, 0x0e, 0x2e, 0x70, 0x62, 0x2e, 0x43, 0x6f,
|
|
|
+ 0x6d, 0x6d, 0x61, 0x6e, 0x64, 0x52, 0x65, 0x71, 0x1a, 0x0f, 0x2e, 0x70, 0x62, 0x2e, 0x43, 0x6f,
|
|
|
+ 0x6d, 0x6d, 0x61, 0x6e, 0x64, 0x52, 0x65, 0x73, 0x70, 0x30, 0x01, 0x12, 0x2d, 0x0a, 0x0a, 0x64,
|
|
|
+ 0x69, 0x73, 0x63, 0x6f, 0x6e, 0x6e, 0x65, 0x63, 0x74, 0x12, 0x0e, 0x2e, 0x70, 0x62, 0x2e, 0x43,
|
|
|
+ 0x6f, 0x6d, 0x6d, 0x61, 0x6e, 0x64, 0x52, 0x65, 0x71, 0x1a, 0x0f, 0x2e, 0x70, 0x62, 0x2e, 0x43,
|
|
|
+ 0x6f, 0x6d, 0x6d, 0x61, 0x6e, 0x64, 0x52, 0x65, 0x73, 0x70, 0x42, 0x06, 0x5a, 0x04, 0x2e, 0x2f,
|
|
|
+ 0x70, 0x62, 0x62, 0x06, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x33,
|
|
|
}
|
|
|
|
|
|
var (
|
|
@@ -180,21 +178,19 @@ func file_pb_flowsrv_proto_rawDescGZIP() []byte {
|
|
|
|
|
|
var file_pb_flowsrv_proto_msgTypes = make([]protoimpl.MessageInfo, 2)
|
|
|
var file_pb_flowsrv_proto_goTypes = []interface{}{
|
|
|
- (*CommandReq)(nil), // 0: pb.CommandReq
|
|
|
- (*CommandResp)(nil), // 1: pb.CommandResp
|
|
|
- (*structpb.Struct)(nil), // 2: google.protobuf.Struct
|
|
|
+ (*CommandReq)(nil), // 0: pb.CommandReq
|
|
|
+ (*CommandResp)(nil), // 1: pb.CommandResp
|
|
|
}
|
|
|
var file_pb_flowsrv_proto_depIdxs = []int32{
|
|
|
- 2, // 0: pb.CommandResp.data:type_name -> google.protobuf.Struct
|
|
|
- 0, // 1: pb.Flowsrv.connect:input_type -> pb.CommandReq
|
|
|
- 0, // 2: pb.Flowsrv.disconnect:input_type -> pb.CommandReq
|
|
|
- 1, // 3: pb.Flowsrv.connect:output_type -> pb.CommandResp
|
|
|
- 1, // 4: pb.Flowsrv.disconnect:output_type -> pb.CommandResp
|
|
|
- 3, // [3:5] is the sub-list for method output_type
|
|
|
- 1, // [1:3] is the sub-list for method input_type
|
|
|
- 1, // [1:1] is the sub-list for extension type_name
|
|
|
- 1, // [1:1] is the sub-list for extension extendee
|
|
|
- 0, // [0:1] is the sub-list for field type_name
|
|
|
+ 0, // 0: pb.Flowsrv.connect:input_type -> pb.CommandReq
|
|
|
+ 0, // 1: pb.Flowsrv.disconnect:input_type -> pb.CommandReq
|
|
|
+ 1, // 2: pb.Flowsrv.connect:output_type -> pb.CommandResp
|
|
|
+ 1, // 3: pb.Flowsrv.disconnect:output_type -> pb.CommandResp
|
|
|
+ 2, // [2:4] is the sub-list for method output_type
|
|
|
+ 0, // [0:2] is the sub-list for method input_type
|
|
|
+ 0, // [0:0] is the sub-list for extension type_name
|
|
|
+ 0, // [0:0] is the sub-list for extension extendee
|
|
|
+ 0, // [0:0] is the sub-list for field type_name
|
|
|
}
|
|
|
|
|
|
func init() { file_pb_flowsrv_proto_init() }
|