statistics_grpc.pb.go 29 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713
  1. // Code generated by protoc-gen-go-grpc. DO NOT EDIT.
  2. package statistics
  3. import (
  4. context "context"
  5. common "git.ikuban.com/server/pw-protobuf/api/common"
  6. grpc "google.golang.org/grpc"
  7. codes "google.golang.org/grpc/codes"
  8. status "google.golang.org/grpc/status"
  9. emptypb "google.golang.org/protobuf/types/known/emptypb"
  10. )
  11. // This is a compile-time assertion to ensure that this generated file
  12. // is compatible with the grpc package it is being compiled against.
  13. // Requires gRPC-Go v1.32.0 or later.
  14. const _ = grpc.SupportPackageIsVersion7
  15. // StatisticsClient is the client API for Statistics service.
  16. //
  17. // For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
  18. type StatisticsClient interface {
  19. // 观看用户主页
  20. LookPerson(ctx context.Context, in *PersonMessage, opts ...grpc.CallOption) (*emptypb.Empty, error)
  21. // 观看用户主页不发模板消息
  22. LookPersonWithoutTemplate(ctx context.Context, in *PersonMessage, opts ...grpc.CallOption) (*emptypb.Empty, error)
  23. // 关注用户
  24. LikePerson(ctx context.Context, in *PersonMessage, opts ...grpc.CallOption) (*emptypb.Empty, error)
  25. // 取关用户
  26. UnLikePerson(ctx context.Context, in *PersonMessage, opts ...grpc.CallOption) (*emptypb.Empty, error)
  27. // 获取喜欢以及访问统计信息
  28. GetLookAndLikeStatisticsMessage(ctx context.Context, in *GetLookAndLikeStatisticsMessageRequest, opts ...grpc.CallOption) (*LookAndLikeMessageReply, error)
  29. // 获取访问统计信息
  30. GetLookStatisticsMessage(ctx context.Context, in *common.PersonParam, opts ...grpc.CallOption) (*LookMessageReply, error)
  31. // 减少"喜欢我的"的未读数
  32. ReduceLikeUnreadNum(ctx context.Context, in *PersonMessage, opts ...grpc.CallOption) (*emptypb.Empty, error)
  33. // 解锁"看过我的"的记录
  34. UnlockLookRecord(ctx context.Context, in *UnlockLookRecordRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
  35. // 查看看过我的列表
  36. FindLookList(ctx context.Context, in *GetLookAndLikeListRequest, opts ...grpc.CallOption) (*LookAndLikeListReply, error)
  37. // 查看我喜欢的列表
  38. FindLikeList(ctx context.Context, in *GetLookAndLikeListRequest, opts ...grpc.CallOption) (*LookAndLikeListReply, error)
  39. // 查看喜欢我的列表
  40. FindLikedList(ctx context.Context, in *GetLookAndLikeListRequest, opts ...grpc.CallOption) (*LookAndLikeListReply, error)
  41. // 获取我是否喜欢(关注)该用户
  42. GetIsLike(ctx context.Context, in *PersonMessage, opts ...grpc.CallOption) (*common.IsLike, error)
  43. // 统计订阅消息
  44. StatisticsSubscribeMessage(ctx context.Context, in *StatisticsSubscribeMessageRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
  45. // 统计订阅消息
  46. StatisticsAISubscribeMessage(ctx context.Context, in *StatisticsAISubscribeMessageRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
  47. // 减少订阅消息
  48. ReduceSubscribeMessage(ctx context.Context, in *ReduceSubscribeMessageRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
  49. // 获取订阅了签到的人
  50. GetSignUser(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*common.PersonIDList, error)
  51. // 定时删除过期的访客记录
  52. CronDeleteOldLookRecord(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*emptypb.Empty, error)
  53. }
  54. type statisticsClient struct {
  55. cc grpc.ClientConnInterface
  56. }
  57. func NewStatisticsClient(cc grpc.ClientConnInterface) StatisticsClient {
  58. return &statisticsClient{cc}
  59. }
  60. func (c *statisticsClient) LookPerson(ctx context.Context, in *PersonMessage, opts ...grpc.CallOption) (*emptypb.Empty, error) {
  61. out := new(emptypb.Empty)
  62. err := c.cc.Invoke(ctx, "/api.statistics.Statistics/LookPerson", in, out, opts...)
  63. if err != nil {
  64. return nil, err
  65. }
  66. return out, nil
  67. }
  68. func (c *statisticsClient) LookPersonWithoutTemplate(ctx context.Context, in *PersonMessage, opts ...grpc.CallOption) (*emptypb.Empty, error) {
  69. out := new(emptypb.Empty)
  70. err := c.cc.Invoke(ctx, "/api.statistics.Statistics/LookPersonWithoutTemplate", in, out, opts...)
  71. if err != nil {
  72. return nil, err
  73. }
  74. return out, nil
  75. }
  76. func (c *statisticsClient) LikePerson(ctx context.Context, in *PersonMessage, opts ...grpc.CallOption) (*emptypb.Empty, error) {
  77. out := new(emptypb.Empty)
  78. err := c.cc.Invoke(ctx, "/api.statistics.Statistics/LikePerson", in, out, opts...)
  79. if err != nil {
  80. return nil, err
  81. }
  82. return out, nil
  83. }
  84. func (c *statisticsClient) UnLikePerson(ctx context.Context, in *PersonMessage, opts ...grpc.CallOption) (*emptypb.Empty, error) {
  85. out := new(emptypb.Empty)
  86. err := c.cc.Invoke(ctx, "/api.statistics.Statistics/UnLikePerson", in, out, opts...)
  87. if err != nil {
  88. return nil, err
  89. }
  90. return out, nil
  91. }
  92. func (c *statisticsClient) GetLookAndLikeStatisticsMessage(ctx context.Context, in *GetLookAndLikeStatisticsMessageRequest, opts ...grpc.CallOption) (*LookAndLikeMessageReply, error) {
  93. out := new(LookAndLikeMessageReply)
  94. err := c.cc.Invoke(ctx, "/api.statistics.Statistics/GetLookAndLikeStatisticsMessage", in, out, opts...)
  95. if err != nil {
  96. return nil, err
  97. }
  98. return out, nil
  99. }
  100. func (c *statisticsClient) GetLookStatisticsMessage(ctx context.Context, in *common.PersonParam, opts ...grpc.CallOption) (*LookMessageReply, error) {
  101. out := new(LookMessageReply)
  102. err := c.cc.Invoke(ctx, "/api.statistics.Statistics/GetLookStatisticsMessage", in, out, opts...)
  103. if err != nil {
  104. return nil, err
  105. }
  106. return out, nil
  107. }
  108. func (c *statisticsClient) ReduceLikeUnreadNum(ctx context.Context, in *PersonMessage, opts ...grpc.CallOption) (*emptypb.Empty, error) {
  109. out := new(emptypb.Empty)
  110. err := c.cc.Invoke(ctx, "/api.statistics.Statistics/ReduceLikeUnreadNum", in, out, opts...)
  111. if err != nil {
  112. return nil, err
  113. }
  114. return out, nil
  115. }
  116. func (c *statisticsClient) UnlockLookRecord(ctx context.Context, in *UnlockLookRecordRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) {
  117. out := new(emptypb.Empty)
  118. err := c.cc.Invoke(ctx, "/api.statistics.Statistics/UnlockLookRecord", in, out, opts...)
  119. if err != nil {
  120. return nil, err
  121. }
  122. return out, nil
  123. }
  124. func (c *statisticsClient) FindLookList(ctx context.Context, in *GetLookAndLikeListRequest, opts ...grpc.CallOption) (*LookAndLikeListReply, error) {
  125. out := new(LookAndLikeListReply)
  126. err := c.cc.Invoke(ctx, "/api.statistics.Statistics/FindLookList", in, out, opts...)
  127. if err != nil {
  128. return nil, err
  129. }
  130. return out, nil
  131. }
  132. func (c *statisticsClient) FindLikeList(ctx context.Context, in *GetLookAndLikeListRequest, opts ...grpc.CallOption) (*LookAndLikeListReply, error) {
  133. out := new(LookAndLikeListReply)
  134. err := c.cc.Invoke(ctx, "/api.statistics.Statistics/FindLikeList", in, out, opts...)
  135. if err != nil {
  136. return nil, err
  137. }
  138. return out, nil
  139. }
  140. func (c *statisticsClient) FindLikedList(ctx context.Context, in *GetLookAndLikeListRequest, opts ...grpc.CallOption) (*LookAndLikeListReply, error) {
  141. out := new(LookAndLikeListReply)
  142. err := c.cc.Invoke(ctx, "/api.statistics.Statistics/FindLikedList", in, out, opts...)
  143. if err != nil {
  144. return nil, err
  145. }
  146. return out, nil
  147. }
  148. func (c *statisticsClient) GetIsLike(ctx context.Context, in *PersonMessage, opts ...grpc.CallOption) (*common.IsLike, error) {
  149. out := new(common.IsLike)
  150. err := c.cc.Invoke(ctx, "/api.statistics.Statistics/GetIsLike", in, out, opts...)
  151. if err != nil {
  152. return nil, err
  153. }
  154. return out, nil
  155. }
  156. func (c *statisticsClient) StatisticsSubscribeMessage(ctx context.Context, in *StatisticsSubscribeMessageRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) {
  157. out := new(emptypb.Empty)
  158. err := c.cc.Invoke(ctx, "/api.statistics.Statistics/StatisticsSubscribeMessage", in, out, opts...)
  159. if err != nil {
  160. return nil, err
  161. }
  162. return out, nil
  163. }
  164. func (c *statisticsClient) StatisticsAISubscribeMessage(ctx context.Context, in *StatisticsAISubscribeMessageRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) {
  165. out := new(emptypb.Empty)
  166. err := c.cc.Invoke(ctx, "/api.statistics.Statistics/StatisticsAISubscribeMessage", in, out, opts...)
  167. if err != nil {
  168. return nil, err
  169. }
  170. return out, nil
  171. }
  172. func (c *statisticsClient) ReduceSubscribeMessage(ctx context.Context, in *ReduceSubscribeMessageRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) {
  173. out := new(emptypb.Empty)
  174. err := c.cc.Invoke(ctx, "/api.statistics.Statistics/ReduceSubscribeMessage", in, out, opts...)
  175. if err != nil {
  176. return nil, err
  177. }
  178. return out, nil
  179. }
  180. func (c *statisticsClient) GetSignUser(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*common.PersonIDList, error) {
  181. out := new(common.PersonIDList)
  182. err := c.cc.Invoke(ctx, "/api.statistics.Statistics/GetSignUser", in, out, opts...)
  183. if err != nil {
  184. return nil, err
  185. }
  186. return out, nil
  187. }
  188. func (c *statisticsClient) CronDeleteOldLookRecord(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*emptypb.Empty, error) {
  189. out := new(emptypb.Empty)
  190. err := c.cc.Invoke(ctx, "/api.statistics.Statistics/CronDeleteOldLookRecord", in, out, opts...)
  191. if err != nil {
  192. return nil, err
  193. }
  194. return out, nil
  195. }
  196. // StatisticsServer is the server API for Statistics service.
  197. // All implementations must embed UnimplementedStatisticsServer
  198. // for forward compatibility
  199. type StatisticsServer interface {
  200. // 观看用户主页
  201. LookPerson(context.Context, *PersonMessage) (*emptypb.Empty, error)
  202. // 观看用户主页不发模板消息
  203. LookPersonWithoutTemplate(context.Context, *PersonMessage) (*emptypb.Empty, error)
  204. // 关注用户
  205. LikePerson(context.Context, *PersonMessage) (*emptypb.Empty, error)
  206. // 取关用户
  207. UnLikePerson(context.Context, *PersonMessage) (*emptypb.Empty, error)
  208. // 获取喜欢以及访问统计信息
  209. GetLookAndLikeStatisticsMessage(context.Context, *GetLookAndLikeStatisticsMessageRequest) (*LookAndLikeMessageReply, error)
  210. // 获取访问统计信息
  211. GetLookStatisticsMessage(context.Context, *common.PersonParam) (*LookMessageReply, error)
  212. // 减少"喜欢我的"的未读数
  213. ReduceLikeUnreadNum(context.Context, *PersonMessage) (*emptypb.Empty, error)
  214. // 解锁"看过我的"的记录
  215. UnlockLookRecord(context.Context, *UnlockLookRecordRequest) (*emptypb.Empty, error)
  216. // 查看看过我的列表
  217. FindLookList(context.Context, *GetLookAndLikeListRequest) (*LookAndLikeListReply, error)
  218. // 查看我喜欢的列表
  219. FindLikeList(context.Context, *GetLookAndLikeListRequest) (*LookAndLikeListReply, error)
  220. // 查看喜欢我的列表
  221. FindLikedList(context.Context, *GetLookAndLikeListRequest) (*LookAndLikeListReply, error)
  222. // 获取我是否喜欢(关注)该用户
  223. GetIsLike(context.Context, *PersonMessage) (*common.IsLike, error)
  224. // 统计订阅消息
  225. StatisticsSubscribeMessage(context.Context, *StatisticsSubscribeMessageRequest) (*emptypb.Empty, error)
  226. // 统计订阅消息
  227. StatisticsAISubscribeMessage(context.Context, *StatisticsAISubscribeMessageRequest) (*emptypb.Empty, error)
  228. // 减少订阅消息
  229. ReduceSubscribeMessage(context.Context, *ReduceSubscribeMessageRequest) (*emptypb.Empty, error)
  230. // 获取订阅了签到的人
  231. GetSignUser(context.Context, *emptypb.Empty) (*common.PersonIDList, error)
  232. // 定时删除过期的访客记录
  233. CronDeleteOldLookRecord(context.Context, *emptypb.Empty) (*emptypb.Empty, error)
  234. mustEmbedUnimplementedStatisticsServer()
  235. }
  236. // UnimplementedStatisticsServer must be embedded to have forward compatible implementations.
  237. type UnimplementedStatisticsServer struct {
  238. }
  239. func (UnimplementedStatisticsServer) LookPerson(context.Context, *PersonMessage) (*emptypb.Empty, error) {
  240. return nil, status.Errorf(codes.Unimplemented, "method LookPerson not implemented")
  241. }
  242. func (UnimplementedStatisticsServer) LookPersonWithoutTemplate(context.Context, *PersonMessage) (*emptypb.Empty, error) {
  243. return nil, status.Errorf(codes.Unimplemented, "method LookPersonWithoutTemplate not implemented")
  244. }
  245. func (UnimplementedStatisticsServer) LikePerson(context.Context, *PersonMessage) (*emptypb.Empty, error) {
  246. return nil, status.Errorf(codes.Unimplemented, "method LikePerson not implemented")
  247. }
  248. func (UnimplementedStatisticsServer) UnLikePerson(context.Context, *PersonMessage) (*emptypb.Empty, error) {
  249. return nil, status.Errorf(codes.Unimplemented, "method UnLikePerson not implemented")
  250. }
  251. func (UnimplementedStatisticsServer) GetLookAndLikeStatisticsMessage(context.Context, *GetLookAndLikeStatisticsMessageRequest) (*LookAndLikeMessageReply, error) {
  252. return nil, status.Errorf(codes.Unimplemented, "method GetLookAndLikeStatisticsMessage not implemented")
  253. }
  254. func (UnimplementedStatisticsServer) GetLookStatisticsMessage(context.Context, *common.PersonParam) (*LookMessageReply, error) {
  255. return nil, status.Errorf(codes.Unimplemented, "method GetLookStatisticsMessage not implemented")
  256. }
  257. func (UnimplementedStatisticsServer) ReduceLikeUnreadNum(context.Context, *PersonMessage) (*emptypb.Empty, error) {
  258. return nil, status.Errorf(codes.Unimplemented, "method ReduceLikeUnreadNum not implemented")
  259. }
  260. func (UnimplementedStatisticsServer) UnlockLookRecord(context.Context, *UnlockLookRecordRequest) (*emptypb.Empty, error) {
  261. return nil, status.Errorf(codes.Unimplemented, "method UnlockLookRecord not implemented")
  262. }
  263. func (UnimplementedStatisticsServer) FindLookList(context.Context, *GetLookAndLikeListRequest) (*LookAndLikeListReply, error) {
  264. return nil, status.Errorf(codes.Unimplemented, "method FindLookList not implemented")
  265. }
  266. func (UnimplementedStatisticsServer) FindLikeList(context.Context, *GetLookAndLikeListRequest) (*LookAndLikeListReply, error) {
  267. return nil, status.Errorf(codes.Unimplemented, "method FindLikeList not implemented")
  268. }
  269. func (UnimplementedStatisticsServer) FindLikedList(context.Context, *GetLookAndLikeListRequest) (*LookAndLikeListReply, error) {
  270. return nil, status.Errorf(codes.Unimplemented, "method FindLikedList not implemented")
  271. }
  272. func (UnimplementedStatisticsServer) GetIsLike(context.Context, *PersonMessage) (*common.IsLike, error) {
  273. return nil, status.Errorf(codes.Unimplemented, "method GetIsLike not implemented")
  274. }
  275. func (UnimplementedStatisticsServer) StatisticsSubscribeMessage(context.Context, *StatisticsSubscribeMessageRequest) (*emptypb.Empty, error) {
  276. return nil, status.Errorf(codes.Unimplemented, "method StatisticsSubscribeMessage not implemented")
  277. }
  278. func (UnimplementedStatisticsServer) StatisticsAISubscribeMessage(context.Context, *StatisticsAISubscribeMessageRequest) (*emptypb.Empty, error) {
  279. return nil, status.Errorf(codes.Unimplemented, "method StatisticsAISubscribeMessage not implemented")
  280. }
  281. func (UnimplementedStatisticsServer) ReduceSubscribeMessage(context.Context, *ReduceSubscribeMessageRequest) (*emptypb.Empty, error) {
  282. return nil, status.Errorf(codes.Unimplemented, "method ReduceSubscribeMessage not implemented")
  283. }
  284. func (UnimplementedStatisticsServer) GetSignUser(context.Context, *emptypb.Empty) (*common.PersonIDList, error) {
  285. return nil, status.Errorf(codes.Unimplemented, "method GetSignUser not implemented")
  286. }
  287. func (UnimplementedStatisticsServer) CronDeleteOldLookRecord(context.Context, *emptypb.Empty) (*emptypb.Empty, error) {
  288. return nil, status.Errorf(codes.Unimplemented, "method CronDeleteOldLookRecord not implemented")
  289. }
  290. func (UnimplementedStatisticsServer) mustEmbedUnimplementedStatisticsServer() {}
  291. // UnsafeStatisticsServer may be embedded to opt out of forward compatibility for this service.
  292. // Use of this interface is not recommended, as added methods to StatisticsServer will
  293. // result in compilation errors.
  294. type UnsafeStatisticsServer interface {
  295. mustEmbedUnimplementedStatisticsServer()
  296. }
  297. func RegisterStatisticsServer(s grpc.ServiceRegistrar, srv StatisticsServer) {
  298. s.RegisterService(&Statistics_ServiceDesc, srv)
  299. }
  300. func _Statistics_LookPerson_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  301. in := new(PersonMessage)
  302. if err := dec(in); err != nil {
  303. return nil, err
  304. }
  305. if interceptor == nil {
  306. return srv.(StatisticsServer).LookPerson(ctx, in)
  307. }
  308. info := &grpc.UnaryServerInfo{
  309. Server: srv,
  310. FullMethod: "/api.statistics.Statistics/LookPerson",
  311. }
  312. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  313. return srv.(StatisticsServer).LookPerson(ctx, req.(*PersonMessage))
  314. }
  315. return interceptor(ctx, in, info, handler)
  316. }
  317. func _Statistics_LookPersonWithoutTemplate_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  318. in := new(PersonMessage)
  319. if err := dec(in); err != nil {
  320. return nil, err
  321. }
  322. if interceptor == nil {
  323. return srv.(StatisticsServer).LookPersonWithoutTemplate(ctx, in)
  324. }
  325. info := &grpc.UnaryServerInfo{
  326. Server: srv,
  327. FullMethod: "/api.statistics.Statistics/LookPersonWithoutTemplate",
  328. }
  329. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  330. return srv.(StatisticsServer).LookPersonWithoutTemplate(ctx, req.(*PersonMessage))
  331. }
  332. return interceptor(ctx, in, info, handler)
  333. }
  334. func _Statistics_LikePerson_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  335. in := new(PersonMessage)
  336. if err := dec(in); err != nil {
  337. return nil, err
  338. }
  339. if interceptor == nil {
  340. return srv.(StatisticsServer).LikePerson(ctx, in)
  341. }
  342. info := &grpc.UnaryServerInfo{
  343. Server: srv,
  344. FullMethod: "/api.statistics.Statistics/LikePerson",
  345. }
  346. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  347. return srv.(StatisticsServer).LikePerson(ctx, req.(*PersonMessage))
  348. }
  349. return interceptor(ctx, in, info, handler)
  350. }
  351. func _Statistics_UnLikePerson_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  352. in := new(PersonMessage)
  353. if err := dec(in); err != nil {
  354. return nil, err
  355. }
  356. if interceptor == nil {
  357. return srv.(StatisticsServer).UnLikePerson(ctx, in)
  358. }
  359. info := &grpc.UnaryServerInfo{
  360. Server: srv,
  361. FullMethod: "/api.statistics.Statistics/UnLikePerson",
  362. }
  363. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  364. return srv.(StatisticsServer).UnLikePerson(ctx, req.(*PersonMessage))
  365. }
  366. return interceptor(ctx, in, info, handler)
  367. }
  368. func _Statistics_GetLookAndLikeStatisticsMessage_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  369. in := new(GetLookAndLikeStatisticsMessageRequest)
  370. if err := dec(in); err != nil {
  371. return nil, err
  372. }
  373. if interceptor == nil {
  374. return srv.(StatisticsServer).GetLookAndLikeStatisticsMessage(ctx, in)
  375. }
  376. info := &grpc.UnaryServerInfo{
  377. Server: srv,
  378. FullMethod: "/api.statistics.Statistics/GetLookAndLikeStatisticsMessage",
  379. }
  380. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  381. return srv.(StatisticsServer).GetLookAndLikeStatisticsMessage(ctx, req.(*GetLookAndLikeStatisticsMessageRequest))
  382. }
  383. return interceptor(ctx, in, info, handler)
  384. }
  385. func _Statistics_GetLookStatisticsMessage_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  386. in := new(common.PersonParam)
  387. if err := dec(in); err != nil {
  388. return nil, err
  389. }
  390. if interceptor == nil {
  391. return srv.(StatisticsServer).GetLookStatisticsMessage(ctx, in)
  392. }
  393. info := &grpc.UnaryServerInfo{
  394. Server: srv,
  395. FullMethod: "/api.statistics.Statistics/GetLookStatisticsMessage",
  396. }
  397. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  398. return srv.(StatisticsServer).GetLookStatisticsMessage(ctx, req.(*common.PersonParam))
  399. }
  400. return interceptor(ctx, in, info, handler)
  401. }
  402. func _Statistics_ReduceLikeUnreadNum_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  403. in := new(PersonMessage)
  404. if err := dec(in); err != nil {
  405. return nil, err
  406. }
  407. if interceptor == nil {
  408. return srv.(StatisticsServer).ReduceLikeUnreadNum(ctx, in)
  409. }
  410. info := &grpc.UnaryServerInfo{
  411. Server: srv,
  412. FullMethod: "/api.statistics.Statistics/ReduceLikeUnreadNum",
  413. }
  414. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  415. return srv.(StatisticsServer).ReduceLikeUnreadNum(ctx, req.(*PersonMessage))
  416. }
  417. return interceptor(ctx, in, info, handler)
  418. }
  419. func _Statistics_UnlockLookRecord_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  420. in := new(UnlockLookRecordRequest)
  421. if err := dec(in); err != nil {
  422. return nil, err
  423. }
  424. if interceptor == nil {
  425. return srv.(StatisticsServer).UnlockLookRecord(ctx, in)
  426. }
  427. info := &grpc.UnaryServerInfo{
  428. Server: srv,
  429. FullMethod: "/api.statistics.Statistics/UnlockLookRecord",
  430. }
  431. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  432. return srv.(StatisticsServer).UnlockLookRecord(ctx, req.(*UnlockLookRecordRequest))
  433. }
  434. return interceptor(ctx, in, info, handler)
  435. }
  436. func _Statistics_FindLookList_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  437. in := new(GetLookAndLikeListRequest)
  438. if err := dec(in); err != nil {
  439. return nil, err
  440. }
  441. if interceptor == nil {
  442. return srv.(StatisticsServer).FindLookList(ctx, in)
  443. }
  444. info := &grpc.UnaryServerInfo{
  445. Server: srv,
  446. FullMethod: "/api.statistics.Statistics/FindLookList",
  447. }
  448. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  449. return srv.(StatisticsServer).FindLookList(ctx, req.(*GetLookAndLikeListRequest))
  450. }
  451. return interceptor(ctx, in, info, handler)
  452. }
  453. func _Statistics_FindLikeList_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  454. in := new(GetLookAndLikeListRequest)
  455. if err := dec(in); err != nil {
  456. return nil, err
  457. }
  458. if interceptor == nil {
  459. return srv.(StatisticsServer).FindLikeList(ctx, in)
  460. }
  461. info := &grpc.UnaryServerInfo{
  462. Server: srv,
  463. FullMethod: "/api.statistics.Statistics/FindLikeList",
  464. }
  465. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  466. return srv.(StatisticsServer).FindLikeList(ctx, req.(*GetLookAndLikeListRequest))
  467. }
  468. return interceptor(ctx, in, info, handler)
  469. }
  470. func _Statistics_FindLikedList_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  471. in := new(GetLookAndLikeListRequest)
  472. if err := dec(in); err != nil {
  473. return nil, err
  474. }
  475. if interceptor == nil {
  476. return srv.(StatisticsServer).FindLikedList(ctx, in)
  477. }
  478. info := &grpc.UnaryServerInfo{
  479. Server: srv,
  480. FullMethod: "/api.statistics.Statistics/FindLikedList",
  481. }
  482. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  483. return srv.(StatisticsServer).FindLikedList(ctx, req.(*GetLookAndLikeListRequest))
  484. }
  485. return interceptor(ctx, in, info, handler)
  486. }
  487. func _Statistics_GetIsLike_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  488. in := new(PersonMessage)
  489. if err := dec(in); err != nil {
  490. return nil, err
  491. }
  492. if interceptor == nil {
  493. return srv.(StatisticsServer).GetIsLike(ctx, in)
  494. }
  495. info := &grpc.UnaryServerInfo{
  496. Server: srv,
  497. FullMethod: "/api.statistics.Statistics/GetIsLike",
  498. }
  499. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  500. return srv.(StatisticsServer).GetIsLike(ctx, req.(*PersonMessage))
  501. }
  502. return interceptor(ctx, in, info, handler)
  503. }
  504. func _Statistics_StatisticsSubscribeMessage_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  505. in := new(StatisticsSubscribeMessageRequest)
  506. if err := dec(in); err != nil {
  507. return nil, err
  508. }
  509. if interceptor == nil {
  510. return srv.(StatisticsServer).StatisticsSubscribeMessage(ctx, in)
  511. }
  512. info := &grpc.UnaryServerInfo{
  513. Server: srv,
  514. FullMethod: "/api.statistics.Statistics/StatisticsSubscribeMessage",
  515. }
  516. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  517. return srv.(StatisticsServer).StatisticsSubscribeMessage(ctx, req.(*StatisticsSubscribeMessageRequest))
  518. }
  519. return interceptor(ctx, in, info, handler)
  520. }
  521. func _Statistics_StatisticsAISubscribeMessage_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  522. in := new(StatisticsAISubscribeMessageRequest)
  523. if err := dec(in); err != nil {
  524. return nil, err
  525. }
  526. if interceptor == nil {
  527. return srv.(StatisticsServer).StatisticsAISubscribeMessage(ctx, in)
  528. }
  529. info := &grpc.UnaryServerInfo{
  530. Server: srv,
  531. FullMethod: "/api.statistics.Statistics/StatisticsAISubscribeMessage",
  532. }
  533. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  534. return srv.(StatisticsServer).StatisticsAISubscribeMessage(ctx, req.(*StatisticsAISubscribeMessageRequest))
  535. }
  536. return interceptor(ctx, in, info, handler)
  537. }
  538. func _Statistics_ReduceSubscribeMessage_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  539. in := new(ReduceSubscribeMessageRequest)
  540. if err := dec(in); err != nil {
  541. return nil, err
  542. }
  543. if interceptor == nil {
  544. return srv.(StatisticsServer).ReduceSubscribeMessage(ctx, in)
  545. }
  546. info := &grpc.UnaryServerInfo{
  547. Server: srv,
  548. FullMethod: "/api.statistics.Statistics/ReduceSubscribeMessage",
  549. }
  550. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  551. return srv.(StatisticsServer).ReduceSubscribeMessage(ctx, req.(*ReduceSubscribeMessageRequest))
  552. }
  553. return interceptor(ctx, in, info, handler)
  554. }
  555. func _Statistics_GetSignUser_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  556. in := new(emptypb.Empty)
  557. if err := dec(in); err != nil {
  558. return nil, err
  559. }
  560. if interceptor == nil {
  561. return srv.(StatisticsServer).GetSignUser(ctx, in)
  562. }
  563. info := &grpc.UnaryServerInfo{
  564. Server: srv,
  565. FullMethod: "/api.statistics.Statistics/GetSignUser",
  566. }
  567. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  568. return srv.(StatisticsServer).GetSignUser(ctx, req.(*emptypb.Empty))
  569. }
  570. return interceptor(ctx, in, info, handler)
  571. }
  572. func _Statistics_CronDeleteOldLookRecord_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  573. in := new(emptypb.Empty)
  574. if err := dec(in); err != nil {
  575. return nil, err
  576. }
  577. if interceptor == nil {
  578. return srv.(StatisticsServer).CronDeleteOldLookRecord(ctx, in)
  579. }
  580. info := &grpc.UnaryServerInfo{
  581. Server: srv,
  582. FullMethod: "/api.statistics.Statistics/CronDeleteOldLookRecord",
  583. }
  584. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  585. return srv.(StatisticsServer).CronDeleteOldLookRecord(ctx, req.(*emptypb.Empty))
  586. }
  587. return interceptor(ctx, in, info, handler)
  588. }
  589. // Statistics_ServiceDesc is the grpc.ServiceDesc for Statistics service.
  590. // It's only intended for direct use with grpc.RegisterService,
  591. // and not to be introspected or modified (even as a copy)
  592. var Statistics_ServiceDesc = grpc.ServiceDesc{
  593. ServiceName: "api.statistics.Statistics",
  594. HandlerType: (*StatisticsServer)(nil),
  595. Methods: []grpc.MethodDesc{
  596. {
  597. MethodName: "LookPerson",
  598. Handler: _Statistics_LookPerson_Handler,
  599. },
  600. {
  601. MethodName: "LookPersonWithoutTemplate",
  602. Handler: _Statistics_LookPersonWithoutTemplate_Handler,
  603. },
  604. {
  605. MethodName: "LikePerson",
  606. Handler: _Statistics_LikePerson_Handler,
  607. },
  608. {
  609. MethodName: "UnLikePerson",
  610. Handler: _Statistics_UnLikePerson_Handler,
  611. },
  612. {
  613. MethodName: "GetLookAndLikeStatisticsMessage",
  614. Handler: _Statistics_GetLookAndLikeStatisticsMessage_Handler,
  615. },
  616. {
  617. MethodName: "GetLookStatisticsMessage",
  618. Handler: _Statistics_GetLookStatisticsMessage_Handler,
  619. },
  620. {
  621. MethodName: "ReduceLikeUnreadNum",
  622. Handler: _Statistics_ReduceLikeUnreadNum_Handler,
  623. },
  624. {
  625. MethodName: "UnlockLookRecord",
  626. Handler: _Statistics_UnlockLookRecord_Handler,
  627. },
  628. {
  629. MethodName: "FindLookList",
  630. Handler: _Statistics_FindLookList_Handler,
  631. },
  632. {
  633. MethodName: "FindLikeList",
  634. Handler: _Statistics_FindLikeList_Handler,
  635. },
  636. {
  637. MethodName: "FindLikedList",
  638. Handler: _Statistics_FindLikedList_Handler,
  639. },
  640. {
  641. MethodName: "GetIsLike",
  642. Handler: _Statistics_GetIsLike_Handler,
  643. },
  644. {
  645. MethodName: "StatisticsSubscribeMessage",
  646. Handler: _Statistics_StatisticsSubscribeMessage_Handler,
  647. },
  648. {
  649. MethodName: "StatisticsAISubscribeMessage",
  650. Handler: _Statistics_StatisticsAISubscribeMessage_Handler,
  651. },
  652. {
  653. MethodName: "ReduceSubscribeMessage",
  654. Handler: _Statistics_ReduceSubscribeMessage_Handler,
  655. },
  656. {
  657. MethodName: "GetSignUser",
  658. Handler: _Statistics_GetSignUser_Handler,
  659. },
  660. {
  661. MethodName: "CronDeleteOldLookRecord",
  662. Handler: _Statistics_CronDeleteOldLookRecord_Handler,
  663. },
  664. },
  665. Streams: []grpc.StreamDesc{},
  666. Metadata: "statistics.proto",
  667. }