api.pb.go 30 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821
  1. // Code generated by protoc-gen-gogo. DO NOT EDIT.
  2. // source: app/service/main/up/api/v1/api.proto
  3. /*
  4. Package v1 is a generated protocol buffer package.
  5. It is generated from these files:
  6. app/service/main/up/api/v1/api.proto
  7. app/service/main/up/api/v1/archive.proto
  8. app/service/main/up/api/v1/reply.proto
  9. app/service/main/up/api/v1/request.proto
  10. app/service/main/up/api/v1/sign_up.proto
  11. app/service/main/up/api/v1/up.proto
  12. It has these top-level messages:
  13. AidPubTime
  14. NoReply
  15. UpArcsReply
  16. UpsArcsReply
  17. UpCountReply
  18. UpsCountReply
  19. UpAidPubTimeReply
  20. UpsAidPubTimeReply
  21. UpActivityListReply
  22. UpGroupsReply
  23. UpSpecialReply
  24. UpsSpecialReply
  25. UpGroupMidsReply
  26. UpAttrReply
  27. UpBaseStatReply
  28. UpSwitchReply
  29. HighAllyUpsReply
  30. NoArgReq
  31. UpArcsReq
  32. UpsArcsReq
  33. UpCountReq
  34. UpsCountReq
  35. UpCacheReq
  36. UpListByLastIDReq
  37. UpSpecialReq
  38. UpsSpecialReq
  39. UpGroupMidsReq
  40. UpAttrReq
  41. UpStatReq
  42. UpSwitchReq
  43. HighAllyUpsReq
  44. SignUp
  45. UpActivity
  46. UpGroup
  47. UpSpecial
  48. */
  49. package v1
  50. import proto "github.com/gogo/protobuf/proto"
  51. import fmt "fmt"
  52. import math "math"
  53. import _ "google.golang.org/genproto/googleapis/api/annotations"
  54. import _ "github.com/gogo/protobuf/gogoproto"
  55. import context "golang.org/x/net/context"
  56. import grpc "google.golang.org/grpc"
  57. // Reference imports to suppress errors if they are not otherwise used.
  58. var _ = proto.Marshal
  59. var _ = fmt.Errorf
  60. var _ = math.Inf
  61. // This is a compile-time assertion to ensure that this generated file
  62. // is compatible with the proto package it is being compiled against.
  63. // A compilation error at this line likely means your copy of the
  64. // proto package needs to be updated.
  65. const _ = proto.GoGoProtoPackageIsVersion2 // please upgrade the proto package
  66. // Reference imports to suppress errors if they are not otherwise used.
  67. var _ context.Context
  68. var _ grpc.ClientConn
  69. // This is a compile-time assertion to ensure that this generated file
  70. // is compatible with the grpc package it is being compiled against.
  71. const _ = grpc.SupportPackageIsVersion4
  72. // Client API for Up service
  73. type UpClient interface {
  74. // UpArcs 单个up主的稿件列表接口-带分页
  75. UpArcs(ctx context.Context, in *UpArcsReq, opts ...grpc.CallOption) (*UpArcsReply, error)
  76. // UpsArcs 多个up主的稿件列表接口-带分页
  77. UpsArcs(ctx context.Context, in *UpsArcsReq, opts ...grpc.CallOption) (*UpsArcsReply, error)
  78. // UpCount 单个up主的稿件计数接口
  79. UpCount(ctx context.Context, in *UpCountReq, opts ...grpc.CallOption) (*UpCountReply, error)
  80. // UpsCount 多个up主的稿件计数接口
  81. UpsCount(ctx context.Context, in *UpsCountReq, opts ...grpc.CallOption) (*UpsCountReply, error)
  82. // UpsAidPubTime archives 多个up主的按分布时间排序的aid接口
  83. UpsAidPubTime(ctx context.Context, in *UpsArcsReq, opts ...grpc.CallOption) (*UpsAidPubTimeReply, error)
  84. // AddUpPassedCacheByStaff staff变更 新增或者变更up主稿件信息列表和计数接口
  85. AddUpPassedCacheByStaff(ctx context.Context, in *UpCacheReq, opts ...grpc.CallOption) (*NoReply, error)
  86. // AddUpPassedCache archive变更 新增或者变更up主稿件信息列表和计数接口
  87. AddUpPassedCache(ctx context.Context, in *UpCacheReq, opts ...grpc.CallOption) (*NoReply, error)
  88. // DelUpPassedCacheByStaff staff解除 删除的up主稿件信息列表和计数接口
  89. DelUpPassedCacheByStaff(ctx context.Context, in *UpCacheReq, opts ...grpc.CallOption) (*NoReply, error)
  90. // DelUpPassedCache archive失效 删除的up主稿件信息列表和计数接口
  91. DelUpPassedCache(ctx context.Context, in *UpCacheReq, opts ...grpc.CallOption) (*NoReply, error)
  92. // UpInfoActivitys 获取up主活跃度列表信息的接口
  93. UpInfoActivitys(ctx context.Context, in *UpListByLastIDReq, opts ...grpc.CallOption) (*UpActivityListReply, error)
  94. // UpSpecial 获取up主的特殊属性信息的接口
  95. UpSpecial(ctx context.Context, in *UpSpecialReq, opts ...grpc.CallOption) (*UpSpecialReply, error)
  96. // UpsSpecial 获取多个up主的特殊属性信息的接口
  97. UpsSpecial(ctx context.Context, in *UpsSpecialReq, opts ...grpc.CallOption) (*UpsSpecialReply, error)
  98. // UpGroups 获取所有特殊用户组信息的接口
  99. UpGroups(ctx context.Context, in *NoArgReq, opts ...grpc.CallOption) (*UpGroupsReply, error)
  100. // UpGroupMids 获取某个分组下的所有用户的接口
  101. UpGroupMids(ctx context.Context, in *UpGroupMidsReq, opts ...grpc.CallOption) (*UpGroupMidsReply, error)
  102. // UpAttr 获取up主身份属性的接口
  103. UpAttr(ctx context.Context, in *UpAttrReq, opts ...grpc.CallOption) (*UpAttrReply, error)
  104. // UpBaseStats 获取up主基础计数的接口
  105. UpBaseStats(ctx context.Context, in *UpStatReq, opts ...grpc.CallOption) (*UpBaseStatReply, error)
  106. // SetUpSwitch 设置up主关注弹窗开关的接口
  107. SetUpSwitch(ctx context.Context, in *UpSwitchReq, opts ...grpc.CallOption) (*NoReply, error)
  108. // UpSwitch 获取up主关注弹窗开关的接口
  109. UpSwitch(ctx context.Context, in *UpSwitchReq, opts ...grpc.CallOption) (*UpSwitchReply, error)
  110. // GetHighAllyUps 获取高能联盟up主列表
  111. GetHighAllyUps(ctx context.Context, in *HighAllyUpsReq, opts ...grpc.CallOption) (*HighAllyUpsReply, error)
  112. }
  113. type upClient struct {
  114. cc *grpc.ClientConn
  115. }
  116. func NewUpClient(cc *grpc.ClientConn) UpClient {
  117. return &upClient{cc}
  118. }
  119. func (c *upClient) UpArcs(ctx context.Context, in *UpArcsReq, opts ...grpc.CallOption) (*UpArcsReply, error) {
  120. out := new(UpArcsReply)
  121. err := grpc.Invoke(ctx, "/archive.service.up.v1.Up/UpArcs", in, out, c.cc, opts...)
  122. if err != nil {
  123. return nil, err
  124. }
  125. return out, nil
  126. }
  127. func (c *upClient) UpsArcs(ctx context.Context, in *UpsArcsReq, opts ...grpc.CallOption) (*UpsArcsReply, error) {
  128. out := new(UpsArcsReply)
  129. err := grpc.Invoke(ctx, "/archive.service.up.v1.Up/UpsArcs", in, out, c.cc, opts...)
  130. if err != nil {
  131. return nil, err
  132. }
  133. return out, nil
  134. }
  135. func (c *upClient) UpCount(ctx context.Context, in *UpCountReq, opts ...grpc.CallOption) (*UpCountReply, error) {
  136. out := new(UpCountReply)
  137. err := grpc.Invoke(ctx, "/archive.service.up.v1.Up/UpCount", in, out, c.cc, opts...)
  138. if err != nil {
  139. return nil, err
  140. }
  141. return out, nil
  142. }
  143. func (c *upClient) UpsCount(ctx context.Context, in *UpsCountReq, opts ...grpc.CallOption) (*UpsCountReply, error) {
  144. out := new(UpsCountReply)
  145. err := grpc.Invoke(ctx, "/archive.service.up.v1.Up/UpsCount", in, out, c.cc, opts...)
  146. if err != nil {
  147. return nil, err
  148. }
  149. return out, nil
  150. }
  151. func (c *upClient) UpsAidPubTime(ctx context.Context, in *UpsArcsReq, opts ...grpc.CallOption) (*UpsAidPubTimeReply, error) {
  152. out := new(UpsAidPubTimeReply)
  153. err := grpc.Invoke(ctx, "/archive.service.up.v1.Up/UpsAidPubTime", in, out, c.cc, opts...)
  154. if err != nil {
  155. return nil, err
  156. }
  157. return out, nil
  158. }
  159. func (c *upClient) AddUpPassedCacheByStaff(ctx context.Context, in *UpCacheReq, opts ...grpc.CallOption) (*NoReply, error) {
  160. out := new(NoReply)
  161. err := grpc.Invoke(ctx, "/archive.service.up.v1.Up/AddUpPassedCacheByStaff", in, out, c.cc, opts...)
  162. if err != nil {
  163. return nil, err
  164. }
  165. return out, nil
  166. }
  167. func (c *upClient) AddUpPassedCache(ctx context.Context, in *UpCacheReq, opts ...grpc.CallOption) (*NoReply, error) {
  168. out := new(NoReply)
  169. err := grpc.Invoke(ctx, "/archive.service.up.v1.Up/AddUpPassedCache", in, out, c.cc, opts...)
  170. if err != nil {
  171. return nil, err
  172. }
  173. return out, nil
  174. }
  175. func (c *upClient) DelUpPassedCacheByStaff(ctx context.Context, in *UpCacheReq, opts ...grpc.CallOption) (*NoReply, error) {
  176. out := new(NoReply)
  177. err := grpc.Invoke(ctx, "/archive.service.up.v1.Up/DelUpPassedCacheByStaff", in, out, c.cc, opts...)
  178. if err != nil {
  179. return nil, err
  180. }
  181. return out, nil
  182. }
  183. func (c *upClient) DelUpPassedCache(ctx context.Context, in *UpCacheReq, opts ...grpc.CallOption) (*NoReply, error) {
  184. out := new(NoReply)
  185. err := grpc.Invoke(ctx, "/archive.service.up.v1.Up/DelUpPassedCache", in, out, c.cc, opts...)
  186. if err != nil {
  187. return nil, err
  188. }
  189. return out, nil
  190. }
  191. func (c *upClient) UpInfoActivitys(ctx context.Context, in *UpListByLastIDReq, opts ...grpc.CallOption) (*UpActivityListReply, error) {
  192. out := new(UpActivityListReply)
  193. err := grpc.Invoke(ctx, "/archive.service.up.v1.Up/UpInfoActivitys", in, out, c.cc, opts...)
  194. if err != nil {
  195. return nil, err
  196. }
  197. return out, nil
  198. }
  199. func (c *upClient) UpSpecial(ctx context.Context, in *UpSpecialReq, opts ...grpc.CallOption) (*UpSpecialReply, error) {
  200. out := new(UpSpecialReply)
  201. err := grpc.Invoke(ctx, "/archive.service.up.v1.Up/UpSpecial", in, out, c.cc, opts...)
  202. if err != nil {
  203. return nil, err
  204. }
  205. return out, nil
  206. }
  207. func (c *upClient) UpsSpecial(ctx context.Context, in *UpsSpecialReq, opts ...grpc.CallOption) (*UpsSpecialReply, error) {
  208. out := new(UpsSpecialReply)
  209. err := grpc.Invoke(ctx, "/archive.service.up.v1.Up/UpsSpecial", in, out, c.cc, opts...)
  210. if err != nil {
  211. return nil, err
  212. }
  213. return out, nil
  214. }
  215. func (c *upClient) UpGroups(ctx context.Context, in *NoArgReq, opts ...grpc.CallOption) (*UpGroupsReply, error) {
  216. out := new(UpGroupsReply)
  217. err := grpc.Invoke(ctx, "/archive.service.up.v1.Up/UpGroups", in, out, c.cc, opts...)
  218. if err != nil {
  219. return nil, err
  220. }
  221. return out, nil
  222. }
  223. func (c *upClient) UpGroupMids(ctx context.Context, in *UpGroupMidsReq, opts ...grpc.CallOption) (*UpGroupMidsReply, error) {
  224. out := new(UpGroupMidsReply)
  225. err := grpc.Invoke(ctx, "/archive.service.up.v1.Up/UpGroupMids", in, out, c.cc, opts...)
  226. if err != nil {
  227. return nil, err
  228. }
  229. return out, nil
  230. }
  231. func (c *upClient) UpAttr(ctx context.Context, in *UpAttrReq, opts ...grpc.CallOption) (*UpAttrReply, error) {
  232. out := new(UpAttrReply)
  233. err := grpc.Invoke(ctx, "/archive.service.up.v1.Up/UpAttr", in, out, c.cc, opts...)
  234. if err != nil {
  235. return nil, err
  236. }
  237. return out, nil
  238. }
  239. func (c *upClient) UpBaseStats(ctx context.Context, in *UpStatReq, opts ...grpc.CallOption) (*UpBaseStatReply, error) {
  240. out := new(UpBaseStatReply)
  241. err := grpc.Invoke(ctx, "/archive.service.up.v1.Up/UpBaseStats", in, out, c.cc, opts...)
  242. if err != nil {
  243. return nil, err
  244. }
  245. return out, nil
  246. }
  247. func (c *upClient) SetUpSwitch(ctx context.Context, in *UpSwitchReq, opts ...grpc.CallOption) (*NoReply, error) {
  248. out := new(NoReply)
  249. err := grpc.Invoke(ctx, "/archive.service.up.v1.Up/SetUpSwitch", in, out, c.cc, opts...)
  250. if err != nil {
  251. return nil, err
  252. }
  253. return out, nil
  254. }
  255. func (c *upClient) UpSwitch(ctx context.Context, in *UpSwitchReq, opts ...grpc.CallOption) (*UpSwitchReply, error) {
  256. out := new(UpSwitchReply)
  257. err := grpc.Invoke(ctx, "/archive.service.up.v1.Up/UpSwitch", in, out, c.cc, opts...)
  258. if err != nil {
  259. return nil, err
  260. }
  261. return out, nil
  262. }
  263. func (c *upClient) GetHighAllyUps(ctx context.Context, in *HighAllyUpsReq, opts ...grpc.CallOption) (*HighAllyUpsReply, error) {
  264. out := new(HighAllyUpsReply)
  265. err := grpc.Invoke(ctx, "/archive.service.up.v1.Up/GetHighAllyUps", in, out, c.cc, opts...)
  266. if err != nil {
  267. return nil, err
  268. }
  269. return out, nil
  270. }
  271. // Server API for Up service
  272. type UpServer interface {
  273. // UpArcs 单个up主的稿件列表接口-带分页
  274. UpArcs(context.Context, *UpArcsReq) (*UpArcsReply, error)
  275. // UpsArcs 多个up主的稿件列表接口-带分页
  276. UpsArcs(context.Context, *UpsArcsReq) (*UpsArcsReply, error)
  277. // UpCount 单个up主的稿件计数接口
  278. UpCount(context.Context, *UpCountReq) (*UpCountReply, error)
  279. // UpsCount 多个up主的稿件计数接口
  280. UpsCount(context.Context, *UpsCountReq) (*UpsCountReply, error)
  281. // UpsAidPubTime archives 多个up主的按分布时间排序的aid接口
  282. UpsAidPubTime(context.Context, *UpsArcsReq) (*UpsAidPubTimeReply, error)
  283. // AddUpPassedCacheByStaff staff变更 新增或者变更up主稿件信息列表和计数接口
  284. AddUpPassedCacheByStaff(context.Context, *UpCacheReq) (*NoReply, error)
  285. // AddUpPassedCache archive变更 新增或者变更up主稿件信息列表和计数接口
  286. AddUpPassedCache(context.Context, *UpCacheReq) (*NoReply, error)
  287. // DelUpPassedCacheByStaff staff解除 删除的up主稿件信息列表和计数接口
  288. DelUpPassedCacheByStaff(context.Context, *UpCacheReq) (*NoReply, error)
  289. // DelUpPassedCache archive失效 删除的up主稿件信息列表和计数接口
  290. DelUpPassedCache(context.Context, *UpCacheReq) (*NoReply, error)
  291. // UpInfoActivitys 获取up主活跃度列表信息的接口
  292. UpInfoActivitys(context.Context, *UpListByLastIDReq) (*UpActivityListReply, error)
  293. // UpSpecial 获取up主的特殊属性信息的接口
  294. UpSpecial(context.Context, *UpSpecialReq) (*UpSpecialReply, error)
  295. // UpsSpecial 获取多个up主的特殊属性信息的接口
  296. UpsSpecial(context.Context, *UpsSpecialReq) (*UpsSpecialReply, error)
  297. // UpGroups 获取所有特殊用户组信息的接口
  298. UpGroups(context.Context, *NoArgReq) (*UpGroupsReply, error)
  299. // UpGroupMids 获取某个分组下的所有用户的接口
  300. UpGroupMids(context.Context, *UpGroupMidsReq) (*UpGroupMidsReply, error)
  301. // UpAttr 获取up主身份属性的接口
  302. UpAttr(context.Context, *UpAttrReq) (*UpAttrReply, error)
  303. // UpBaseStats 获取up主基础计数的接口
  304. UpBaseStats(context.Context, *UpStatReq) (*UpBaseStatReply, error)
  305. // SetUpSwitch 设置up主关注弹窗开关的接口
  306. SetUpSwitch(context.Context, *UpSwitchReq) (*NoReply, error)
  307. // UpSwitch 获取up主关注弹窗开关的接口
  308. UpSwitch(context.Context, *UpSwitchReq) (*UpSwitchReply, error)
  309. // GetHighAllyUps 获取高能联盟up主列表
  310. GetHighAllyUps(context.Context, *HighAllyUpsReq) (*HighAllyUpsReply, error)
  311. }
  312. func RegisterUpServer(s *grpc.Server, srv UpServer) {
  313. s.RegisterService(&_Up_serviceDesc, srv)
  314. }
  315. func _Up_UpArcs_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  316. in := new(UpArcsReq)
  317. if err := dec(in); err != nil {
  318. return nil, err
  319. }
  320. if interceptor == nil {
  321. return srv.(UpServer).UpArcs(ctx, in)
  322. }
  323. info := &grpc.UnaryServerInfo{
  324. Server: srv,
  325. FullMethod: "/archive.service.up.v1.Up/UpArcs",
  326. }
  327. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  328. return srv.(UpServer).UpArcs(ctx, req.(*UpArcsReq))
  329. }
  330. return interceptor(ctx, in, info, handler)
  331. }
  332. func _Up_UpsArcs_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  333. in := new(UpsArcsReq)
  334. if err := dec(in); err != nil {
  335. return nil, err
  336. }
  337. if interceptor == nil {
  338. return srv.(UpServer).UpsArcs(ctx, in)
  339. }
  340. info := &grpc.UnaryServerInfo{
  341. Server: srv,
  342. FullMethod: "/archive.service.up.v1.Up/UpsArcs",
  343. }
  344. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  345. return srv.(UpServer).UpsArcs(ctx, req.(*UpsArcsReq))
  346. }
  347. return interceptor(ctx, in, info, handler)
  348. }
  349. func _Up_UpCount_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  350. in := new(UpCountReq)
  351. if err := dec(in); err != nil {
  352. return nil, err
  353. }
  354. if interceptor == nil {
  355. return srv.(UpServer).UpCount(ctx, in)
  356. }
  357. info := &grpc.UnaryServerInfo{
  358. Server: srv,
  359. FullMethod: "/archive.service.up.v1.Up/UpCount",
  360. }
  361. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  362. return srv.(UpServer).UpCount(ctx, req.(*UpCountReq))
  363. }
  364. return interceptor(ctx, in, info, handler)
  365. }
  366. func _Up_UpsCount_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  367. in := new(UpsCountReq)
  368. if err := dec(in); err != nil {
  369. return nil, err
  370. }
  371. if interceptor == nil {
  372. return srv.(UpServer).UpsCount(ctx, in)
  373. }
  374. info := &grpc.UnaryServerInfo{
  375. Server: srv,
  376. FullMethod: "/archive.service.up.v1.Up/UpsCount",
  377. }
  378. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  379. return srv.(UpServer).UpsCount(ctx, req.(*UpsCountReq))
  380. }
  381. return interceptor(ctx, in, info, handler)
  382. }
  383. func _Up_UpsAidPubTime_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  384. in := new(UpsArcsReq)
  385. if err := dec(in); err != nil {
  386. return nil, err
  387. }
  388. if interceptor == nil {
  389. return srv.(UpServer).UpsAidPubTime(ctx, in)
  390. }
  391. info := &grpc.UnaryServerInfo{
  392. Server: srv,
  393. FullMethod: "/archive.service.up.v1.Up/UpsAidPubTime",
  394. }
  395. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  396. return srv.(UpServer).UpsAidPubTime(ctx, req.(*UpsArcsReq))
  397. }
  398. return interceptor(ctx, in, info, handler)
  399. }
  400. func _Up_AddUpPassedCacheByStaff_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  401. in := new(UpCacheReq)
  402. if err := dec(in); err != nil {
  403. return nil, err
  404. }
  405. if interceptor == nil {
  406. return srv.(UpServer).AddUpPassedCacheByStaff(ctx, in)
  407. }
  408. info := &grpc.UnaryServerInfo{
  409. Server: srv,
  410. FullMethod: "/archive.service.up.v1.Up/AddUpPassedCacheByStaff",
  411. }
  412. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  413. return srv.(UpServer).AddUpPassedCacheByStaff(ctx, req.(*UpCacheReq))
  414. }
  415. return interceptor(ctx, in, info, handler)
  416. }
  417. func _Up_AddUpPassedCache_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  418. in := new(UpCacheReq)
  419. if err := dec(in); err != nil {
  420. return nil, err
  421. }
  422. if interceptor == nil {
  423. return srv.(UpServer).AddUpPassedCache(ctx, in)
  424. }
  425. info := &grpc.UnaryServerInfo{
  426. Server: srv,
  427. FullMethod: "/archive.service.up.v1.Up/AddUpPassedCache",
  428. }
  429. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  430. return srv.(UpServer).AddUpPassedCache(ctx, req.(*UpCacheReq))
  431. }
  432. return interceptor(ctx, in, info, handler)
  433. }
  434. func _Up_DelUpPassedCacheByStaff_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  435. in := new(UpCacheReq)
  436. if err := dec(in); err != nil {
  437. return nil, err
  438. }
  439. if interceptor == nil {
  440. return srv.(UpServer).DelUpPassedCacheByStaff(ctx, in)
  441. }
  442. info := &grpc.UnaryServerInfo{
  443. Server: srv,
  444. FullMethod: "/archive.service.up.v1.Up/DelUpPassedCacheByStaff",
  445. }
  446. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  447. return srv.(UpServer).DelUpPassedCacheByStaff(ctx, req.(*UpCacheReq))
  448. }
  449. return interceptor(ctx, in, info, handler)
  450. }
  451. func _Up_DelUpPassedCache_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  452. in := new(UpCacheReq)
  453. if err := dec(in); err != nil {
  454. return nil, err
  455. }
  456. if interceptor == nil {
  457. return srv.(UpServer).DelUpPassedCache(ctx, in)
  458. }
  459. info := &grpc.UnaryServerInfo{
  460. Server: srv,
  461. FullMethod: "/archive.service.up.v1.Up/DelUpPassedCache",
  462. }
  463. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  464. return srv.(UpServer).DelUpPassedCache(ctx, req.(*UpCacheReq))
  465. }
  466. return interceptor(ctx, in, info, handler)
  467. }
  468. func _Up_UpInfoActivitys_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  469. in := new(UpListByLastIDReq)
  470. if err := dec(in); err != nil {
  471. return nil, err
  472. }
  473. if interceptor == nil {
  474. return srv.(UpServer).UpInfoActivitys(ctx, in)
  475. }
  476. info := &grpc.UnaryServerInfo{
  477. Server: srv,
  478. FullMethod: "/archive.service.up.v1.Up/UpInfoActivitys",
  479. }
  480. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  481. return srv.(UpServer).UpInfoActivitys(ctx, req.(*UpListByLastIDReq))
  482. }
  483. return interceptor(ctx, in, info, handler)
  484. }
  485. func _Up_UpSpecial_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  486. in := new(UpSpecialReq)
  487. if err := dec(in); err != nil {
  488. return nil, err
  489. }
  490. if interceptor == nil {
  491. return srv.(UpServer).UpSpecial(ctx, in)
  492. }
  493. info := &grpc.UnaryServerInfo{
  494. Server: srv,
  495. FullMethod: "/archive.service.up.v1.Up/UpSpecial",
  496. }
  497. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  498. return srv.(UpServer).UpSpecial(ctx, req.(*UpSpecialReq))
  499. }
  500. return interceptor(ctx, in, info, handler)
  501. }
  502. func _Up_UpsSpecial_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  503. in := new(UpsSpecialReq)
  504. if err := dec(in); err != nil {
  505. return nil, err
  506. }
  507. if interceptor == nil {
  508. return srv.(UpServer).UpsSpecial(ctx, in)
  509. }
  510. info := &grpc.UnaryServerInfo{
  511. Server: srv,
  512. FullMethod: "/archive.service.up.v1.Up/UpsSpecial",
  513. }
  514. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  515. return srv.(UpServer).UpsSpecial(ctx, req.(*UpsSpecialReq))
  516. }
  517. return interceptor(ctx, in, info, handler)
  518. }
  519. func _Up_UpGroups_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  520. in := new(NoArgReq)
  521. if err := dec(in); err != nil {
  522. return nil, err
  523. }
  524. if interceptor == nil {
  525. return srv.(UpServer).UpGroups(ctx, in)
  526. }
  527. info := &grpc.UnaryServerInfo{
  528. Server: srv,
  529. FullMethod: "/archive.service.up.v1.Up/UpGroups",
  530. }
  531. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  532. return srv.(UpServer).UpGroups(ctx, req.(*NoArgReq))
  533. }
  534. return interceptor(ctx, in, info, handler)
  535. }
  536. func _Up_UpGroupMids_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  537. in := new(UpGroupMidsReq)
  538. if err := dec(in); err != nil {
  539. return nil, err
  540. }
  541. if interceptor == nil {
  542. return srv.(UpServer).UpGroupMids(ctx, in)
  543. }
  544. info := &grpc.UnaryServerInfo{
  545. Server: srv,
  546. FullMethod: "/archive.service.up.v1.Up/UpGroupMids",
  547. }
  548. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  549. return srv.(UpServer).UpGroupMids(ctx, req.(*UpGroupMidsReq))
  550. }
  551. return interceptor(ctx, in, info, handler)
  552. }
  553. func _Up_UpAttr_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  554. in := new(UpAttrReq)
  555. if err := dec(in); err != nil {
  556. return nil, err
  557. }
  558. if interceptor == nil {
  559. return srv.(UpServer).UpAttr(ctx, in)
  560. }
  561. info := &grpc.UnaryServerInfo{
  562. Server: srv,
  563. FullMethod: "/archive.service.up.v1.Up/UpAttr",
  564. }
  565. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  566. return srv.(UpServer).UpAttr(ctx, req.(*UpAttrReq))
  567. }
  568. return interceptor(ctx, in, info, handler)
  569. }
  570. func _Up_UpBaseStats_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  571. in := new(UpStatReq)
  572. if err := dec(in); err != nil {
  573. return nil, err
  574. }
  575. if interceptor == nil {
  576. return srv.(UpServer).UpBaseStats(ctx, in)
  577. }
  578. info := &grpc.UnaryServerInfo{
  579. Server: srv,
  580. FullMethod: "/archive.service.up.v1.Up/UpBaseStats",
  581. }
  582. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  583. return srv.(UpServer).UpBaseStats(ctx, req.(*UpStatReq))
  584. }
  585. return interceptor(ctx, in, info, handler)
  586. }
  587. func _Up_SetUpSwitch_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  588. in := new(UpSwitchReq)
  589. if err := dec(in); err != nil {
  590. return nil, err
  591. }
  592. if interceptor == nil {
  593. return srv.(UpServer).SetUpSwitch(ctx, in)
  594. }
  595. info := &grpc.UnaryServerInfo{
  596. Server: srv,
  597. FullMethod: "/archive.service.up.v1.Up/SetUpSwitch",
  598. }
  599. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  600. return srv.(UpServer).SetUpSwitch(ctx, req.(*UpSwitchReq))
  601. }
  602. return interceptor(ctx, in, info, handler)
  603. }
  604. func _Up_UpSwitch_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  605. in := new(UpSwitchReq)
  606. if err := dec(in); err != nil {
  607. return nil, err
  608. }
  609. if interceptor == nil {
  610. return srv.(UpServer).UpSwitch(ctx, in)
  611. }
  612. info := &grpc.UnaryServerInfo{
  613. Server: srv,
  614. FullMethod: "/archive.service.up.v1.Up/UpSwitch",
  615. }
  616. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  617. return srv.(UpServer).UpSwitch(ctx, req.(*UpSwitchReq))
  618. }
  619. return interceptor(ctx, in, info, handler)
  620. }
  621. func _Up_GetHighAllyUps_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  622. in := new(HighAllyUpsReq)
  623. if err := dec(in); err != nil {
  624. return nil, err
  625. }
  626. if interceptor == nil {
  627. return srv.(UpServer).GetHighAllyUps(ctx, in)
  628. }
  629. info := &grpc.UnaryServerInfo{
  630. Server: srv,
  631. FullMethod: "/archive.service.up.v1.Up/GetHighAllyUps",
  632. }
  633. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  634. return srv.(UpServer).GetHighAllyUps(ctx, req.(*HighAllyUpsReq))
  635. }
  636. return interceptor(ctx, in, info, handler)
  637. }
  638. var _Up_serviceDesc = grpc.ServiceDesc{
  639. ServiceName: "archive.service.up.v1.Up",
  640. HandlerType: (*UpServer)(nil),
  641. Methods: []grpc.MethodDesc{
  642. {
  643. MethodName: "UpArcs",
  644. Handler: _Up_UpArcs_Handler,
  645. },
  646. {
  647. MethodName: "UpsArcs",
  648. Handler: _Up_UpsArcs_Handler,
  649. },
  650. {
  651. MethodName: "UpCount",
  652. Handler: _Up_UpCount_Handler,
  653. },
  654. {
  655. MethodName: "UpsCount",
  656. Handler: _Up_UpsCount_Handler,
  657. },
  658. {
  659. MethodName: "UpsAidPubTime",
  660. Handler: _Up_UpsAidPubTime_Handler,
  661. },
  662. {
  663. MethodName: "AddUpPassedCacheByStaff",
  664. Handler: _Up_AddUpPassedCacheByStaff_Handler,
  665. },
  666. {
  667. MethodName: "AddUpPassedCache",
  668. Handler: _Up_AddUpPassedCache_Handler,
  669. },
  670. {
  671. MethodName: "DelUpPassedCacheByStaff",
  672. Handler: _Up_DelUpPassedCacheByStaff_Handler,
  673. },
  674. {
  675. MethodName: "DelUpPassedCache",
  676. Handler: _Up_DelUpPassedCache_Handler,
  677. },
  678. {
  679. MethodName: "UpInfoActivitys",
  680. Handler: _Up_UpInfoActivitys_Handler,
  681. },
  682. {
  683. MethodName: "UpSpecial",
  684. Handler: _Up_UpSpecial_Handler,
  685. },
  686. {
  687. MethodName: "UpsSpecial",
  688. Handler: _Up_UpsSpecial_Handler,
  689. },
  690. {
  691. MethodName: "UpGroups",
  692. Handler: _Up_UpGroups_Handler,
  693. },
  694. {
  695. MethodName: "UpGroupMids",
  696. Handler: _Up_UpGroupMids_Handler,
  697. },
  698. {
  699. MethodName: "UpAttr",
  700. Handler: _Up_UpAttr_Handler,
  701. },
  702. {
  703. MethodName: "UpBaseStats",
  704. Handler: _Up_UpBaseStats_Handler,
  705. },
  706. {
  707. MethodName: "SetUpSwitch",
  708. Handler: _Up_SetUpSwitch_Handler,
  709. },
  710. {
  711. MethodName: "UpSwitch",
  712. Handler: _Up_UpSwitch_Handler,
  713. },
  714. {
  715. MethodName: "GetHighAllyUps",
  716. Handler: _Up_GetHighAllyUps_Handler,
  717. },
  718. },
  719. Streams: []grpc.StreamDesc{},
  720. Metadata: "app/service/main/up/api/v1/api.proto",
  721. }
  722. func init() { proto.RegisterFile("app/service/main/up/api/v1/api.proto", fileDescriptorApi) }
  723. var fileDescriptorApi = []byte{
  724. // 613 bytes of a gzipped FileDescriptorProto
  725. 0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0xb4, 0x95, 0xdf, 0x6a, 0x14, 0x3d,
  726. 0x18, 0x87, 0xd9, 0x1e, 0xf4, 0xfb, 0x4c, 0xb1, 0x96, 0x80, 0x14, 0x16, 0x59, 0xed, 0xfe, 0xa9,
  727. 0x6d, 0xc5, 0x19, 0x56, 0xaf, 0x60, 0xb7, 0x85, 0x5a, 0xa8, 0xa5, 0xba, 0x0d, 0x42, 0x69, 0xc1,
  728. 0xec, 0x6c, 0x76, 0x36, 0x30, 0x3b, 0x79, 0x9b, 0x64, 0x46, 0x47, 0x44, 0xc4, 0x5b, 0xf0, 0xa6,
  729. 0x3c, 0x12, 0xc1, 0x1b, 0x90, 0xc5, 0x0b, 0x91, 0x64, 0x66, 0x4b, 0x2d, 0x4e, 0x66, 0x85, 0x7a,
  730. 0xd4, 0xce, 0xe4, 0xc9, 0xf3, 0x4b, 0xde, 0x77, 0x92, 0x45, 0x6d, 0x0a, 0xe0, 0x2b, 0x26, 0x53,
  731. 0x1e, 0x30, 0x7f, 0x4a, 0x79, 0xec, 0x27, 0xe0, 0x53, 0xe0, 0x7e, 0xda, 0x35, 0x7f, 0x3c, 0x90,
  732. 0x42, 0x0b, 0x7c, 0x97, 0xca, 0x60, 0xc2, 0x53, 0xe6, 0x15, 0xa4, 0x97, 0x80, 0x97, 0x76, 0xeb,
  733. 0x5b, 0x8e, 0xc9, 0x92, 0x5d, 0x24, 0x4c, 0xe9, 0x5c, 0x50, 0xdf, 0x74, 0x92, 0x10, 0x65, 0x05,
  734. 0x77, 0x2f, 0x14, 0x22, 0x8c, 0x98, 0x1d, 0xa2, 0x71, 0x2c, 0x34, 0xd5, 0x5c, 0xc4, 0xaa, 0x18,
  735. 0x7d, 0x1c, 0x72, 0x3d, 0x49, 0x86, 0x5e, 0x20, 0xa6, 0x7e, 0x28, 0x42, 0xe1, 0xdb, 0xd7, 0xc3,
  736. 0x64, 0x6c, 0x9f, 0xec, 0x83, 0xfd, 0x2f, 0xc7, 0x9f, 0x7c, 0x5d, 0x45, 0x4b, 0x04, 0xf0, 0x3b,
  737. 0xb4, 0x4c, 0xa0, 0x27, 0x03, 0x85, 0x1f, 0x78, 0x7f, 0xdc, 0x87, 0x97, 0x0f, 0xbf, 0x64, 0x17,
  738. 0xf5, 0x66, 0x05, 0x01, 0x51, 0xd6, 0xdc, 0xf9, 0xf4, 0xfd, 0xe7, 0xe7, 0xa5, 0x36, 0x6e, 0xfa,
  739. 0x6f, 0x7d, 0x1e, 0x6b, 0x26, 0x63, 0x1a, 0xf9, 0x09, 0x30, 0xe9, 0x17, 0x73, 0xcd, 0xde, 0x80,
  740. 0x2a, 0xc5, 0x46, 0xf8, 0x03, 0xfa, 0x8f, 0x80, 0xb2, 0xe1, 0x1b, 0xa5, 0x6a, 0x35, 0x4f, 0x6f,
  741. 0x55, 0x21, 0x26, 0xfe, 0x91, 0x8d, 0xef, 0xe0, 0x96, 0x23, 0x5e, 0xcd, 0xf3, 0xdf, 0x9b, 0xfc,
  742. 0x5d, 0x91, 0xc4, 0xda, 0x91, 0x6f, 0xc7, 0xdd, 0xf9, 0x05, 0x62, 0xf2, 0xb7, 0x6d, 0x7e, 0x0b,
  743. 0x6f, 0xb8, 0xb6, 0x1f, 0xd8, 0xc8, 0x8f, 0x35, 0xf4, 0x3f, 0x01, 0x95, 0xe7, 0x97, 0x97, 0x56,
  744. 0x5d, 0x2e, 0xa0, 0x5d, 0xc9, 0x2c, 0xda, 0x00, 0x55, 0x2c, 0xe1, 0x1c, 0xdd, 0x36, 0xd5, 0xe3,
  745. 0xa3, 0xe3, 0x64, 0x78, 0xc2, 0xa7, 0x6c, 0x91, 0x36, 0x6c, 0x3b, 0x90, 0x4b, 0x91, 0x5d, 0x0a,
  746. 0x3e, 0x43, 0xeb, 0xbd, 0xd1, 0x88, 0xc0, 0xb1, 0x2d, 0xf7, 0x2e, 0x0d, 0x26, 0xac, 0x9f, 0x0d,
  747. 0x34, 0x1d, 0x8f, 0x5d, 0xf5, 0x36, 0x98, 0x09, 0x6a, 0x94, 0x20, 0x47, 0x22, 0xb7, 0x13, 0xb4,
  748. 0x76, 0xdd, 0x7e, 0x13, 0xda, 0x33, 0xb4, 0xbe, 0xc7, 0xa2, 0x7f, 0xb8, 0xe8, 0xeb, 0xf6, 0x9b,
  749. 0xd0, 0x86, 0xe8, 0x0e, 0x81, 0x83, 0x78, 0x2c, 0x7a, 0x81, 0xe6, 0x29, 0xd7, 0x99, 0xc2, 0x5b,
  750. 0xa5, 0xd6, 0x43, 0xae, 0x74, 0x3f, 0x3b, 0xa4, 0x4a, 0x1f, 0xec, 0x19, 0xf9, 0x4e, 0xf9, 0xb1,
  751. 0x2e, 0x6c, 0x66, 0x46, 0x1e, 0xf4, 0x0a, 0xdd, 0x22, 0x30, 0x00, 0x16, 0x70, 0x1a, 0xe1, 0xf2,
  752. 0x13, 0x51, 0x10, 0xc6, 0xde, 0xa9, 0x86, 0x8c, 0xf8, 0x14, 0x21, 0x02, 0x6a, 0x6e, 0x76, 0x7c,
  753. 0xea, 0x57, 0xd4, 0x9b, 0x0b, 0x50, 0xc6, 0xfd, 0xc2, 0x1c, 0xb4, 0x7d, 0x29, 0x12, 0x50, 0xf8,
  754. 0x7e, 0x69, 0x25, 0x7b, 0x32, 0x74, 0x9f, 0xb2, 0xdc, 0x90, 0x2b, 0xcf, 0xd1, 0x4a, 0xf1, 0xe2,
  755. 0x39, 0x1f, 0x29, 0xdc, 0x71, 0x4f, 0x32, 0x8c, 0x71, 0x3f, 0x5c, 0x04, 0x33, 0xfa, 0x23, 0x7b,
  756. 0x2b, 0x6b, 0x2d, 0x5d, 0xb7, 0xb2, 0xd6, 0xb2, 0xe2, 0x56, 0xb6, 0x44, 0xde, 0xb6, 0x15, 0x02,
  757. 0x7d, 0xaa, 0xd8, 0x40, 0x53, 0xed, 0xba, 0xea, 0xcd, 0xb8, 0xbb, 0xb4, 0x73, 0xcb, 0xbc, 0xb4,
  758. 0x2b, 0x03, 0xa6, 0x09, 0x0c, 0xde, 0x70, 0x1d, 0x4c, 0x1c, 0xd7, 0x58, 0x0e, 0x2c, 0xf2, 0x2d,
  759. 0x9f, 0x98, 0x6e, 0xfd, 0x85, 0xaf, 0x5d, 0xc9, 0x18, 0xeb, 0x6b, 0xb4, 0xba, 0xcf, 0xf4, 0x33,
  760. 0x1e, 0x4e, 0x7a, 0x51, 0x94, 0x11, 0x28, 0xef, 0xd9, 0x15, 0xc6, 0xd5, 0xb3, 0xdf, 0x30, 0x88,
  761. 0xb2, 0xfe, 0xda, 0x97, 0x59, 0xa3, 0xf6, 0x6d, 0xd6, 0xa8, 0xfd, 0x98, 0x35, 0x6a, 0xa7, 0x4b,
  762. 0x69, 0x77, 0xb8, 0x6c, 0x7f, 0x69, 0x9f, 0xfe, 0x0a, 0x00, 0x00, 0xff, 0xff, 0xc9, 0x84, 0x1b,
  763. 0x65, 0x47, 0x08, 0x00, 0x00,
  764. }