api.pb.go 25 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132
  1. // Code generated by protoc-gen-gogo. DO NOT EDIT.
  2. // source: app/service/main/reply-feed/api/api.proto
  3. /*
  4. Package v1 is a generated protocol buffer package.
  5. It is generated from these files:
  6. app/service/main/reply-feed/api/api.proto
  7. It has these top-level messages:
  8. HotReplyReq
  9. HotReplyRes
  10. ReplyReq
  11. ReplyRes
  12. */
  13. package v1
  14. import proto "github.com/gogo/protobuf/proto"
  15. import fmt "fmt"
  16. import math "math"
  17. import context "golang.org/x/net/context"
  18. import grpc "google.golang.org/grpc"
  19. import io "io"
  20. // Reference imports to suppress errors if they are not otherwise used.
  21. var _ = proto.Marshal
  22. var _ = fmt.Errorf
  23. var _ = math.Inf
  24. // This is a compile-time assertion to ensure that this generated file
  25. // is compatible with the proto package it is being compiled against.
  26. // A compilation error at this line likely means your copy of the
  27. // proto package needs to be updated.
  28. const _ = proto.GoGoProtoPackageIsVersion2 // please upgrade the proto package
  29. type HotReplyReq struct {
  30. Mid int64 `protobuf:"varint,1,opt,name=mid,proto3" json:"mid,omitempty"`
  31. Oid int64 `protobuf:"varint,2,opt,name=oid,proto3" json:"oid,omitempty"`
  32. Tp int32 `protobuf:"varint,3,opt,name=tp,proto3" json:"tp,omitempty"`
  33. Pn int32 `protobuf:"varint,4,opt,name=pn,proto3" json:"pn,omitempty"`
  34. Ps int32 `protobuf:"varint,5,opt,name=ps,proto3" json:"ps,omitempty"`
  35. }
  36. func (m *HotReplyReq) Reset() { *m = HotReplyReq{} }
  37. func (m *HotReplyReq) String() string { return proto.CompactTextString(m) }
  38. func (*HotReplyReq) ProtoMessage() {}
  39. func (*HotReplyReq) Descriptor() ([]byte, []int) { return fileDescriptorApi, []int{0} }
  40. func (m *HotReplyReq) GetMid() int64 {
  41. if m != nil {
  42. return m.Mid
  43. }
  44. return 0
  45. }
  46. func (m *HotReplyReq) GetOid() int64 {
  47. if m != nil {
  48. return m.Oid
  49. }
  50. return 0
  51. }
  52. func (m *HotReplyReq) GetTp() int32 {
  53. if m != nil {
  54. return m.Tp
  55. }
  56. return 0
  57. }
  58. func (m *HotReplyReq) GetPn() int32 {
  59. if m != nil {
  60. return m.Pn
  61. }
  62. return 0
  63. }
  64. func (m *HotReplyReq) GetPs() int32 {
  65. if m != nil {
  66. return m.Ps
  67. }
  68. return 0
  69. }
  70. type HotReplyRes struct {
  71. Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
  72. RpIDs []int64 `protobuf:"varint,2,rep,packed,name=rpIDs" json:"rpIDs,omitempty"`
  73. Count int32 `protobuf:"varint,3,opt,name=count,proto3" json:"count,omitempty"`
  74. }
  75. func (m *HotReplyRes) Reset() { *m = HotReplyRes{} }
  76. func (m *HotReplyRes) String() string { return proto.CompactTextString(m) }
  77. func (*HotReplyRes) ProtoMessage() {}
  78. func (*HotReplyRes) Descriptor() ([]byte, []int) { return fileDescriptorApi, []int{1} }
  79. func (m *HotReplyRes) GetName() string {
  80. if m != nil {
  81. return m.Name
  82. }
  83. return ""
  84. }
  85. func (m *HotReplyRes) GetRpIDs() []int64 {
  86. if m != nil {
  87. return m.RpIDs
  88. }
  89. return nil
  90. }
  91. func (m *HotReplyRes) GetCount() int32 {
  92. if m != nil {
  93. return m.Count
  94. }
  95. return 0
  96. }
  97. type ReplyReq struct {
  98. Mid int64 `protobuf:"varint,1,opt,name=mid,proto3" json:"mid,omitempty"`
  99. Pn int32 `protobuf:"varint,2,opt,name=pn,proto3" json:"pn,omitempty"`
  100. Ps int32 `protobuf:"varint,3,opt,name=ps,proto3" json:"ps,omitempty"`
  101. }
  102. func (m *ReplyReq) Reset() { *m = ReplyReq{} }
  103. func (m *ReplyReq) String() string { return proto.CompactTextString(m) }
  104. func (*ReplyReq) ProtoMessage() {}
  105. func (*ReplyReq) Descriptor() ([]byte, []int) { return fileDescriptorApi, []int{2} }
  106. func (m *ReplyReq) GetMid() int64 {
  107. if m != nil {
  108. return m.Mid
  109. }
  110. return 0
  111. }
  112. func (m *ReplyReq) GetPn() int32 {
  113. if m != nil {
  114. return m.Pn
  115. }
  116. return 0
  117. }
  118. func (m *ReplyReq) GetPs() int32 {
  119. if m != nil {
  120. return m.Ps
  121. }
  122. return 0
  123. }
  124. type ReplyRes struct {
  125. Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
  126. }
  127. func (m *ReplyRes) Reset() { *m = ReplyRes{} }
  128. func (m *ReplyRes) String() string { return proto.CompactTextString(m) }
  129. func (*ReplyRes) ProtoMessage() {}
  130. func (*ReplyRes) Descriptor() ([]byte, []int) { return fileDescriptorApi, []int{3} }
  131. func (m *ReplyRes) GetName() string {
  132. if m != nil {
  133. return m.Name
  134. }
  135. return ""
  136. }
  137. func init() {
  138. proto.RegisterType((*HotReplyReq)(nil), "community.reply.feed.v1.HotReplyReq")
  139. proto.RegisterType((*HotReplyRes)(nil), "community.reply.feed.v1.HotReplyRes")
  140. proto.RegisterType((*ReplyReq)(nil), "community.reply.feed.v1.ReplyReq")
  141. proto.RegisterType((*ReplyRes)(nil), "community.reply.feed.v1.ReplyRes")
  142. }
  143. // Reference imports to suppress errors if they are not otherwise used.
  144. var _ context.Context
  145. var _ grpc.ClientConn
  146. // This is a compile-time assertion to ensure that this generated file
  147. // is compatible with the grpc package it is being compiled against.
  148. const _ = grpc.SupportPackageIsVersion4
  149. // Client API for ReplyFeed service
  150. type ReplyFeedClient interface {
  151. HotReply(ctx context.Context, in *HotReplyReq, opts ...grpc.CallOption) (*HotReplyRes, error)
  152. Reply(ctx context.Context, in *ReplyReq, opts ...grpc.CallOption) (*ReplyRes, error)
  153. }
  154. type replyFeedClient struct {
  155. cc *grpc.ClientConn
  156. }
  157. func NewReplyFeedClient(cc *grpc.ClientConn) ReplyFeedClient {
  158. return &replyFeedClient{cc}
  159. }
  160. func (c *replyFeedClient) HotReply(ctx context.Context, in *HotReplyReq, opts ...grpc.CallOption) (*HotReplyRes, error) {
  161. out := new(HotReplyRes)
  162. err := grpc.Invoke(ctx, "/community.reply.feed.v1.ReplyFeed/HotReply", in, out, c.cc, opts...)
  163. if err != nil {
  164. return nil, err
  165. }
  166. return out, nil
  167. }
  168. func (c *replyFeedClient) Reply(ctx context.Context, in *ReplyReq, opts ...grpc.CallOption) (*ReplyRes, error) {
  169. out := new(ReplyRes)
  170. err := grpc.Invoke(ctx, "/community.reply.feed.v1.ReplyFeed/Reply", in, out, c.cc, opts...)
  171. if err != nil {
  172. return nil, err
  173. }
  174. return out, nil
  175. }
  176. // Server API for ReplyFeed service
  177. type ReplyFeedServer interface {
  178. HotReply(context.Context, *HotReplyReq) (*HotReplyRes, error)
  179. Reply(context.Context, *ReplyReq) (*ReplyRes, error)
  180. }
  181. func RegisterReplyFeedServer(s *grpc.Server, srv ReplyFeedServer) {
  182. s.RegisterService(&_ReplyFeed_serviceDesc, srv)
  183. }
  184. func _ReplyFeed_HotReply_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  185. in := new(HotReplyReq)
  186. if err := dec(in); err != nil {
  187. return nil, err
  188. }
  189. if interceptor == nil {
  190. return srv.(ReplyFeedServer).HotReply(ctx, in)
  191. }
  192. info := &grpc.UnaryServerInfo{
  193. Server: srv,
  194. FullMethod: "/community.reply.feed.v1.ReplyFeed/HotReply",
  195. }
  196. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  197. return srv.(ReplyFeedServer).HotReply(ctx, req.(*HotReplyReq))
  198. }
  199. return interceptor(ctx, in, info, handler)
  200. }
  201. func _ReplyFeed_Reply_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  202. in := new(ReplyReq)
  203. if err := dec(in); err != nil {
  204. return nil, err
  205. }
  206. if interceptor == nil {
  207. return srv.(ReplyFeedServer).Reply(ctx, in)
  208. }
  209. info := &grpc.UnaryServerInfo{
  210. Server: srv,
  211. FullMethod: "/community.reply.feed.v1.ReplyFeed/Reply",
  212. }
  213. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  214. return srv.(ReplyFeedServer).Reply(ctx, req.(*ReplyReq))
  215. }
  216. return interceptor(ctx, in, info, handler)
  217. }
  218. var _ReplyFeed_serviceDesc = grpc.ServiceDesc{
  219. ServiceName: "community.reply.feed.v1.ReplyFeed",
  220. HandlerType: (*ReplyFeedServer)(nil),
  221. Methods: []grpc.MethodDesc{
  222. {
  223. MethodName: "HotReply",
  224. Handler: _ReplyFeed_HotReply_Handler,
  225. },
  226. {
  227. MethodName: "Reply",
  228. Handler: _ReplyFeed_Reply_Handler,
  229. },
  230. },
  231. Streams: []grpc.StreamDesc{},
  232. Metadata: "app/service/main/reply-feed/api/api.proto",
  233. }
  234. func (m *HotReplyReq) Marshal() (dAtA []byte, err error) {
  235. size := m.Size()
  236. dAtA = make([]byte, size)
  237. n, err := m.MarshalTo(dAtA)
  238. if err != nil {
  239. return nil, err
  240. }
  241. return dAtA[:n], nil
  242. }
  243. func (m *HotReplyReq) MarshalTo(dAtA []byte) (int, error) {
  244. var i int
  245. _ = i
  246. var l int
  247. _ = l
  248. if m.Mid != 0 {
  249. dAtA[i] = 0x8
  250. i++
  251. i = encodeVarintApi(dAtA, i, uint64(m.Mid))
  252. }
  253. if m.Oid != 0 {
  254. dAtA[i] = 0x10
  255. i++
  256. i = encodeVarintApi(dAtA, i, uint64(m.Oid))
  257. }
  258. if m.Tp != 0 {
  259. dAtA[i] = 0x18
  260. i++
  261. i = encodeVarintApi(dAtA, i, uint64(m.Tp))
  262. }
  263. if m.Pn != 0 {
  264. dAtA[i] = 0x20
  265. i++
  266. i = encodeVarintApi(dAtA, i, uint64(m.Pn))
  267. }
  268. if m.Ps != 0 {
  269. dAtA[i] = 0x28
  270. i++
  271. i = encodeVarintApi(dAtA, i, uint64(m.Ps))
  272. }
  273. return i, nil
  274. }
  275. func (m *HotReplyRes) Marshal() (dAtA []byte, err error) {
  276. size := m.Size()
  277. dAtA = make([]byte, size)
  278. n, err := m.MarshalTo(dAtA)
  279. if err != nil {
  280. return nil, err
  281. }
  282. return dAtA[:n], nil
  283. }
  284. func (m *HotReplyRes) MarshalTo(dAtA []byte) (int, error) {
  285. var i int
  286. _ = i
  287. var l int
  288. _ = l
  289. if len(m.Name) > 0 {
  290. dAtA[i] = 0xa
  291. i++
  292. i = encodeVarintApi(dAtA, i, uint64(len(m.Name)))
  293. i += copy(dAtA[i:], m.Name)
  294. }
  295. if len(m.RpIDs) > 0 {
  296. dAtA2 := make([]byte, len(m.RpIDs)*10)
  297. var j1 int
  298. for _, num1 := range m.RpIDs {
  299. num := uint64(num1)
  300. for num >= 1<<7 {
  301. dAtA2[j1] = uint8(uint64(num)&0x7f | 0x80)
  302. num >>= 7
  303. j1++
  304. }
  305. dAtA2[j1] = uint8(num)
  306. j1++
  307. }
  308. dAtA[i] = 0x12
  309. i++
  310. i = encodeVarintApi(dAtA, i, uint64(j1))
  311. i += copy(dAtA[i:], dAtA2[:j1])
  312. }
  313. if m.Count != 0 {
  314. dAtA[i] = 0x18
  315. i++
  316. i = encodeVarintApi(dAtA, i, uint64(m.Count))
  317. }
  318. return i, nil
  319. }
  320. func (m *ReplyReq) Marshal() (dAtA []byte, err error) {
  321. size := m.Size()
  322. dAtA = make([]byte, size)
  323. n, err := m.MarshalTo(dAtA)
  324. if err != nil {
  325. return nil, err
  326. }
  327. return dAtA[:n], nil
  328. }
  329. func (m *ReplyReq) MarshalTo(dAtA []byte) (int, error) {
  330. var i int
  331. _ = i
  332. var l int
  333. _ = l
  334. if m.Mid != 0 {
  335. dAtA[i] = 0x8
  336. i++
  337. i = encodeVarintApi(dAtA, i, uint64(m.Mid))
  338. }
  339. if m.Pn != 0 {
  340. dAtA[i] = 0x10
  341. i++
  342. i = encodeVarintApi(dAtA, i, uint64(m.Pn))
  343. }
  344. if m.Ps != 0 {
  345. dAtA[i] = 0x18
  346. i++
  347. i = encodeVarintApi(dAtA, i, uint64(m.Ps))
  348. }
  349. return i, nil
  350. }
  351. func (m *ReplyRes) Marshal() (dAtA []byte, err error) {
  352. size := m.Size()
  353. dAtA = make([]byte, size)
  354. n, err := m.MarshalTo(dAtA)
  355. if err != nil {
  356. return nil, err
  357. }
  358. return dAtA[:n], nil
  359. }
  360. func (m *ReplyRes) MarshalTo(dAtA []byte) (int, error) {
  361. var i int
  362. _ = i
  363. var l int
  364. _ = l
  365. if len(m.Name) > 0 {
  366. dAtA[i] = 0xa
  367. i++
  368. i = encodeVarintApi(dAtA, i, uint64(len(m.Name)))
  369. i += copy(dAtA[i:], m.Name)
  370. }
  371. return i, nil
  372. }
  373. func encodeVarintApi(dAtA []byte, offset int, v uint64) int {
  374. for v >= 1<<7 {
  375. dAtA[offset] = uint8(v&0x7f | 0x80)
  376. v >>= 7
  377. offset++
  378. }
  379. dAtA[offset] = uint8(v)
  380. return offset + 1
  381. }
  382. func (m *HotReplyReq) Size() (n int) {
  383. var l int
  384. _ = l
  385. if m.Mid != 0 {
  386. n += 1 + sovApi(uint64(m.Mid))
  387. }
  388. if m.Oid != 0 {
  389. n += 1 + sovApi(uint64(m.Oid))
  390. }
  391. if m.Tp != 0 {
  392. n += 1 + sovApi(uint64(m.Tp))
  393. }
  394. if m.Pn != 0 {
  395. n += 1 + sovApi(uint64(m.Pn))
  396. }
  397. if m.Ps != 0 {
  398. n += 1 + sovApi(uint64(m.Ps))
  399. }
  400. return n
  401. }
  402. func (m *HotReplyRes) Size() (n int) {
  403. var l int
  404. _ = l
  405. l = len(m.Name)
  406. if l > 0 {
  407. n += 1 + l + sovApi(uint64(l))
  408. }
  409. if len(m.RpIDs) > 0 {
  410. l = 0
  411. for _, e := range m.RpIDs {
  412. l += sovApi(uint64(e))
  413. }
  414. n += 1 + sovApi(uint64(l)) + l
  415. }
  416. if m.Count != 0 {
  417. n += 1 + sovApi(uint64(m.Count))
  418. }
  419. return n
  420. }
  421. func (m *ReplyReq) Size() (n int) {
  422. var l int
  423. _ = l
  424. if m.Mid != 0 {
  425. n += 1 + sovApi(uint64(m.Mid))
  426. }
  427. if m.Pn != 0 {
  428. n += 1 + sovApi(uint64(m.Pn))
  429. }
  430. if m.Ps != 0 {
  431. n += 1 + sovApi(uint64(m.Ps))
  432. }
  433. return n
  434. }
  435. func (m *ReplyRes) Size() (n int) {
  436. var l int
  437. _ = l
  438. l = len(m.Name)
  439. if l > 0 {
  440. n += 1 + l + sovApi(uint64(l))
  441. }
  442. return n
  443. }
  444. func sovApi(x uint64) (n int) {
  445. for {
  446. n++
  447. x >>= 7
  448. if x == 0 {
  449. break
  450. }
  451. }
  452. return n
  453. }
  454. func sozApi(x uint64) (n int) {
  455. return sovApi(uint64((x << 1) ^ uint64((int64(x) >> 63))))
  456. }
  457. func (m *HotReplyReq) Unmarshal(dAtA []byte) error {
  458. l := len(dAtA)
  459. iNdEx := 0
  460. for iNdEx < l {
  461. preIndex := iNdEx
  462. var wire uint64
  463. for shift := uint(0); ; shift += 7 {
  464. if shift >= 64 {
  465. return ErrIntOverflowApi
  466. }
  467. if iNdEx >= l {
  468. return io.ErrUnexpectedEOF
  469. }
  470. b := dAtA[iNdEx]
  471. iNdEx++
  472. wire |= (uint64(b) & 0x7F) << shift
  473. if b < 0x80 {
  474. break
  475. }
  476. }
  477. fieldNum := int32(wire >> 3)
  478. wireType := int(wire & 0x7)
  479. if wireType == 4 {
  480. return fmt.Errorf("proto: HotReplyReq: wiretype end group for non-group")
  481. }
  482. if fieldNum <= 0 {
  483. return fmt.Errorf("proto: HotReplyReq: illegal tag %d (wire type %d)", fieldNum, wire)
  484. }
  485. switch fieldNum {
  486. case 1:
  487. if wireType != 0 {
  488. return fmt.Errorf("proto: wrong wireType = %d for field Mid", wireType)
  489. }
  490. m.Mid = 0
  491. for shift := uint(0); ; shift += 7 {
  492. if shift >= 64 {
  493. return ErrIntOverflowApi
  494. }
  495. if iNdEx >= l {
  496. return io.ErrUnexpectedEOF
  497. }
  498. b := dAtA[iNdEx]
  499. iNdEx++
  500. m.Mid |= (int64(b) & 0x7F) << shift
  501. if b < 0x80 {
  502. break
  503. }
  504. }
  505. case 2:
  506. if wireType != 0 {
  507. return fmt.Errorf("proto: wrong wireType = %d for field Oid", wireType)
  508. }
  509. m.Oid = 0
  510. for shift := uint(0); ; shift += 7 {
  511. if shift >= 64 {
  512. return ErrIntOverflowApi
  513. }
  514. if iNdEx >= l {
  515. return io.ErrUnexpectedEOF
  516. }
  517. b := dAtA[iNdEx]
  518. iNdEx++
  519. m.Oid |= (int64(b) & 0x7F) << shift
  520. if b < 0x80 {
  521. break
  522. }
  523. }
  524. case 3:
  525. if wireType != 0 {
  526. return fmt.Errorf("proto: wrong wireType = %d for field Tp", wireType)
  527. }
  528. m.Tp = 0
  529. for shift := uint(0); ; shift += 7 {
  530. if shift >= 64 {
  531. return ErrIntOverflowApi
  532. }
  533. if iNdEx >= l {
  534. return io.ErrUnexpectedEOF
  535. }
  536. b := dAtA[iNdEx]
  537. iNdEx++
  538. m.Tp |= (int32(b) & 0x7F) << shift
  539. if b < 0x80 {
  540. break
  541. }
  542. }
  543. case 4:
  544. if wireType != 0 {
  545. return fmt.Errorf("proto: wrong wireType = %d for field Pn", wireType)
  546. }
  547. m.Pn = 0
  548. for shift := uint(0); ; shift += 7 {
  549. if shift >= 64 {
  550. return ErrIntOverflowApi
  551. }
  552. if iNdEx >= l {
  553. return io.ErrUnexpectedEOF
  554. }
  555. b := dAtA[iNdEx]
  556. iNdEx++
  557. m.Pn |= (int32(b) & 0x7F) << shift
  558. if b < 0x80 {
  559. break
  560. }
  561. }
  562. case 5:
  563. if wireType != 0 {
  564. return fmt.Errorf("proto: wrong wireType = %d for field Ps", wireType)
  565. }
  566. m.Ps = 0
  567. for shift := uint(0); ; shift += 7 {
  568. if shift >= 64 {
  569. return ErrIntOverflowApi
  570. }
  571. if iNdEx >= l {
  572. return io.ErrUnexpectedEOF
  573. }
  574. b := dAtA[iNdEx]
  575. iNdEx++
  576. m.Ps |= (int32(b) & 0x7F) << shift
  577. if b < 0x80 {
  578. break
  579. }
  580. }
  581. default:
  582. iNdEx = preIndex
  583. skippy, err := skipApi(dAtA[iNdEx:])
  584. if err != nil {
  585. return err
  586. }
  587. if skippy < 0 {
  588. return ErrInvalidLengthApi
  589. }
  590. if (iNdEx + skippy) > l {
  591. return io.ErrUnexpectedEOF
  592. }
  593. iNdEx += skippy
  594. }
  595. }
  596. if iNdEx > l {
  597. return io.ErrUnexpectedEOF
  598. }
  599. return nil
  600. }
  601. func (m *HotReplyRes) Unmarshal(dAtA []byte) error {
  602. l := len(dAtA)
  603. iNdEx := 0
  604. for iNdEx < l {
  605. preIndex := iNdEx
  606. var wire uint64
  607. for shift := uint(0); ; shift += 7 {
  608. if shift >= 64 {
  609. return ErrIntOverflowApi
  610. }
  611. if iNdEx >= l {
  612. return io.ErrUnexpectedEOF
  613. }
  614. b := dAtA[iNdEx]
  615. iNdEx++
  616. wire |= (uint64(b) & 0x7F) << shift
  617. if b < 0x80 {
  618. break
  619. }
  620. }
  621. fieldNum := int32(wire >> 3)
  622. wireType := int(wire & 0x7)
  623. if wireType == 4 {
  624. return fmt.Errorf("proto: HotReplyRes: wiretype end group for non-group")
  625. }
  626. if fieldNum <= 0 {
  627. return fmt.Errorf("proto: HotReplyRes: illegal tag %d (wire type %d)", fieldNum, wire)
  628. }
  629. switch fieldNum {
  630. case 1:
  631. if wireType != 2 {
  632. return fmt.Errorf("proto: wrong wireType = %d for field Name", wireType)
  633. }
  634. var stringLen uint64
  635. for shift := uint(0); ; shift += 7 {
  636. if shift >= 64 {
  637. return ErrIntOverflowApi
  638. }
  639. if iNdEx >= l {
  640. return io.ErrUnexpectedEOF
  641. }
  642. b := dAtA[iNdEx]
  643. iNdEx++
  644. stringLen |= (uint64(b) & 0x7F) << shift
  645. if b < 0x80 {
  646. break
  647. }
  648. }
  649. intStringLen := int(stringLen)
  650. if intStringLen < 0 {
  651. return ErrInvalidLengthApi
  652. }
  653. postIndex := iNdEx + intStringLen
  654. if postIndex > l {
  655. return io.ErrUnexpectedEOF
  656. }
  657. m.Name = string(dAtA[iNdEx:postIndex])
  658. iNdEx = postIndex
  659. case 2:
  660. if wireType == 0 {
  661. var v int64
  662. for shift := uint(0); ; shift += 7 {
  663. if shift >= 64 {
  664. return ErrIntOverflowApi
  665. }
  666. if iNdEx >= l {
  667. return io.ErrUnexpectedEOF
  668. }
  669. b := dAtA[iNdEx]
  670. iNdEx++
  671. v |= (int64(b) & 0x7F) << shift
  672. if b < 0x80 {
  673. break
  674. }
  675. }
  676. m.RpIDs = append(m.RpIDs, v)
  677. } else if wireType == 2 {
  678. var packedLen int
  679. for shift := uint(0); ; shift += 7 {
  680. if shift >= 64 {
  681. return ErrIntOverflowApi
  682. }
  683. if iNdEx >= l {
  684. return io.ErrUnexpectedEOF
  685. }
  686. b := dAtA[iNdEx]
  687. iNdEx++
  688. packedLen |= (int(b) & 0x7F) << shift
  689. if b < 0x80 {
  690. break
  691. }
  692. }
  693. if packedLen < 0 {
  694. return ErrInvalidLengthApi
  695. }
  696. postIndex := iNdEx + packedLen
  697. if postIndex > l {
  698. return io.ErrUnexpectedEOF
  699. }
  700. for iNdEx < postIndex {
  701. var v int64
  702. for shift := uint(0); ; shift += 7 {
  703. if shift >= 64 {
  704. return ErrIntOverflowApi
  705. }
  706. if iNdEx >= l {
  707. return io.ErrUnexpectedEOF
  708. }
  709. b := dAtA[iNdEx]
  710. iNdEx++
  711. v |= (int64(b) & 0x7F) << shift
  712. if b < 0x80 {
  713. break
  714. }
  715. }
  716. m.RpIDs = append(m.RpIDs, v)
  717. }
  718. } else {
  719. return fmt.Errorf("proto: wrong wireType = %d for field RpIDs", wireType)
  720. }
  721. case 3:
  722. if wireType != 0 {
  723. return fmt.Errorf("proto: wrong wireType = %d for field Count", wireType)
  724. }
  725. m.Count = 0
  726. for shift := uint(0); ; shift += 7 {
  727. if shift >= 64 {
  728. return ErrIntOverflowApi
  729. }
  730. if iNdEx >= l {
  731. return io.ErrUnexpectedEOF
  732. }
  733. b := dAtA[iNdEx]
  734. iNdEx++
  735. m.Count |= (int32(b) & 0x7F) << shift
  736. if b < 0x80 {
  737. break
  738. }
  739. }
  740. default:
  741. iNdEx = preIndex
  742. skippy, err := skipApi(dAtA[iNdEx:])
  743. if err != nil {
  744. return err
  745. }
  746. if skippy < 0 {
  747. return ErrInvalidLengthApi
  748. }
  749. if (iNdEx + skippy) > l {
  750. return io.ErrUnexpectedEOF
  751. }
  752. iNdEx += skippy
  753. }
  754. }
  755. if iNdEx > l {
  756. return io.ErrUnexpectedEOF
  757. }
  758. return nil
  759. }
  760. func (m *ReplyReq) Unmarshal(dAtA []byte) error {
  761. l := len(dAtA)
  762. iNdEx := 0
  763. for iNdEx < l {
  764. preIndex := iNdEx
  765. var wire uint64
  766. for shift := uint(0); ; shift += 7 {
  767. if shift >= 64 {
  768. return ErrIntOverflowApi
  769. }
  770. if iNdEx >= l {
  771. return io.ErrUnexpectedEOF
  772. }
  773. b := dAtA[iNdEx]
  774. iNdEx++
  775. wire |= (uint64(b) & 0x7F) << shift
  776. if b < 0x80 {
  777. break
  778. }
  779. }
  780. fieldNum := int32(wire >> 3)
  781. wireType := int(wire & 0x7)
  782. if wireType == 4 {
  783. return fmt.Errorf("proto: ReplyReq: wiretype end group for non-group")
  784. }
  785. if fieldNum <= 0 {
  786. return fmt.Errorf("proto: ReplyReq: illegal tag %d (wire type %d)", fieldNum, wire)
  787. }
  788. switch fieldNum {
  789. case 1:
  790. if wireType != 0 {
  791. return fmt.Errorf("proto: wrong wireType = %d for field Mid", wireType)
  792. }
  793. m.Mid = 0
  794. for shift := uint(0); ; shift += 7 {
  795. if shift >= 64 {
  796. return ErrIntOverflowApi
  797. }
  798. if iNdEx >= l {
  799. return io.ErrUnexpectedEOF
  800. }
  801. b := dAtA[iNdEx]
  802. iNdEx++
  803. m.Mid |= (int64(b) & 0x7F) << shift
  804. if b < 0x80 {
  805. break
  806. }
  807. }
  808. case 2:
  809. if wireType != 0 {
  810. return fmt.Errorf("proto: wrong wireType = %d for field Pn", wireType)
  811. }
  812. m.Pn = 0
  813. for shift := uint(0); ; shift += 7 {
  814. if shift >= 64 {
  815. return ErrIntOverflowApi
  816. }
  817. if iNdEx >= l {
  818. return io.ErrUnexpectedEOF
  819. }
  820. b := dAtA[iNdEx]
  821. iNdEx++
  822. m.Pn |= (int32(b) & 0x7F) << shift
  823. if b < 0x80 {
  824. break
  825. }
  826. }
  827. case 3:
  828. if wireType != 0 {
  829. return fmt.Errorf("proto: wrong wireType = %d for field Ps", wireType)
  830. }
  831. m.Ps = 0
  832. for shift := uint(0); ; shift += 7 {
  833. if shift >= 64 {
  834. return ErrIntOverflowApi
  835. }
  836. if iNdEx >= l {
  837. return io.ErrUnexpectedEOF
  838. }
  839. b := dAtA[iNdEx]
  840. iNdEx++
  841. m.Ps |= (int32(b) & 0x7F) << shift
  842. if b < 0x80 {
  843. break
  844. }
  845. }
  846. default:
  847. iNdEx = preIndex
  848. skippy, err := skipApi(dAtA[iNdEx:])
  849. if err != nil {
  850. return err
  851. }
  852. if skippy < 0 {
  853. return ErrInvalidLengthApi
  854. }
  855. if (iNdEx + skippy) > l {
  856. return io.ErrUnexpectedEOF
  857. }
  858. iNdEx += skippy
  859. }
  860. }
  861. if iNdEx > l {
  862. return io.ErrUnexpectedEOF
  863. }
  864. return nil
  865. }
  866. func (m *ReplyRes) Unmarshal(dAtA []byte) error {
  867. l := len(dAtA)
  868. iNdEx := 0
  869. for iNdEx < l {
  870. preIndex := iNdEx
  871. var wire uint64
  872. for shift := uint(0); ; shift += 7 {
  873. if shift >= 64 {
  874. return ErrIntOverflowApi
  875. }
  876. if iNdEx >= l {
  877. return io.ErrUnexpectedEOF
  878. }
  879. b := dAtA[iNdEx]
  880. iNdEx++
  881. wire |= (uint64(b) & 0x7F) << shift
  882. if b < 0x80 {
  883. break
  884. }
  885. }
  886. fieldNum := int32(wire >> 3)
  887. wireType := int(wire & 0x7)
  888. if wireType == 4 {
  889. return fmt.Errorf("proto: ReplyRes: wiretype end group for non-group")
  890. }
  891. if fieldNum <= 0 {
  892. return fmt.Errorf("proto: ReplyRes: illegal tag %d (wire type %d)", fieldNum, wire)
  893. }
  894. switch fieldNum {
  895. case 1:
  896. if wireType != 2 {
  897. return fmt.Errorf("proto: wrong wireType = %d for field Name", wireType)
  898. }
  899. var stringLen uint64
  900. for shift := uint(0); ; shift += 7 {
  901. if shift >= 64 {
  902. return ErrIntOverflowApi
  903. }
  904. if iNdEx >= l {
  905. return io.ErrUnexpectedEOF
  906. }
  907. b := dAtA[iNdEx]
  908. iNdEx++
  909. stringLen |= (uint64(b) & 0x7F) << shift
  910. if b < 0x80 {
  911. break
  912. }
  913. }
  914. intStringLen := int(stringLen)
  915. if intStringLen < 0 {
  916. return ErrInvalidLengthApi
  917. }
  918. postIndex := iNdEx + intStringLen
  919. if postIndex > l {
  920. return io.ErrUnexpectedEOF
  921. }
  922. m.Name = string(dAtA[iNdEx:postIndex])
  923. iNdEx = postIndex
  924. default:
  925. iNdEx = preIndex
  926. skippy, err := skipApi(dAtA[iNdEx:])
  927. if err != nil {
  928. return err
  929. }
  930. if skippy < 0 {
  931. return ErrInvalidLengthApi
  932. }
  933. if (iNdEx + skippy) > l {
  934. return io.ErrUnexpectedEOF
  935. }
  936. iNdEx += skippy
  937. }
  938. }
  939. if iNdEx > l {
  940. return io.ErrUnexpectedEOF
  941. }
  942. return nil
  943. }
  944. func skipApi(dAtA []byte) (n int, err error) {
  945. l := len(dAtA)
  946. iNdEx := 0
  947. for iNdEx < l {
  948. var wire uint64
  949. for shift := uint(0); ; shift += 7 {
  950. if shift >= 64 {
  951. return 0, ErrIntOverflowApi
  952. }
  953. if iNdEx >= l {
  954. return 0, io.ErrUnexpectedEOF
  955. }
  956. b := dAtA[iNdEx]
  957. iNdEx++
  958. wire |= (uint64(b) & 0x7F) << shift
  959. if b < 0x80 {
  960. break
  961. }
  962. }
  963. wireType := int(wire & 0x7)
  964. switch wireType {
  965. case 0:
  966. for shift := uint(0); ; shift += 7 {
  967. if shift >= 64 {
  968. return 0, ErrIntOverflowApi
  969. }
  970. if iNdEx >= l {
  971. return 0, io.ErrUnexpectedEOF
  972. }
  973. iNdEx++
  974. if dAtA[iNdEx-1] < 0x80 {
  975. break
  976. }
  977. }
  978. return iNdEx, nil
  979. case 1:
  980. iNdEx += 8
  981. return iNdEx, nil
  982. case 2:
  983. var length int
  984. for shift := uint(0); ; shift += 7 {
  985. if shift >= 64 {
  986. return 0, ErrIntOverflowApi
  987. }
  988. if iNdEx >= l {
  989. return 0, io.ErrUnexpectedEOF
  990. }
  991. b := dAtA[iNdEx]
  992. iNdEx++
  993. length |= (int(b) & 0x7F) << shift
  994. if b < 0x80 {
  995. break
  996. }
  997. }
  998. iNdEx += length
  999. if length < 0 {
  1000. return 0, ErrInvalidLengthApi
  1001. }
  1002. return iNdEx, nil
  1003. case 3:
  1004. for {
  1005. var innerWire uint64
  1006. var start int = iNdEx
  1007. for shift := uint(0); ; shift += 7 {
  1008. if shift >= 64 {
  1009. return 0, ErrIntOverflowApi
  1010. }
  1011. if iNdEx >= l {
  1012. return 0, io.ErrUnexpectedEOF
  1013. }
  1014. b := dAtA[iNdEx]
  1015. iNdEx++
  1016. innerWire |= (uint64(b) & 0x7F) << shift
  1017. if b < 0x80 {
  1018. break
  1019. }
  1020. }
  1021. innerWireType := int(innerWire & 0x7)
  1022. if innerWireType == 4 {
  1023. break
  1024. }
  1025. next, err := skipApi(dAtA[start:])
  1026. if err != nil {
  1027. return 0, err
  1028. }
  1029. iNdEx = start + next
  1030. }
  1031. return iNdEx, nil
  1032. case 4:
  1033. return iNdEx, nil
  1034. case 5:
  1035. iNdEx += 4
  1036. return iNdEx, nil
  1037. default:
  1038. return 0, fmt.Errorf("proto: illegal wireType %d", wireType)
  1039. }
  1040. }
  1041. panic("unreachable")
  1042. }
  1043. var (
  1044. ErrInvalidLengthApi = fmt.Errorf("proto: negative length found during unmarshaling")
  1045. ErrIntOverflowApi = fmt.Errorf("proto: integer overflow")
  1046. )
  1047. func init() { proto.RegisterFile("app/service/main/reply-feed/api/api.proto", fileDescriptorApi) }
  1048. var fileDescriptorApi = []byte{
  1049. // 298 bytes of a gzipped FileDescriptorProto
  1050. 0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0x8c, 0x91, 0xb1, 0x4a, 0xc4, 0x30,
  1051. 0x1c, 0xc6, 0x49, 0x72, 0x95, 0xbb, 0x08, 0x72, 0x04, 0xc1, 0xe0, 0x50, 0xce, 0xe2, 0x50, 0x07,
  1052. 0x53, 0x4e, 0x57, 0xa7, 0x43, 0x44, 0x07, 0x07, 0x33, 0x38, 0xb8, 0xd5, 0x36, 0x42, 0xc0, 0x26,
  1053. 0xb1, 0xc9, 0x15, 0xee, 0xb5, 0x7c, 0x0a, 0x47, 0x1f, 0x41, 0xfa, 0x24, 0x92, 0xe4, 0x2c, 0x87,
  1054. 0x78, 0xea, 0x50, 0xf8, 0x7f, 0x1f, 0x5f, 0xff, 0xdf, 0x8f, 0x7f, 0xf0, 0x49, 0x69, 0x4c, 0x61,
  1055. 0x45, 0xdb, 0xc9, 0x4a, 0x14, 0x4d, 0x29, 0x55, 0xd1, 0x0a, 0xf3, 0xbc, 0x3a, 0x7d, 0x12, 0xa2,
  1056. 0x2e, 0x4a, 0x23, 0xfd, 0xc7, 0x4c, 0xab, 0x9d, 0x26, 0x07, 0x95, 0x6e, 0x9a, 0xa5, 0x92, 0x6e,
  1057. 0xc5, 0x42, 0x86, 0xf9, 0x0c, 0xeb, 0xe6, 0x59, 0x89, 0x77, 0xaf, 0xb5, 0xe3, 0xde, 0xe3, 0xe2,
  1058. 0x85, 0x4c, 0x31, 0x6a, 0x64, 0x4d, 0xc1, 0x0c, 0xe4, 0x88, 0xfb, 0xd1, 0x3b, 0x5a, 0xd6, 0x14,
  1059. 0x46, 0x47, 0xcb, 0x9a, 0xec, 0x61, 0xe8, 0x0c, 0x45, 0x33, 0x90, 0x27, 0x1c, 0x3a, 0xe3, 0xb5,
  1060. 0x51, 0x74, 0x14, 0xb5, 0x51, 0x41, 0x5b, 0x9a, 0xac, 0xb5, 0xcd, 0xee, 0x36, 0x2b, 0x2c, 0x21,
  1061. 0x78, 0xa4, 0xca, 0x46, 0x84, 0x8e, 0x09, 0x0f, 0x33, 0xa1, 0x38, 0x69, 0xcd, 0xcd, 0xa5, 0xa5,
  1062. 0x70, 0x86, 0x72, 0xb4, 0x80, 0x53, 0xc0, 0xa3, 0x41, 0xf6, 0x71, 0x52, 0xe9, 0xa5, 0x72, 0xeb,
  1063. 0xbe, 0x28, 0xb2, 0x0b, 0x3c, 0xfe, 0x05, 0x39, 0x02, 0xc1, 0x6f, 0x40, 0x68, 0x00, 0x4a, 0x87,
  1064. 0xbf, 0x7f, 0xa4, 0x39, 0x7b, 0x05, 0x78, 0x12, 0x02, 0x57, 0x42, 0xd4, 0xe4, 0x1e, 0x8f, 0xbf,
  1065. 0xf0, 0xc9, 0x31, 0xdb, 0x72, 0x47, 0xb6, 0x71, 0xc4, 0xc3, 0xff, 0xa4, 0x2c, 0xb9, 0xc5, 0x49,
  1066. 0x5c, 0x7a, 0xb4, 0x35, 0x3e, 0x6c, 0xfc, 0x33, 0x62, 0x17, 0xd3, 0xb7, 0x3e, 0x05, 0xef, 0x7d,
  1067. 0x0a, 0x3e, 0xfa, 0x14, 0x3c, 0xc0, 0x6e, 0xfe, 0xb8, 0x13, 0x9e, 0xfe, 0xfc, 0x33, 0x00, 0x00,
  1068. 0xff, 0xff, 0x68, 0x87, 0xe8, 0xf5, 0x27, 0x02, 0x00, 0x00,
  1069. }