mq.pb.go 17 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462
  1. // Code generated by protoc-gen-go. DO NOT EDIT.
  2. // source: mq.proto
  3. package gapi
  4. import (
  5. context "context"
  6. fmt "fmt"
  7. proto "github.com/golang/protobuf/proto"
  8. grpc "google.golang.org/grpc"
  9. codes "google.golang.org/grpc/codes"
  10. status "google.golang.org/grpc/status"
  11. math "math"
  12. )
  13. // Reference imports to suppress errors if they are not otherwise used.
  14. var _ = proto.Marshal
  15. var _ = fmt.Errorf
  16. var _ = math.Inf
  17. // This is a compile-time assertion to ensure that this generated file
  18. // is compatible with the proto package it is being compiled against.
  19. // A compilation error at this line likely means your copy of the
  20. // proto package needs to be updated.
  21. const _ = proto.ProtoPackageIsVersion3 // please upgrade the proto package
  22. //gRPC消息队列请求消息体
  23. type ExecuteGRPCRequest struct {
  24. Method string `protobuf:"bytes,1,opt,name=method,proto3" json:"method,omitempty"`
  25. Data []byte `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
  26. Priority int32 `protobuf:"varint,3,opt,name=priority,proto3" json:"priority,omitempty"`
  27. MsgId string `protobuf:"bytes,4,opt,name=msgId,proto3" json:"msgId,omitempty"`
  28. XXX_NoUnkeyedLiteral struct{} `json:"-"`
  29. XXX_unrecognized []byte `json:"-"`
  30. XXX_sizecache int32 `json:"-"`
  31. }
  32. func (m *ExecuteGRPCRequest) Reset() { *m = ExecuteGRPCRequest{} }
  33. func (m *ExecuteGRPCRequest) String() string { return proto.CompactTextString(m) }
  34. func (*ExecuteGRPCRequest) ProtoMessage() {}
  35. func (*ExecuteGRPCRequest) Descriptor() ([]byte, []int) {
  36. return fileDescriptor_7caa8199c0db1966, []int{0}
  37. }
  38. func (m *ExecuteGRPCRequest) XXX_Unmarshal(b []byte) error {
  39. return xxx_messageInfo_ExecuteGRPCRequest.Unmarshal(m, b)
  40. }
  41. func (m *ExecuteGRPCRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
  42. return xxx_messageInfo_ExecuteGRPCRequest.Marshal(b, m, deterministic)
  43. }
  44. func (m *ExecuteGRPCRequest) XXX_Merge(src proto.Message) {
  45. xxx_messageInfo_ExecuteGRPCRequest.Merge(m, src)
  46. }
  47. func (m *ExecuteGRPCRequest) XXX_Size() int {
  48. return xxx_messageInfo_ExecuteGRPCRequest.Size(m)
  49. }
  50. func (m *ExecuteGRPCRequest) XXX_DiscardUnknown() {
  51. xxx_messageInfo_ExecuteGRPCRequest.DiscardUnknown(m)
  52. }
  53. var xxx_messageInfo_ExecuteGRPCRequest proto.InternalMessageInfo
  54. func (m *ExecuteGRPCRequest) GetMethod() string {
  55. if m != nil {
  56. return m.Method
  57. }
  58. return ""
  59. }
  60. func (m *ExecuteGRPCRequest) GetData() []byte {
  61. if m != nil {
  62. return m.Data
  63. }
  64. return nil
  65. }
  66. func (m *ExecuteGRPCRequest) GetPriority() int32 {
  67. if m != nil {
  68. return m.Priority
  69. }
  70. return 0
  71. }
  72. func (m *ExecuteGRPCRequest) GetMsgId() string {
  73. if m != nil {
  74. return m.MsgId
  75. }
  76. return ""
  77. }
  78. //gRPC请求消息体入队返回结果
  79. type ExecuteGRPCResponse struct {
  80. Code int32 `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"`
  81. MsgId string `protobuf:"bytes,2,opt,name=msgId,proto3" json:"msgId,omitempty"`
  82. XXX_NoUnkeyedLiteral struct{} `json:"-"`
  83. XXX_unrecognized []byte `json:"-"`
  84. XXX_sizecache int32 `json:"-"`
  85. }
  86. func (m *ExecuteGRPCResponse) Reset() { *m = ExecuteGRPCResponse{} }
  87. func (m *ExecuteGRPCResponse) String() string { return proto.CompactTextString(m) }
  88. func (*ExecuteGRPCResponse) ProtoMessage() {}
  89. func (*ExecuteGRPCResponse) Descriptor() ([]byte, []int) {
  90. return fileDescriptor_7caa8199c0db1966, []int{1}
  91. }
  92. func (m *ExecuteGRPCResponse) XXX_Unmarshal(b []byte) error {
  93. return xxx_messageInfo_ExecuteGRPCResponse.Unmarshal(m, b)
  94. }
  95. func (m *ExecuteGRPCResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
  96. return xxx_messageInfo_ExecuteGRPCResponse.Marshal(b, m, deterministic)
  97. }
  98. func (m *ExecuteGRPCResponse) XXX_Merge(src proto.Message) {
  99. xxx_messageInfo_ExecuteGRPCResponse.Merge(m, src)
  100. }
  101. func (m *ExecuteGRPCResponse) XXX_Size() int {
  102. return xxx_messageInfo_ExecuteGRPCResponse.Size(m)
  103. }
  104. func (m *ExecuteGRPCResponse) XXX_DiscardUnknown() {
  105. xxx_messageInfo_ExecuteGRPCResponse.DiscardUnknown(m)
  106. }
  107. var xxx_messageInfo_ExecuteGRPCResponse proto.InternalMessageInfo
  108. func (m *ExecuteGRPCResponse) GetCode() int32 {
  109. if m != nil {
  110. return m.Code
  111. }
  112. return 0
  113. }
  114. func (m *ExecuteGRPCResponse) GetMsgId() string {
  115. if m != nil {
  116. return m.MsgId
  117. }
  118. return ""
  119. }
  120. type ExecuteRestRequest struct {
  121. Url string `protobuf:"bytes,1,opt,name=url,proto3" json:"url,omitempty"`
  122. Body []byte `protobuf:"bytes,2,opt,name=body,proto3" json:"body,omitempty"`
  123. Priority int32 `protobuf:"varint,3,opt,name=priority,proto3" json:"priority,omitempty"`
  124. MsgId string `protobuf:"bytes,4,opt,name=msgId,proto3" json:"msgId,omitempty"`
  125. Method string `protobuf:"bytes,5,opt,name=method,proto3" json:"method,omitempty"`
  126. Headers []*ExecuteRestRequest_Header `protobuf:"bytes,6,rep,name=headers,proto3" json:"headers,omitempty"`
  127. XXX_NoUnkeyedLiteral struct{} `json:"-"`
  128. XXX_unrecognized []byte `json:"-"`
  129. XXX_sizecache int32 `json:"-"`
  130. }
  131. func (m *ExecuteRestRequest) Reset() { *m = ExecuteRestRequest{} }
  132. func (m *ExecuteRestRequest) String() string { return proto.CompactTextString(m) }
  133. func (*ExecuteRestRequest) ProtoMessage() {}
  134. func (*ExecuteRestRequest) Descriptor() ([]byte, []int) {
  135. return fileDescriptor_7caa8199c0db1966, []int{2}
  136. }
  137. func (m *ExecuteRestRequest) XXX_Unmarshal(b []byte) error {
  138. return xxx_messageInfo_ExecuteRestRequest.Unmarshal(m, b)
  139. }
  140. func (m *ExecuteRestRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
  141. return xxx_messageInfo_ExecuteRestRequest.Marshal(b, m, deterministic)
  142. }
  143. func (m *ExecuteRestRequest) XXX_Merge(src proto.Message) {
  144. xxx_messageInfo_ExecuteRestRequest.Merge(m, src)
  145. }
  146. func (m *ExecuteRestRequest) XXX_Size() int {
  147. return xxx_messageInfo_ExecuteRestRequest.Size(m)
  148. }
  149. func (m *ExecuteRestRequest) XXX_DiscardUnknown() {
  150. xxx_messageInfo_ExecuteRestRequest.DiscardUnknown(m)
  151. }
  152. var xxx_messageInfo_ExecuteRestRequest proto.InternalMessageInfo
  153. func (m *ExecuteRestRequest) GetUrl() string {
  154. if m != nil {
  155. return m.Url
  156. }
  157. return ""
  158. }
  159. func (m *ExecuteRestRequest) GetBody() []byte {
  160. if m != nil {
  161. return m.Body
  162. }
  163. return nil
  164. }
  165. func (m *ExecuteRestRequest) GetPriority() int32 {
  166. if m != nil {
  167. return m.Priority
  168. }
  169. return 0
  170. }
  171. func (m *ExecuteRestRequest) GetMsgId() string {
  172. if m != nil {
  173. return m.MsgId
  174. }
  175. return ""
  176. }
  177. func (m *ExecuteRestRequest) GetMethod() string {
  178. if m != nil {
  179. return m.Method
  180. }
  181. return ""
  182. }
  183. func (m *ExecuteRestRequest) GetHeaders() []*ExecuteRestRequest_Header {
  184. if m != nil {
  185. return m.Headers
  186. }
  187. return nil
  188. }
  189. type ExecuteRestRequest_Header struct {
  190. Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
  191. Value string `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
  192. XXX_NoUnkeyedLiteral struct{} `json:"-"`
  193. XXX_unrecognized []byte `json:"-"`
  194. XXX_sizecache int32 `json:"-"`
  195. }
  196. func (m *ExecuteRestRequest_Header) Reset() { *m = ExecuteRestRequest_Header{} }
  197. func (m *ExecuteRestRequest_Header) String() string { return proto.CompactTextString(m) }
  198. func (*ExecuteRestRequest_Header) ProtoMessage() {}
  199. func (*ExecuteRestRequest_Header) Descriptor() ([]byte, []int) {
  200. return fileDescriptor_7caa8199c0db1966, []int{2, 0}
  201. }
  202. func (m *ExecuteRestRequest_Header) XXX_Unmarshal(b []byte) error {
  203. return xxx_messageInfo_ExecuteRestRequest_Header.Unmarshal(m, b)
  204. }
  205. func (m *ExecuteRestRequest_Header) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
  206. return xxx_messageInfo_ExecuteRestRequest_Header.Marshal(b, m, deterministic)
  207. }
  208. func (m *ExecuteRestRequest_Header) XXX_Merge(src proto.Message) {
  209. xxx_messageInfo_ExecuteRestRequest_Header.Merge(m, src)
  210. }
  211. func (m *ExecuteRestRequest_Header) XXX_Size() int {
  212. return xxx_messageInfo_ExecuteRestRequest_Header.Size(m)
  213. }
  214. func (m *ExecuteRestRequest_Header) XXX_DiscardUnknown() {
  215. xxx_messageInfo_ExecuteRestRequest_Header.DiscardUnknown(m)
  216. }
  217. var xxx_messageInfo_ExecuteRestRequest_Header proto.InternalMessageInfo
  218. func (m *ExecuteRestRequest_Header) GetKey() string {
  219. if m != nil {
  220. return m.Key
  221. }
  222. return ""
  223. }
  224. func (m *ExecuteRestRequest_Header) GetValue() string {
  225. if m != nil {
  226. return m.Value
  227. }
  228. return ""
  229. }
  230. type ExecuteRestResponse struct {
  231. Code int32 `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"`
  232. MsgId string `protobuf:"bytes,2,opt,name=msgId,proto3" json:"msgId,omitempty"`
  233. XXX_NoUnkeyedLiteral struct{} `json:"-"`
  234. XXX_unrecognized []byte `json:"-"`
  235. XXX_sizecache int32 `json:"-"`
  236. }
  237. func (m *ExecuteRestResponse) Reset() { *m = ExecuteRestResponse{} }
  238. func (m *ExecuteRestResponse) String() string { return proto.CompactTextString(m) }
  239. func (*ExecuteRestResponse) ProtoMessage() {}
  240. func (*ExecuteRestResponse) Descriptor() ([]byte, []int) {
  241. return fileDescriptor_7caa8199c0db1966, []int{3}
  242. }
  243. func (m *ExecuteRestResponse) XXX_Unmarshal(b []byte) error {
  244. return xxx_messageInfo_ExecuteRestResponse.Unmarshal(m, b)
  245. }
  246. func (m *ExecuteRestResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
  247. return xxx_messageInfo_ExecuteRestResponse.Marshal(b, m, deterministic)
  248. }
  249. func (m *ExecuteRestResponse) XXX_Merge(src proto.Message) {
  250. xxx_messageInfo_ExecuteRestResponse.Merge(m, src)
  251. }
  252. func (m *ExecuteRestResponse) XXX_Size() int {
  253. return xxx_messageInfo_ExecuteRestResponse.Size(m)
  254. }
  255. func (m *ExecuteRestResponse) XXX_DiscardUnknown() {
  256. xxx_messageInfo_ExecuteRestResponse.DiscardUnknown(m)
  257. }
  258. var xxx_messageInfo_ExecuteRestResponse proto.InternalMessageInfo
  259. func (m *ExecuteRestResponse) GetCode() int32 {
  260. if m != nil {
  261. return m.Code
  262. }
  263. return 0
  264. }
  265. func (m *ExecuteRestResponse) GetMsgId() string {
  266. if m != nil {
  267. return m.MsgId
  268. }
  269. return ""
  270. }
  271. func init() {
  272. proto.RegisterType((*ExecuteGRPCRequest)(nil), "com.ywt.gapi.mq.ExecuteGRPCRequest")
  273. proto.RegisterType((*ExecuteGRPCResponse)(nil), "com.ywt.gapi.mq.ExecuteGRPCResponse")
  274. proto.RegisterType((*ExecuteRestRequest)(nil), "com.ywt.gapi.mq.ExecuteRestRequest")
  275. proto.RegisterType((*ExecuteRestRequest_Header)(nil), "com.ywt.gapi.mq.ExecuteRestRequest.Header")
  276. proto.RegisterType((*ExecuteRestResponse)(nil), "com.ywt.gapi.mq.ExecuteRestResponse")
  277. }
  278. func init() { proto.RegisterFile("mq.proto", fileDescriptor_7caa8199c0db1966) }
  279. var fileDescriptor_7caa8199c0db1966 = []byte{
  280. // 343 bytes of a gzipped FileDescriptorProto
  281. 0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0x94, 0x92, 0xcf, 0x4a, 0xc3, 0x40,
  282. 0x10, 0x87, 0xd9, 0xb6, 0x89, 0x75, 0x2a, 0xa8, 0xab, 0x48, 0x28, 0x08, 0xa1, 0x7a, 0x08, 0x1e,
  283. 0x56, 0xa9, 0x0f, 0x20, 0xf8, 0x07, 0xf5, 0x20, 0xd4, 0xf5, 0x22, 0xde, 0xd2, 0x64, 0x68, 0x43,
  284. 0x1b, 0x37, 0xdd, 0x6c, 0xaa, 0x79, 0x03, 0xdf, 0xcc, 0x97, 0xf2, 0x20, 0xbb, 0x69, 0xda, 0xb4,
  285. 0x52, 0xa1, 0xb7, 0x99, 0x90, 0xfd, 0xf6, 0x9b, 0xdf, 0x0e, 0x34, 0xe3, 0x09, 0x4b, 0xa4, 0x50,
  286. 0x82, 0xee, 0x06, 0x22, 0x66, 0xf9, 0x87, 0x62, 0x03, 0x3f, 0x89, 0x58, 0x3c, 0xe9, 0x48, 0xa0,
  287. 0x77, 0x9f, 0x18, 0x64, 0x0a, 0xef, 0x79, 0xef, 0x86, 0xe3, 0x24, 0xc3, 0x54, 0xd1, 0x23, 0xb0,
  288. 0x63, 0x54, 0x43, 0x11, 0x3a, 0xc4, 0x25, 0xde, 0x36, 0x9f, 0x75, 0x94, 0x42, 0x23, 0xf4, 0x95,
  289. 0xef, 0xd4, 0x5c, 0xe2, 0xed, 0x70, 0x53, 0xd3, 0x36, 0x34, 0x13, 0x19, 0x09, 0x19, 0xa9, 0xdc,
  290. 0xa9, 0xbb, 0xc4, 0xb3, 0xf8, 0xbc, 0xa7, 0x87, 0x60, 0xc5, 0xe9, 0xe0, 0x31, 0x74, 0x1a, 0x06,
  291. 0x53, 0x34, 0x9d, 0x2b, 0x38, 0x58, 0xba, 0x33, 0x4d, 0xc4, 0x7b, 0x8a, 0x1a, 0x1e, 0x88, 0x10,
  292. 0xcd, 0x95, 0x16, 0x37, 0xf5, 0x02, 0x50, 0xab, 0x02, 0x7e, 0xc8, 0xdc, 0x9a, 0x63, 0xaa, 0x4a,
  293. 0xeb, 0x3d, 0xa8, 0x67, 0x72, 0x3c, 0x53, 0xd6, 0xa5, 0x46, 0xf6, 0x45, 0x98, 0x97, 0xbe, 0xba,
  294. 0xde, 0xdc, 0xb7, 0x92, 0x86, 0xb5, 0x94, 0xc6, 0x2d, 0x6c, 0x0d, 0xd1, 0x0f, 0x51, 0xa6, 0x8e,
  295. 0xed, 0xd6, 0xbd, 0x56, 0xf7, 0x8c, 0xad, 0xc4, 0xcb, 0xfe, 0x5a, 0xb2, 0x07, 0x73, 0x84, 0x97,
  296. 0x47, 0xdb, 0x17, 0x60, 0x17, 0x9f, 0xb4, 0xff, 0x08, 0xf3, 0xd2, 0x7f, 0x84, 0xc6, 0x67, 0xea,
  297. 0x8f, 0x33, 0x2c, 0xc7, 0x37, 0x4d, 0x25, 0xbf, 0x82, 0xbb, 0x69, 0x7e, 0xdd, 0x6f, 0x02, 0xfb,
  298. 0x4f, 0xcf, 0x05, 0x43, 0xc8, 0x17, 0x94, 0xd3, 0x28, 0x40, 0xfa, 0x0a, 0x2d, 0x5c, 0x3c, 0x0b,
  299. 0x3d, 0x59, 0x37, 0x4c, 0x65, 0x51, 0xda, 0xa7, 0xff, 0xff, 0x34, 0x33, 0x5b, 0x90, 0xb5, 0xf0,
  300. 0x7a, 0x72, 0x25, 0xa6, 0xf5, 0xe4, 0xea, 0xcc, 0xd7, 0xc7, 0xb0, 0xba, 0xd1, 0x3d, 0xf2, 0x66,
  301. 0x9d, 0xeb, 0xfa, 0x8b, 0x90, 0xbe, 0x6d, 0xb6, 0xfe, 0xf2, 0x37, 0x00, 0x00, 0xff, 0xff, 0x7e,
  302. 0xa1, 0x6c, 0x38, 0x01, 0x03, 0x00, 0x00,
  303. }
  304. // Reference imports to suppress errors if they are not otherwise used.
  305. var _ context.Context
  306. var _ grpc.ClientConn
  307. // This is a compile-time assertion to ensure that this generated file
  308. // is compatible with the grpc package it is being compiled against.
  309. const _ = grpc.SupportPackageIsVersion4
  310. // MQExecutorServiceClient is the client API for MQExecutorService service.
  311. //
  312. // For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
  313. type MQExecutorServiceClient interface {
  314. ExecuteGRPC(ctx context.Context, in *ExecuteGRPCRequest, opts ...grpc.CallOption) (*ExecuteGRPCResponse, error)
  315. ExecuteRest(ctx context.Context, in *ExecuteRestRequest, opts ...grpc.CallOption) (*ExecuteRestResponse, error)
  316. }
  317. type mQExecutorServiceClient struct {
  318. cc *grpc.ClientConn
  319. }
  320. func NewMQExecutorServiceClient(cc *grpc.ClientConn) MQExecutorServiceClient {
  321. return &mQExecutorServiceClient{cc}
  322. }
  323. func (c *mQExecutorServiceClient) ExecuteGRPC(ctx context.Context, in *ExecuteGRPCRequest, opts ...grpc.CallOption) (*ExecuteGRPCResponse, error) {
  324. out := new(ExecuteGRPCResponse)
  325. err := c.cc.Invoke(ctx, "/com.ywt.gapi.mq.MQExecutorService/executeGRPC", in, out, opts...)
  326. if err != nil {
  327. return nil, err
  328. }
  329. return out, nil
  330. }
  331. func (c *mQExecutorServiceClient) ExecuteRest(ctx context.Context, in *ExecuteRestRequest, opts ...grpc.CallOption) (*ExecuteRestResponse, error) {
  332. out := new(ExecuteRestResponse)
  333. err := c.cc.Invoke(ctx, "/com.ywt.gapi.mq.MQExecutorService/executeRest", in, out, opts...)
  334. if err != nil {
  335. return nil, err
  336. }
  337. return out, nil
  338. }
  339. // MQExecutorServiceServer is the server API for MQExecutorService service.
  340. type MQExecutorServiceServer interface {
  341. ExecuteGRPC(context.Context, *ExecuteGRPCRequest) (*ExecuteGRPCResponse, error)
  342. ExecuteRest(context.Context, *ExecuteRestRequest) (*ExecuteRestResponse, error)
  343. }
  344. // UnimplementedMQExecutorServiceServer can be embedded to have forward compatible implementations.
  345. type UnimplementedMQExecutorServiceServer struct {
  346. }
  347. func (*UnimplementedMQExecutorServiceServer) ExecuteGRPC(ctx context.Context, req *ExecuteGRPCRequest) (*ExecuteGRPCResponse, error) {
  348. return nil, status.Errorf(codes.Unimplemented, "method ExecuteGRPC not implemented")
  349. }
  350. func (*UnimplementedMQExecutorServiceServer) ExecuteRest(ctx context.Context, req *ExecuteRestRequest) (*ExecuteRestResponse, error) {
  351. return nil, status.Errorf(codes.Unimplemented, "method ExecuteRest not implemented")
  352. }
  353. func RegisterMQExecutorServiceServer(s *grpc.Server, srv MQExecutorServiceServer) {
  354. s.RegisterService(&_MQExecutorService_serviceDesc, srv)
  355. }
  356. func _MQExecutorService_ExecuteGRPC_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  357. in := new(ExecuteGRPCRequest)
  358. if err := dec(in); err != nil {
  359. return nil, err
  360. }
  361. if interceptor == nil {
  362. return srv.(MQExecutorServiceServer).ExecuteGRPC(ctx, in)
  363. }
  364. info := &grpc.UnaryServerInfo{
  365. Server: srv,
  366. FullMethod: "/com.ywt.gapi.mq.MQExecutorService/ExecuteGRPC",
  367. }
  368. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  369. return srv.(MQExecutorServiceServer).ExecuteGRPC(ctx, req.(*ExecuteGRPCRequest))
  370. }
  371. return interceptor(ctx, in, info, handler)
  372. }
  373. func _MQExecutorService_ExecuteRest_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  374. in := new(ExecuteRestRequest)
  375. if err := dec(in); err != nil {
  376. return nil, err
  377. }
  378. if interceptor == nil {
  379. return srv.(MQExecutorServiceServer).ExecuteRest(ctx, in)
  380. }
  381. info := &grpc.UnaryServerInfo{
  382. Server: srv,
  383. FullMethod: "/com.ywt.gapi.mq.MQExecutorService/ExecuteRest",
  384. }
  385. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  386. return srv.(MQExecutorServiceServer).ExecuteRest(ctx, req.(*ExecuteRestRequest))
  387. }
  388. return interceptor(ctx, in, info, handler)
  389. }
  390. var _MQExecutorService_serviceDesc = grpc.ServiceDesc{
  391. ServiceName: "com.ywt.gapi.mq.MQExecutorService",
  392. HandlerType: (*MQExecutorServiceServer)(nil),
  393. Methods: []grpc.MethodDesc{
  394. {
  395. MethodName: "executeGRPC",
  396. Handler: _MQExecutorService_ExecuteGRPC_Handler,
  397. },
  398. {
  399. MethodName: "executeRest",
  400. Handler: _MQExecutorService_ExecuteRest_Handler,
  401. },
  402. },
  403. Streams: []grpc.StreamDesc{},
  404. Metadata: "mq.proto",
  405. }