message.pb.go 69 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173117411751176117711781179118011811182118311841185118611871188118911901191119211931194119511961197119811991200120112021203120412051206120712081209121012111212121312141215121612171218121912201221122212231224122512261227122812291230123112321233123412351236123712381239124012411242124312441245124612471248124912501251125212531254125512561257125812591260126112621263126412651266126712681269127012711272127312741275127612771278127912801281128212831284128512861287128812891290129112921293129412951296129712981299130013011302130313041305130613071308130913101311131213131314131513161317131813191320132113221323132413251326132713281329133013311332133313341335133613371338133913401341134213431344134513461347134813491350135113521353135413551356135713581359136013611362136313641365136613671368136913701371137213731374137513761377137813791380138113821383138413851386138713881389139013911392139313941395139613971398139914001401140214031404140514061407140814091410141114121413141414151416141714181419142014211422142314241425142614271428142914301431143214331434143514361437143814391440144114421443144414451446144714481449145014511452145314541455145614571458145914601461146214631464146514661467146814691470147114721473147414751476147714781479148014811482148314841485148614871488148914901491149214931494149514961497149814991500150115021503150415051506150715081509151015111512151315141515151615171518151915201521152215231524152515261527152815291530153115321533153415351536153715381539154015411542154315441545154615471548154915501551155215531554155515561557155815591560156115621563156415651566156715681569157015711572157315741575157615771578157915801581158215831584158515861587158815891590159115921593159415951596159715981599160016011602160316041605160616071608160916101611161216131614161516161617161816191620162116221623162416251626162716281629163016311632163316341635163616371638163916401641164216431644164516461647164816491650165116521653165416551656165716581659166016611662166316641665166616671668166916701671167216731674167516761677167816791680168116821683168416851686168716881689169016911692169316941695169616971698169917001701170217031704170517061707170817091710171117121713171417151716171717181719172017211722172317241725172617271728172917301731173217331734173517361737173817391740174117421743174417451746174717481749175017511752175317541755175617571758175917601761176217631764176517661767176817691770177117721773177417751776177717781779178017811782178317841785178617871788178917901791179217931794179517961797179817991800180118021803180418051806180718081809181018111812181318141815181618171818181918201821182218231824182518261827182818291830183118321833183418351836183718381839184018411842184318441845184618471848184918501851185218531854185518561857185818591860186118621863186418651866186718681869187018711872187318741875187618771878187918801881188218831884188518861887188818891890189118921893189418951896189718981899190019011902190319041905190619071908190919101911191219131914191519161917191819191920192119221923192419251926192719281929193019311932193319341935193619371938193919401941194219431944194519461947194819491950195119521953195419551956195719581959196019611962196319641965196619671968196919701971197219731974197519761977
  1. // Code generated by protoc-gen-go. DO NOT EDIT.
  2. // versions:
  3. // protoc-gen-go v1.25.0
  4. // protoc v3.15.1
  5. // source: message.proto
  6. package message
  7. import (
  8. context "context"
  9. proto "github.com/golang/protobuf/proto"
  10. grpc "google.golang.org/grpc"
  11. codes "google.golang.org/grpc/codes"
  12. status "google.golang.org/grpc/status"
  13. protoreflect "google.golang.org/protobuf/reflect/protoreflect"
  14. protoimpl "google.golang.org/protobuf/runtime/protoimpl"
  15. reflect "reflect"
  16. sync "sync"
  17. )
  18. const (
  19. // Verify that this generated code is sufficiently up-to-date.
  20. _ = protoimpl.EnforceVersion(20 - protoimpl.MinVersion)
  21. // Verify that runtime/protoimpl is sufficiently up-to-date.
  22. _ = protoimpl.EnforceVersion(protoimpl.MaxVersion - 20)
  23. )
  24. // This is a compile-time assertion that a sufficiently up-to-date version
  25. // of the legacy proto package is being used.
  26. const _ = proto.ProtoPackageIsVersion4
  27. type SendMsgRequest struct {
  28. state protoimpl.MessageState
  29. sizeCache protoimpl.SizeCache
  30. unknownFields protoimpl.UnknownFields
  31. ReceiveUserId string `protobuf:"bytes,1,opt,name=receiveUserId,proto3" json:"receiveUserId,omitempty"` //接收方用户ID
  32. ReceiveName string `protobuf:"bytes,2,opt,name=receiveName,proto3" json:"receiveName,omitempty"` //接收方用户名
  33. SendUserId string `protobuf:"bytes,3,opt,name=sendUserId,proto3" json:"sendUserId,omitempty"` //发送方用户ID
  34. SendName string `protobuf:"bytes,4,opt,name=sendName,proto3" json:"sendName,omitempty"` //发送方用户名
  35. Title string `protobuf:"bytes,5,opt,name=title,proto3" json:"title,omitempty"` //主题
  36. Content string `protobuf:"bytes,6,opt,name=content,proto3" json:"content,omitempty"` //内容
  37. MsgType int64 `protobuf:"varint,7,opt,name=msgType,proto3" json:"msgType,omitempty"` //消息类型 1:客服 2:系统通知 3:营销 4:用户会话
  38. Link string `protobuf:"bytes,8,opt,name=link,proto3" json:"link,omitempty"` //跳转链接
  39. CiteId int64 `protobuf:"varint,9,opt,name=citeId,proto3" json:"citeId,omitempty"` //引用id
  40. Appid string `protobuf:"bytes,10,opt,name=appid,proto3" json:"appid,omitempty"` //应用标识
  41. Isdel int64 `protobuf:"varint,11,opt,name=isdel,proto3" json:"isdel,omitempty"` //是否删除
  42. SendTime string `protobuf:"bytes,12,opt,name=sendTime,proto3" json:"sendTime,omitempty"` //发送时间
  43. SendMode string `protobuf:"bytes,13,opt,name=sendMode,proto3" json:"sendMode,omitempty"` //发送模式
  44. ReceiveTime string `protobuf:"bytes,14,opt,name=receiveTime,proto3" json:"receiveTime,omitempty"` //接收时间
  45. SendStatus int64 `protobuf:"varint,15,opt,name=sendStatus,proto3" json:"sendStatus,omitempty"` //发送状态
  46. UpdateTime string `protobuf:"bytes,16,opt,name=updateTime,proto3" json:"updateTime,omitempty"` //修改时间
  47. }
  48. func (x *SendMsgRequest) Reset() {
  49. *x = SendMsgRequest{}
  50. if protoimpl.UnsafeEnabled {
  51. mi := &file_message_proto_msgTypes[0]
  52. ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  53. ms.StoreMessageInfo(mi)
  54. }
  55. }
  56. func (x *SendMsgRequest) String() string {
  57. return protoimpl.X.MessageStringOf(x)
  58. }
  59. func (*SendMsgRequest) ProtoMessage() {}
  60. func (x *SendMsgRequest) ProtoReflect() protoreflect.Message {
  61. mi := &file_message_proto_msgTypes[0]
  62. if protoimpl.UnsafeEnabled && x != nil {
  63. ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  64. if ms.LoadMessageInfo() == nil {
  65. ms.StoreMessageInfo(mi)
  66. }
  67. return ms
  68. }
  69. return mi.MessageOf(x)
  70. }
  71. // Deprecated: Use SendMsgRequest.ProtoReflect.Descriptor instead.
  72. func (*SendMsgRequest) Descriptor() ([]byte, []int) {
  73. return file_message_proto_rawDescGZIP(), []int{0}
  74. }
  75. func (x *SendMsgRequest) GetReceiveUserId() string {
  76. if x != nil {
  77. return x.ReceiveUserId
  78. }
  79. return ""
  80. }
  81. func (x *SendMsgRequest) GetReceiveName() string {
  82. if x != nil {
  83. return x.ReceiveName
  84. }
  85. return ""
  86. }
  87. func (x *SendMsgRequest) GetSendUserId() string {
  88. if x != nil {
  89. return x.SendUserId
  90. }
  91. return ""
  92. }
  93. func (x *SendMsgRequest) GetSendName() string {
  94. if x != nil {
  95. return x.SendName
  96. }
  97. return ""
  98. }
  99. func (x *SendMsgRequest) GetTitle() string {
  100. if x != nil {
  101. return x.Title
  102. }
  103. return ""
  104. }
  105. func (x *SendMsgRequest) GetContent() string {
  106. if x != nil {
  107. return x.Content
  108. }
  109. return ""
  110. }
  111. func (x *SendMsgRequest) GetMsgType() int64 {
  112. if x != nil {
  113. return x.MsgType
  114. }
  115. return 0
  116. }
  117. func (x *SendMsgRequest) GetLink() string {
  118. if x != nil {
  119. return x.Link
  120. }
  121. return ""
  122. }
  123. func (x *SendMsgRequest) GetCiteId() int64 {
  124. if x != nil {
  125. return x.CiteId
  126. }
  127. return 0
  128. }
  129. func (x *SendMsgRequest) GetAppid() string {
  130. if x != nil {
  131. return x.Appid
  132. }
  133. return ""
  134. }
  135. func (x *SendMsgRequest) GetIsdel() int64 {
  136. if x != nil {
  137. return x.Isdel
  138. }
  139. return 0
  140. }
  141. func (x *SendMsgRequest) GetSendTime() string {
  142. if x != nil {
  143. return x.SendTime
  144. }
  145. return ""
  146. }
  147. func (x *SendMsgRequest) GetSendMode() string {
  148. if x != nil {
  149. return x.SendMode
  150. }
  151. return ""
  152. }
  153. func (x *SendMsgRequest) GetReceiveTime() string {
  154. if x != nil {
  155. return x.ReceiveTime
  156. }
  157. return ""
  158. }
  159. func (x *SendMsgRequest) GetSendStatus() int64 {
  160. if x != nil {
  161. return x.SendStatus
  162. }
  163. return 0
  164. }
  165. func (x *SendMsgRequest) GetUpdateTime() string {
  166. if x != nil {
  167. return x.UpdateTime
  168. }
  169. return ""
  170. }
  171. type ChangeReadStatusRequest struct {
  172. state protoimpl.MessageState
  173. sizeCache protoimpl.SizeCache
  174. unknownFields protoimpl.UnknownFields
  175. Id int64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"` // 消息id
  176. ReadStatus int64 `protobuf:"varint,2,opt,name=readStatus,proto3" json:"readStatus,omitempty"` // 阅读状态 0-未读 1-已读
  177. Appid string `protobuf:"bytes,3,opt,name=appid,proto3" json:"appid,omitempty"` //应用标识
  178. }
  179. func (x *ChangeReadStatusRequest) Reset() {
  180. *x = ChangeReadStatusRequest{}
  181. if protoimpl.UnsafeEnabled {
  182. mi := &file_message_proto_msgTypes[1]
  183. ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  184. ms.StoreMessageInfo(mi)
  185. }
  186. }
  187. func (x *ChangeReadStatusRequest) String() string {
  188. return protoimpl.X.MessageStringOf(x)
  189. }
  190. func (*ChangeReadStatusRequest) ProtoMessage() {}
  191. func (x *ChangeReadStatusRequest) ProtoReflect() protoreflect.Message {
  192. mi := &file_message_proto_msgTypes[1]
  193. if protoimpl.UnsafeEnabled && x != nil {
  194. ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  195. if ms.LoadMessageInfo() == nil {
  196. ms.StoreMessageInfo(mi)
  197. }
  198. return ms
  199. }
  200. return mi.MessageOf(x)
  201. }
  202. // Deprecated: Use ChangeReadStatusRequest.ProtoReflect.Descriptor instead.
  203. func (*ChangeReadStatusRequest) Descriptor() ([]byte, []int) {
  204. return file_message_proto_rawDescGZIP(), []int{1}
  205. }
  206. func (x *ChangeReadStatusRequest) GetId() int64 {
  207. if x != nil {
  208. return x.Id
  209. }
  210. return 0
  211. }
  212. func (x *ChangeReadStatusRequest) GetReadStatus() int64 {
  213. if x != nil {
  214. return x.ReadStatus
  215. }
  216. return 0
  217. }
  218. func (x *ChangeReadStatusRequest) GetAppid() string {
  219. if x != nil {
  220. return x.Appid
  221. }
  222. return ""
  223. }
  224. // 删除单一消息
  225. type DeleteSingleMessageRequest struct {
  226. state protoimpl.MessageState
  227. sizeCache protoimpl.SizeCache
  228. unknownFields protoimpl.UnknownFields
  229. Id int64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"` // 消息id
  230. Appid string `protobuf:"bytes,3,opt,name=appid,proto3" json:"appid,omitempty"` //应用标识
  231. }
  232. func (x *DeleteSingleMessageRequest) Reset() {
  233. *x = DeleteSingleMessageRequest{}
  234. if protoimpl.UnsafeEnabled {
  235. mi := &file_message_proto_msgTypes[2]
  236. ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  237. ms.StoreMessageInfo(mi)
  238. }
  239. }
  240. func (x *DeleteSingleMessageRequest) String() string {
  241. return protoimpl.X.MessageStringOf(x)
  242. }
  243. func (*DeleteSingleMessageRequest) ProtoMessage() {}
  244. func (x *DeleteSingleMessageRequest) ProtoReflect() protoreflect.Message {
  245. mi := &file_message_proto_msgTypes[2]
  246. if protoimpl.UnsafeEnabled && x != nil {
  247. ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  248. if ms.LoadMessageInfo() == nil {
  249. ms.StoreMessageInfo(mi)
  250. }
  251. return ms
  252. }
  253. return mi.MessageOf(x)
  254. }
  255. // Deprecated: Use DeleteSingleMessageRequest.ProtoReflect.Descriptor instead.
  256. func (*DeleteSingleMessageRequest) Descriptor() ([]byte, []int) {
  257. return file_message_proto_rawDescGZIP(), []int{2}
  258. }
  259. func (x *DeleteSingleMessageRequest) GetId() int64 {
  260. if x != nil {
  261. return x.Id
  262. }
  263. return 0
  264. }
  265. func (x *DeleteSingleMessageRequest) GetAppid() string {
  266. if x != nil {
  267. return x.Appid
  268. }
  269. return ""
  270. }
  271. // 批量删除消息
  272. type DeleteMultipleMessageRequest struct {
  273. state protoimpl.MessageState
  274. sizeCache protoimpl.SizeCache
  275. unknownFields protoimpl.UnknownFields
  276. Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` // 多条消息id, 逗号分隔
  277. Appid string `protobuf:"bytes,3,opt,name=appid,proto3" json:"appid,omitempty"` //应用标识
  278. }
  279. func (x *DeleteMultipleMessageRequest) Reset() {
  280. *x = DeleteMultipleMessageRequest{}
  281. if protoimpl.UnsafeEnabled {
  282. mi := &file_message_proto_msgTypes[3]
  283. ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  284. ms.StoreMessageInfo(mi)
  285. }
  286. }
  287. func (x *DeleteMultipleMessageRequest) String() string {
  288. return protoimpl.X.MessageStringOf(x)
  289. }
  290. func (*DeleteMultipleMessageRequest) ProtoMessage() {}
  291. func (x *DeleteMultipleMessageRequest) ProtoReflect() protoreflect.Message {
  292. mi := &file_message_proto_msgTypes[3]
  293. if protoimpl.UnsafeEnabled && x != nil {
  294. ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  295. if ms.LoadMessageInfo() == nil {
  296. ms.StoreMessageInfo(mi)
  297. }
  298. return ms
  299. }
  300. return mi.MessageOf(x)
  301. }
  302. // Deprecated: Use DeleteMultipleMessageRequest.ProtoReflect.Descriptor instead.
  303. func (*DeleteMultipleMessageRequest) Descriptor() ([]byte, []int) {
  304. return file_message_proto_rawDescGZIP(), []int{3}
  305. }
  306. func (x *DeleteMultipleMessageRequest) GetId() string {
  307. if x != nil {
  308. return x.Id
  309. }
  310. return ""
  311. }
  312. func (x *DeleteMultipleMessageRequest) GetAppid() string {
  313. if x != nil {
  314. return x.Appid
  315. }
  316. return ""
  317. }
  318. // 查询指定用户未读消息合计
  319. type GetUnreadCountRequest struct {
  320. state protoimpl.MessageState
  321. sizeCache protoimpl.SizeCache
  322. unknownFields protoimpl.UnknownFields
  323. UserId string `protobuf:"bytes,1,opt,name=userId,proto3" json:"userId,omitempty"` // 用户id
  324. Appid string `protobuf:"bytes,2,opt,name=appid,proto3" json:"appid,omitempty"` //应用标识
  325. }
  326. func (x *GetUnreadCountRequest) Reset() {
  327. *x = GetUnreadCountRequest{}
  328. if protoimpl.UnsafeEnabled {
  329. mi := &file_message_proto_msgTypes[4]
  330. ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  331. ms.StoreMessageInfo(mi)
  332. }
  333. }
  334. func (x *GetUnreadCountRequest) String() string {
  335. return protoimpl.X.MessageStringOf(x)
  336. }
  337. func (*GetUnreadCountRequest) ProtoMessage() {}
  338. func (x *GetUnreadCountRequest) ProtoReflect() protoreflect.Message {
  339. mi := &file_message_proto_msgTypes[4]
  340. if protoimpl.UnsafeEnabled && x != nil {
  341. ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  342. if ms.LoadMessageInfo() == nil {
  343. ms.StoreMessageInfo(mi)
  344. }
  345. return ms
  346. }
  347. return mi.MessageOf(x)
  348. }
  349. // Deprecated: Use GetUnreadCountRequest.ProtoReflect.Descriptor instead.
  350. func (*GetUnreadCountRequest) Descriptor() ([]byte, []int) {
  351. return file_message_proto_rawDescGZIP(), []int{4}
  352. }
  353. func (x *GetUnreadCountRequest) GetUserId() string {
  354. if x != nil {
  355. return x.UserId
  356. }
  357. return ""
  358. }
  359. func (x *GetUnreadCountRequest) GetAppid() string {
  360. if x != nil {
  361. return x.Appid
  362. }
  363. return ""
  364. }
  365. type Response struct {
  366. state protoimpl.MessageState
  367. sizeCache protoimpl.SizeCache
  368. unknownFields protoimpl.UnknownFields
  369. Code int64 `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"` //状态码
  370. Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"` //响应消息
  371. }
  372. func (x *Response) Reset() {
  373. *x = Response{}
  374. if protoimpl.UnsafeEnabled {
  375. mi := &file_message_proto_msgTypes[5]
  376. ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  377. ms.StoreMessageInfo(mi)
  378. }
  379. }
  380. func (x *Response) String() string {
  381. return protoimpl.X.MessageStringOf(x)
  382. }
  383. func (*Response) ProtoMessage() {}
  384. func (x *Response) ProtoReflect() protoreflect.Message {
  385. mi := &file_message_proto_msgTypes[5]
  386. if protoimpl.UnsafeEnabled && x != nil {
  387. ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  388. if ms.LoadMessageInfo() == nil {
  389. ms.StoreMessageInfo(mi)
  390. }
  391. return ms
  392. }
  393. return mi.MessageOf(x)
  394. }
  395. // Deprecated: Use Response.ProtoReflect.Descriptor instead.
  396. func (*Response) Descriptor() ([]byte, []int) {
  397. return file_message_proto_rawDescGZIP(), []int{5}
  398. }
  399. func (x *Response) GetCode() int64 {
  400. if x != nil {
  401. return x.Code
  402. }
  403. return 0
  404. }
  405. func (x *Response) GetMessage() string {
  406. if x != nil {
  407. return x.Message
  408. }
  409. return ""
  410. }
  411. type GetUnreadCountResponse struct {
  412. state protoimpl.MessageState
  413. sizeCache protoimpl.SizeCache
  414. unknownFields protoimpl.UnknownFields
  415. Code int64 `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"` //状态码
  416. Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"` //响应消息
  417. Count int64 `protobuf:"varint,3,opt,name=count,proto3" json:"count,omitempty"` //
  418. }
  419. func (x *GetUnreadCountResponse) Reset() {
  420. *x = GetUnreadCountResponse{}
  421. if protoimpl.UnsafeEnabled {
  422. mi := &file_message_proto_msgTypes[6]
  423. ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  424. ms.StoreMessageInfo(mi)
  425. }
  426. }
  427. func (x *GetUnreadCountResponse) String() string {
  428. return protoimpl.X.MessageStringOf(x)
  429. }
  430. func (*GetUnreadCountResponse) ProtoMessage() {}
  431. func (x *GetUnreadCountResponse) ProtoReflect() protoreflect.Message {
  432. mi := &file_message_proto_msgTypes[6]
  433. if protoimpl.UnsafeEnabled && x != nil {
  434. ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  435. if ms.LoadMessageInfo() == nil {
  436. ms.StoreMessageInfo(mi)
  437. }
  438. return ms
  439. }
  440. return mi.MessageOf(x)
  441. }
  442. // Deprecated: Use GetUnreadCountResponse.ProtoReflect.Descriptor instead.
  443. func (*GetUnreadCountResponse) Descriptor() ([]byte, []int) {
  444. return file_message_proto_rawDescGZIP(), []int{6}
  445. }
  446. func (x *GetUnreadCountResponse) GetCode() int64 {
  447. if x != nil {
  448. return x.Code
  449. }
  450. return 0
  451. }
  452. func (x *GetUnreadCountResponse) GetMessage() string {
  453. if x != nil {
  454. return x.Message
  455. }
  456. return ""
  457. }
  458. func (x *GetUnreadCountResponse) GetCount() int64 {
  459. if x != nil {
  460. return x.Count
  461. }
  462. return 0
  463. }
  464. type FindUserMsgReq struct {
  465. state protoimpl.MessageState
  466. sizeCache protoimpl.SizeCache
  467. unknownFields protoimpl.UnknownFields
  468. UserId string `protobuf:"bytes,1,opt,name=userId,proto3" json:"userId,omitempty"` //用户id
  469. ReceiveUserId string `protobuf:"bytes,2,opt,name=receiveUserId,proto3" json:"receiveUserId,omitempty"` //聊天方用户id
  470. Appid string `protobuf:"bytes,3,opt,name=appid,proto3" json:"appid,omitempty"` //应用标识
  471. OffSet int64 `protobuf:"varint,4,opt,name=offSet,proto3" json:"offSet,omitempty"` //当前
  472. PageSize int64 `protobuf:"varint,5,opt,name=pageSize,proto3" json:"pageSize,omitempty"` //大小
  473. MsgType int64 `protobuf:"varint,6,opt,name=msgType,proto3" json:"msgType,omitempty"` //是否区分类型
  474. Read int64 `protobuf:"varint,7,opt,name=read,proto3" json:"read,omitempty"` // 是否区分已读未读 -1 不区分已读未读 0 未读 1 已读
  475. }
  476. func (x *FindUserMsgReq) Reset() {
  477. *x = FindUserMsgReq{}
  478. if protoimpl.UnsafeEnabled {
  479. mi := &file_message_proto_msgTypes[7]
  480. ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  481. ms.StoreMessageInfo(mi)
  482. }
  483. }
  484. func (x *FindUserMsgReq) String() string {
  485. return protoimpl.X.MessageStringOf(x)
  486. }
  487. func (*FindUserMsgReq) ProtoMessage() {}
  488. func (x *FindUserMsgReq) ProtoReflect() protoreflect.Message {
  489. mi := &file_message_proto_msgTypes[7]
  490. if protoimpl.UnsafeEnabled && x != nil {
  491. ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  492. if ms.LoadMessageInfo() == nil {
  493. ms.StoreMessageInfo(mi)
  494. }
  495. return ms
  496. }
  497. return mi.MessageOf(x)
  498. }
  499. // Deprecated: Use FindUserMsgReq.ProtoReflect.Descriptor instead.
  500. func (*FindUserMsgReq) Descriptor() ([]byte, []int) {
  501. return file_message_proto_rawDescGZIP(), []int{7}
  502. }
  503. func (x *FindUserMsgReq) GetUserId() string {
  504. if x != nil {
  505. return x.UserId
  506. }
  507. return ""
  508. }
  509. func (x *FindUserMsgReq) GetReceiveUserId() string {
  510. if x != nil {
  511. return x.ReceiveUserId
  512. }
  513. return ""
  514. }
  515. func (x *FindUserMsgReq) GetAppid() string {
  516. if x != nil {
  517. return x.Appid
  518. }
  519. return ""
  520. }
  521. func (x *FindUserMsgReq) GetOffSet() int64 {
  522. if x != nil {
  523. return x.OffSet
  524. }
  525. return 0
  526. }
  527. func (x *FindUserMsgReq) GetPageSize() int64 {
  528. if x != nil {
  529. return x.PageSize
  530. }
  531. return 0
  532. }
  533. func (x *FindUserMsgReq) GetMsgType() int64 {
  534. if x != nil {
  535. return x.MsgType
  536. }
  537. return 0
  538. }
  539. func (x *FindUserMsgReq) GetRead() int64 {
  540. if x != nil {
  541. return x.Read
  542. }
  543. return 0
  544. }
  545. type Messages struct {
  546. state protoimpl.MessageState
  547. sizeCache protoimpl.SizeCache
  548. unknownFields protoimpl.UnknownFields
  549. ReceiveUserId string `protobuf:"bytes,1,opt,name=receiveUserId,proto3" json:"receiveUserId,omitempty"` //接收方用户ID
  550. ReceiveName string `protobuf:"bytes,2,opt,name=receiveName,proto3" json:"receiveName,omitempty"` //接收方用户名
  551. SendUserId string `protobuf:"bytes,3,opt,name=sendUserId,proto3" json:"sendUserId,omitempty"` //发送方用户ID
  552. SendName string `protobuf:"bytes,4,opt,name=sendName,proto3" json:"sendName,omitempty"` //发送方用户名
  553. Title string `protobuf:"bytes,5,opt,name=title,proto3" json:"title,omitempty"` //主题
  554. Content string `protobuf:"bytes,6,opt,name=content,proto3" json:"content,omitempty"` //内容
  555. MsgType int64 `protobuf:"varint,7,opt,name=msgType,proto3" json:"msgType,omitempty"` //消息类型 1:客服 2:系统通知 3:营销 4:用户会话
  556. Link string `protobuf:"bytes,8,opt,name=link,proto3" json:"link,omitempty"` //跳转链接
  557. CiteId int64 `protobuf:"varint,9,opt,name=citeId,proto3" json:"citeId,omitempty"` //引用id
  558. IsRead int64 `protobuf:"varint,10,opt,name=isRead,proto3" json:"isRead,omitempty"` //已读未读 0:未读 1:已读
  559. Createtime string `protobuf:"bytes,11,opt,name=createtime,proto3" json:"createtime,omitempty"`
  560. Appid string `protobuf:"bytes,12,opt,name=appid,proto3" json:"appid,omitempty"` //应用标识
  561. }
  562. func (x *Messages) Reset() {
  563. *x = Messages{}
  564. if protoimpl.UnsafeEnabled {
  565. mi := &file_message_proto_msgTypes[8]
  566. ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  567. ms.StoreMessageInfo(mi)
  568. }
  569. }
  570. func (x *Messages) String() string {
  571. return protoimpl.X.MessageStringOf(x)
  572. }
  573. func (*Messages) ProtoMessage() {}
  574. func (x *Messages) ProtoReflect() protoreflect.Message {
  575. mi := &file_message_proto_msgTypes[8]
  576. if protoimpl.UnsafeEnabled && x != nil {
  577. ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  578. if ms.LoadMessageInfo() == nil {
  579. ms.StoreMessageInfo(mi)
  580. }
  581. return ms
  582. }
  583. return mi.MessageOf(x)
  584. }
  585. // Deprecated: Use Messages.ProtoReflect.Descriptor instead.
  586. func (*Messages) Descriptor() ([]byte, []int) {
  587. return file_message_proto_rawDescGZIP(), []int{8}
  588. }
  589. func (x *Messages) GetReceiveUserId() string {
  590. if x != nil {
  591. return x.ReceiveUserId
  592. }
  593. return ""
  594. }
  595. func (x *Messages) GetReceiveName() string {
  596. if x != nil {
  597. return x.ReceiveName
  598. }
  599. return ""
  600. }
  601. func (x *Messages) GetSendUserId() string {
  602. if x != nil {
  603. return x.SendUserId
  604. }
  605. return ""
  606. }
  607. func (x *Messages) GetSendName() string {
  608. if x != nil {
  609. return x.SendName
  610. }
  611. return ""
  612. }
  613. func (x *Messages) GetTitle() string {
  614. if x != nil {
  615. return x.Title
  616. }
  617. return ""
  618. }
  619. func (x *Messages) GetContent() string {
  620. if x != nil {
  621. return x.Content
  622. }
  623. return ""
  624. }
  625. func (x *Messages) GetMsgType() int64 {
  626. if x != nil {
  627. return x.MsgType
  628. }
  629. return 0
  630. }
  631. func (x *Messages) GetLink() string {
  632. if x != nil {
  633. return x.Link
  634. }
  635. return ""
  636. }
  637. func (x *Messages) GetCiteId() int64 {
  638. if x != nil {
  639. return x.CiteId
  640. }
  641. return 0
  642. }
  643. func (x *Messages) GetIsRead() int64 {
  644. if x != nil {
  645. return x.IsRead
  646. }
  647. return 0
  648. }
  649. func (x *Messages) GetCreatetime() string {
  650. if x != nil {
  651. return x.Createtime
  652. }
  653. return ""
  654. }
  655. func (x *Messages) GetAppid() string {
  656. if x != nil {
  657. return x.Appid
  658. }
  659. return ""
  660. }
  661. type FindUserMsgRes struct {
  662. state protoimpl.MessageState
  663. sizeCache protoimpl.SizeCache
  664. unknownFields protoimpl.UnknownFields
  665. Code int64 `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"` //状态码
  666. Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"` //响应消息
  667. Data []*Messages `protobuf:"bytes,3,rep,name=data,proto3" json:"data,omitempty"` //
  668. Count int64 `protobuf:"varint,4,opt,name=count,proto3" json:"count,omitempty"` //总数
  669. }
  670. func (x *FindUserMsgRes) Reset() {
  671. *x = FindUserMsgRes{}
  672. if protoimpl.UnsafeEnabled {
  673. mi := &file_message_proto_msgTypes[9]
  674. ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  675. ms.StoreMessageInfo(mi)
  676. }
  677. }
  678. func (x *FindUserMsgRes) String() string {
  679. return protoimpl.X.MessageStringOf(x)
  680. }
  681. func (*FindUserMsgRes) ProtoMessage() {}
  682. func (x *FindUserMsgRes) ProtoReflect() protoreflect.Message {
  683. mi := &file_message_proto_msgTypes[9]
  684. if protoimpl.UnsafeEnabled && x != nil {
  685. ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  686. if ms.LoadMessageInfo() == nil {
  687. ms.StoreMessageInfo(mi)
  688. }
  689. return ms
  690. }
  691. return mi.MessageOf(x)
  692. }
  693. // Deprecated: Use FindUserMsgRes.ProtoReflect.Descriptor instead.
  694. func (*FindUserMsgRes) Descriptor() ([]byte, []int) {
  695. return file_message_proto_rawDescGZIP(), []int{9}
  696. }
  697. func (x *FindUserMsgRes) GetCode() int64 {
  698. if x != nil {
  699. return x.Code
  700. }
  701. return 0
  702. }
  703. func (x *FindUserMsgRes) GetMessage() string {
  704. if x != nil {
  705. return x.Message
  706. }
  707. return ""
  708. }
  709. func (x *FindUserMsgRes) GetData() []*Messages {
  710. if x != nil {
  711. return x.Data
  712. }
  713. return nil
  714. }
  715. func (x *FindUserMsgRes) GetCount() int64 {
  716. if x != nil {
  717. return x.Count
  718. }
  719. return 0
  720. }
  721. type GetClassUnreadCountReq struct {
  722. state protoimpl.MessageState
  723. sizeCache protoimpl.SizeCache
  724. unknownFields protoimpl.UnknownFields
  725. UserId string `protobuf:"bytes,1,opt,name=userId,proto3" json:"userId,omitempty"` // 用户id
  726. MsgType int64 `protobuf:"varint,2,opt,name=msgType,proto3" json:"msgType,omitempty"` //分类 1:客服 2:系统通知 3:营销 4:用户会话
  727. Appid string `protobuf:"bytes,3,opt,name=appid,proto3" json:"appid,omitempty"` //应用标识
  728. }
  729. func (x *GetClassUnreadCountReq) Reset() {
  730. *x = GetClassUnreadCountReq{}
  731. if protoimpl.UnsafeEnabled {
  732. mi := &file_message_proto_msgTypes[10]
  733. ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  734. ms.StoreMessageInfo(mi)
  735. }
  736. }
  737. func (x *GetClassUnreadCountReq) String() string {
  738. return protoimpl.X.MessageStringOf(x)
  739. }
  740. func (*GetClassUnreadCountReq) ProtoMessage() {}
  741. func (x *GetClassUnreadCountReq) ProtoReflect() protoreflect.Message {
  742. mi := &file_message_proto_msgTypes[10]
  743. if protoimpl.UnsafeEnabled && x != nil {
  744. ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  745. if ms.LoadMessageInfo() == nil {
  746. ms.StoreMessageInfo(mi)
  747. }
  748. return ms
  749. }
  750. return mi.MessageOf(x)
  751. }
  752. // Deprecated: Use GetClassUnreadCountReq.ProtoReflect.Descriptor instead.
  753. func (*GetClassUnreadCountReq) Descriptor() ([]byte, []int) {
  754. return file_message_proto_rawDescGZIP(), []int{10}
  755. }
  756. func (x *GetClassUnreadCountReq) GetUserId() string {
  757. if x != nil {
  758. return x.UserId
  759. }
  760. return ""
  761. }
  762. func (x *GetClassUnreadCountReq) GetMsgType() int64 {
  763. if x != nil {
  764. return x.MsgType
  765. }
  766. return 0
  767. }
  768. func (x *GetClassUnreadCountReq) GetAppid() string {
  769. if x != nil {
  770. return x.Appid
  771. }
  772. return ""
  773. }
  774. //查看消息内容
  775. type MessageDetailReq struct {
  776. state protoimpl.MessageState
  777. sizeCache protoimpl.SizeCache
  778. unknownFields protoimpl.UnknownFields
  779. Id int64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"` //消息id
  780. }
  781. func (x *MessageDetailReq) Reset() {
  782. *x = MessageDetailReq{}
  783. if protoimpl.UnsafeEnabled {
  784. mi := &file_message_proto_msgTypes[11]
  785. ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  786. ms.StoreMessageInfo(mi)
  787. }
  788. }
  789. func (x *MessageDetailReq) String() string {
  790. return protoimpl.X.MessageStringOf(x)
  791. }
  792. func (*MessageDetailReq) ProtoMessage() {}
  793. func (x *MessageDetailReq) ProtoReflect() protoreflect.Message {
  794. mi := &file_message_proto_msgTypes[11]
  795. if protoimpl.UnsafeEnabled && x != nil {
  796. ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  797. if ms.LoadMessageInfo() == nil {
  798. ms.StoreMessageInfo(mi)
  799. }
  800. return ms
  801. }
  802. return mi.MessageOf(x)
  803. }
  804. // Deprecated: Use MessageDetailReq.ProtoReflect.Descriptor instead.
  805. func (*MessageDetailReq) Descriptor() ([]byte, []int) {
  806. return file_message_proto_rawDescGZIP(), []int{11}
  807. }
  808. func (x *MessageDetailReq) GetId() int64 {
  809. if x != nil {
  810. return x.Id
  811. }
  812. return 0
  813. }
  814. type MessageDetailResp struct {
  815. state protoimpl.MessageState
  816. sizeCache protoimpl.SizeCache
  817. unknownFields protoimpl.UnknownFields
  818. Code int64 `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"` //状态码
  819. Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"` //响应消息
  820. Data *Messages `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"` //
  821. }
  822. func (x *MessageDetailResp) Reset() {
  823. *x = MessageDetailResp{}
  824. if protoimpl.UnsafeEnabled {
  825. mi := &file_message_proto_msgTypes[12]
  826. ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  827. ms.StoreMessageInfo(mi)
  828. }
  829. }
  830. func (x *MessageDetailResp) String() string {
  831. return protoimpl.X.MessageStringOf(x)
  832. }
  833. func (*MessageDetailResp) ProtoMessage() {}
  834. func (x *MessageDetailResp) ProtoReflect() protoreflect.Message {
  835. mi := &file_message_proto_msgTypes[12]
  836. if protoimpl.UnsafeEnabled && x != nil {
  837. ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  838. if ms.LoadMessageInfo() == nil {
  839. ms.StoreMessageInfo(mi)
  840. }
  841. return ms
  842. }
  843. return mi.MessageOf(x)
  844. }
  845. // Deprecated: Use MessageDetailResp.ProtoReflect.Descriptor instead.
  846. func (*MessageDetailResp) Descriptor() ([]byte, []int) {
  847. return file_message_proto_rawDescGZIP(), []int{12}
  848. }
  849. func (x *MessageDetailResp) GetCode() int64 {
  850. if x != nil {
  851. return x.Code
  852. }
  853. return 0
  854. }
  855. func (x *MessageDetailResp) GetMessage() string {
  856. if x != nil {
  857. return x.Message
  858. }
  859. return ""
  860. }
  861. func (x *MessageDetailResp) GetData() *Messages {
  862. if x != nil {
  863. return x.Data
  864. }
  865. return nil
  866. }
  867. type GetLastMessageReq struct {
  868. state protoimpl.MessageState
  869. sizeCache protoimpl.SizeCache
  870. unknownFields protoimpl.UnknownFields
  871. UserId string `protobuf:"bytes,1,opt,name=userId,proto3" json:"userId,omitempty"` // 用户id
  872. MsgType int64 `protobuf:"varint,2,opt,name=msgType,proto3" json:"msgType,omitempty"` //分类 1:客服 2:系统通知 3:营销 4:用户会话
  873. Appid string `protobuf:"bytes,3,opt,name=appid,proto3" json:"appid,omitempty"` //应用标识
  874. }
  875. func (x *GetLastMessageReq) Reset() {
  876. *x = GetLastMessageReq{}
  877. if protoimpl.UnsafeEnabled {
  878. mi := &file_message_proto_msgTypes[13]
  879. ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  880. ms.StoreMessageInfo(mi)
  881. }
  882. }
  883. func (x *GetLastMessageReq) String() string {
  884. return protoimpl.X.MessageStringOf(x)
  885. }
  886. func (*GetLastMessageReq) ProtoMessage() {}
  887. func (x *GetLastMessageReq) ProtoReflect() protoreflect.Message {
  888. mi := &file_message_proto_msgTypes[13]
  889. if protoimpl.UnsafeEnabled && x != nil {
  890. ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  891. if ms.LoadMessageInfo() == nil {
  892. ms.StoreMessageInfo(mi)
  893. }
  894. return ms
  895. }
  896. return mi.MessageOf(x)
  897. }
  898. // Deprecated: Use GetLastMessageReq.ProtoReflect.Descriptor instead.
  899. func (*GetLastMessageReq) Descriptor() ([]byte, []int) {
  900. return file_message_proto_rawDescGZIP(), []int{13}
  901. }
  902. func (x *GetLastMessageReq) GetUserId() string {
  903. if x != nil {
  904. return x.UserId
  905. }
  906. return ""
  907. }
  908. func (x *GetLastMessageReq) GetMsgType() int64 {
  909. if x != nil {
  910. return x.MsgType
  911. }
  912. return 0
  913. }
  914. func (x *GetLastMessageReq) GetAppid() string {
  915. if x != nil {
  916. return x.Appid
  917. }
  918. return ""
  919. }
  920. type GetLastMessageRes struct {
  921. state protoimpl.MessageState
  922. sizeCache protoimpl.SizeCache
  923. unknownFields protoimpl.UnknownFields
  924. Code int64 `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"` //状态码
  925. Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"` //响应消息
  926. Data *Messages `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"` //
  927. }
  928. func (x *GetLastMessageRes) Reset() {
  929. *x = GetLastMessageRes{}
  930. if protoimpl.UnsafeEnabled {
  931. mi := &file_message_proto_msgTypes[14]
  932. ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  933. ms.StoreMessageInfo(mi)
  934. }
  935. }
  936. func (x *GetLastMessageRes) String() string {
  937. return protoimpl.X.MessageStringOf(x)
  938. }
  939. func (*GetLastMessageRes) ProtoMessage() {}
  940. func (x *GetLastMessageRes) ProtoReflect() protoreflect.Message {
  941. mi := &file_message_proto_msgTypes[14]
  942. if protoimpl.UnsafeEnabled && x != nil {
  943. ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  944. if ms.LoadMessageInfo() == nil {
  945. ms.StoreMessageInfo(mi)
  946. }
  947. return ms
  948. }
  949. return mi.MessageOf(x)
  950. }
  951. // Deprecated: Use GetLastMessageRes.ProtoReflect.Descriptor instead.
  952. func (*GetLastMessageRes) Descriptor() ([]byte, []int) {
  953. return file_message_proto_rawDescGZIP(), []int{14}
  954. }
  955. func (x *GetLastMessageRes) GetCode() int64 {
  956. if x != nil {
  957. return x.Code
  958. }
  959. return 0
  960. }
  961. func (x *GetLastMessageRes) GetMessage() string {
  962. if x != nil {
  963. return x.Message
  964. }
  965. return ""
  966. }
  967. func (x *GetLastMessageRes) GetData() *Messages {
  968. if x != nil {
  969. return x.Data
  970. }
  971. return nil
  972. }
  973. var File_message_proto protoreflect.FileDescriptor
  974. var file_message_proto_rawDesc = []byte{
  975. 0x0a, 0x0d, 0x6d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x12,
  976. 0x07, 0x6d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 0x22, 0xd0, 0x03, 0x0a, 0x0e, 0x53, 0x65, 0x6e,
  977. 0x64, 0x4d, 0x73, 0x67, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x24, 0x0a, 0x0d, 0x72,
  978. 0x65, 0x63, 0x65, 0x69, 0x76, 0x65, 0x55, 0x73, 0x65, 0x72, 0x49, 0x64, 0x18, 0x01, 0x20, 0x01,
  979. 0x28, 0x09, 0x52, 0x0d, 0x72, 0x65, 0x63, 0x65, 0x69, 0x76, 0x65, 0x55, 0x73, 0x65, 0x72, 0x49,
  980. 0x64, 0x12, 0x20, 0x0a, 0x0b, 0x72, 0x65, 0x63, 0x65, 0x69, 0x76, 0x65, 0x4e, 0x61, 0x6d, 0x65,
  981. 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0b, 0x72, 0x65, 0x63, 0x65, 0x69, 0x76, 0x65, 0x4e,
  982. 0x61, 0x6d, 0x65, 0x12, 0x1e, 0x0a, 0x0a, 0x73, 0x65, 0x6e, 0x64, 0x55, 0x73, 0x65, 0x72, 0x49,
  983. 0x64, 0x18, 0x03, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0a, 0x73, 0x65, 0x6e, 0x64, 0x55, 0x73, 0x65,
  984. 0x72, 0x49, 0x64, 0x12, 0x1a, 0x0a, 0x08, 0x73, 0x65, 0x6e, 0x64, 0x4e, 0x61, 0x6d, 0x65, 0x18,
  985. 0x04, 0x20, 0x01, 0x28, 0x09, 0x52, 0x08, 0x73, 0x65, 0x6e, 0x64, 0x4e, 0x61, 0x6d, 0x65, 0x12,
  986. 0x14, 0x0a, 0x05, 0x74, 0x69, 0x74, 0x6c, 0x65, 0x18, 0x05, 0x20, 0x01, 0x28, 0x09, 0x52, 0x05,
  987. 0x74, 0x69, 0x74, 0x6c, 0x65, 0x12, 0x18, 0x0a, 0x07, 0x63, 0x6f, 0x6e, 0x74, 0x65, 0x6e, 0x74,
  988. 0x18, 0x06, 0x20, 0x01, 0x28, 0x09, 0x52, 0x07, 0x63, 0x6f, 0x6e, 0x74, 0x65, 0x6e, 0x74, 0x12,
  989. 0x18, 0x0a, 0x07, 0x6d, 0x73, 0x67, 0x54, 0x79, 0x70, 0x65, 0x18, 0x07, 0x20, 0x01, 0x28, 0x03,
  990. 0x52, 0x07, 0x6d, 0x73, 0x67, 0x54, 0x79, 0x70, 0x65, 0x12, 0x12, 0x0a, 0x04, 0x6c, 0x69, 0x6e,
  991. 0x6b, 0x18, 0x08, 0x20, 0x01, 0x28, 0x09, 0x52, 0x04, 0x6c, 0x69, 0x6e, 0x6b, 0x12, 0x16, 0x0a,
  992. 0x06, 0x63, 0x69, 0x74, 0x65, 0x49, 0x64, 0x18, 0x09, 0x20, 0x01, 0x28, 0x03, 0x52, 0x06, 0x63,
  993. 0x69, 0x74, 0x65, 0x49, 0x64, 0x12, 0x14, 0x0a, 0x05, 0x61, 0x70, 0x70, 0x69, 0x64, 0x18, 0x0a,
  994. 0x20, 0x01, 0x28, 0x09, 0x52, 0x05, 0x61, 0x70, 0x70, 0x69, 0x64, 0x12, 0x14, 0x0a, 0x05, 0x69,
  995. 0x73, 0x64, 0x65, 0x6c, 0x18, 0x0b, 0x20, 0x01, 0x28, 0x03, 0x52, 0x05, 0x69, 0x73, 0x64, 0x65,
  996. 0x6c, 0x12, 0x1a, 0x0a, 0x08, 0x73, 0x65, 0x6e, 0x64, 0x54, 0x69, 0x6d, 0x65, 0x18, 0x0c, 0x20,
  997. 0x01, 0x28, 0x09, 0x52, 0x08, 0x73, 0x65, 0x6e, 0x64, 0x54, 0x69, 0x6d, 0x65, 0x12, 0x1a, 0x0a,
  998. 0x08, 0x73, 0x65, 0x6e, 0x64, 0x4d, 0x6f, 0x64, 0x65, 0x18, 0x0d, 0x20, 0x01, 0x28, 0x09, 0x52,
  999. 0x08, 0x73, 0x65, 0x6e, 0x64, 0x4d, 0x6f, 0x64, 0x65, 0x12, 0x20, 0x0a, 0x0b, 0x72, 0x65, 0x63,
  1000. 0x65, 0x69, 0x76, 0x65, 0x54, 0x69, 0x6d, 0x65, 0x18, 0x0e, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0b,
  1001. 0x72, 0x65, 0x63, 0x65, 0x69, 0x76, 0x65, 0x54, 0x69, 0x6d, 0x65, 0x12, 0x1e, 0x0a, 0x0a, 0x73,
  1002. 0x65, 0x6e, 0x64, 0x53, 0x74, 0x61, 0x74, 0x75, 0x73, 0x18, 0x0f, 0x20, 0x01, 0x28, 0x03, 0x52,
  1003. 0x0a, 0x73, 0x65, 0x6e, 0x64, 0x53, 0x74, 0x61, 0x74, 0x75, 0x73, 0x12, 0x1e, 0x0a, 0x0a, 0x75,
  1004. 0x70, 0x64, 0x61, 0x74, 0x65, 0x54, 0x69, 0x6d, 0x65, 0x18, 0x10, 0x20, 0x01, 0x28, 0x09, 0x52,
  1005. 0x0a, 0x75, 0x70, 0x64, 0x61, 0x74, 0x65, 0x54, 0x69, 0x6d, 0x65, 0x22, 0x5f, 0x0a, 0x17, 0x43,
  1006. 0x68, 0x61, 0x6e, 0x67, 0x65, 0x52, 0x65, 0x61, 0x64, 0x53, 0x74, 0x61, 0x74, 0x75, 0x73, 0x52,
  1007. 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x0e, 0x0a, 0x02, 0x69, 0x64, 0x18, 0x01, 0x20, 0x01,
  1008. 0x28, 0x03, 0x52, 0x02, 0x69, 0x64, 0x12, 0x1e, 0x0a, 0x0a, 0x72, 0x65, 0x61, 0x64, 0x53, 0x74,
  1009. 0x61, 0x74, 0x75, 0x73, 0x18, 0x02, 0x20, 0x01, 0x28, 0x03, 0x52, 0x0a, 0x72, 0x65, 0x61, 0x64,
  1010. 0x53, 0x74, 0x61, 0x74, 0x75, 0x73, 0x12, 0x14, 0x0a, 0x05, 0x61, 0x70, 0x70, 0x69, 0x64, 0x18,
  1011. 0x03, 0x20, 0x01, 0x28, 0x09, 0x52, 0x05, 0x61, 0x70, 0x70, 0x69, 0x64, 0x22, 0x42, 0x0a, 0x1a,
  1012. 0x44, 0x65, 0x6c, 0x65, 0x74, 0x65, 0x53, 0x69, 0x6e, 0x67, 0x6c, 0x65, 0x4d, 0x65, 0x73, 0x73,
  1013. 0x61, 0x67, 0x65, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x0e, 0x0a, 0x02, 0x69, 0x64,
  1014. 0x18, 0x01, 0x20, 0x01, 0x28, 0x03, 0x52, 0x02, 0x69, 0x64, 0x12, 0x14, 0x0a, 0x05, 0x61, 0x70,
  1015. 0x70, 0x69, 0x64, 0x18, 0x03, 0x20, 0x01, 0x28, 0x09, 0x52, 0x05, 0x61, 0x70, 0x70, 0x69, 0x64,
  1016. 0x22, 0x44, 0x0a, 0x1c, 0x44, 0x65, 0x6c, 0x65, 0x74, 0x65, 0x4d, 0x75, 0x6c, 0x74, 0x69, 0x70,
  1017. 0x6c, 0x65, 0x4d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74,
  1018. 0x12, 0x0e, 0x0a, 0x02, 0x69, 0x64, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x02, 0x69, 0x64,
  1019. 0x12, 0x14, 0x0a, 0x05, 0x61, 0x70, 0x70, 0x69, 0x64, 0x18, 0x03, 0x20, 0x01, 0x28, 0x09, 0x52,
  1020. 0x05, 0x61, 0x70, 0x70, 0x69, 0x64, 0x22, 0x45, 0x0a, 0x15, 0x47, 0x65, 0x74, 0x55, 0x6e, 0x72,
  1021. 0x65, 0x61, 0x64, 0x43, 0x6f, 0x75, 0x6e, 0x74, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12,
  1022. 0x16, 0x0a, 0x06, 0x75, 0x73, 0x65, 0x72, 0x49, 0x64, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52,
  1023. 0x06, 0x75, 0x73, 0x65, 0x72, 0x49, 0x64, 0x12, 0x14, 0x0a, 0x05, 0x61, 0x70, 0x70, 0x69, 0x64,
  1024. 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x05, 0x61, 0x70, 0x70, 0x69, 0x64, 0x22, 0x38, 0x0a,
  1025. 0x08, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x12, 0x0a, 0x04, 0x63, 0x6f, 0x64,
  1026. 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x03, 0x52, 0x04, 0x63, 0x6f, 0x64, 0x65, 0x12, 0x18, 0x0a,
  1027. 0x07, 0x6d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x07,
  1028. 0x6d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 0x22, 0x5c, 0x0a, 0x16, 0x47, 0x65, 0x74, 0x55, 0x6e,
  1029. 0x72, 0x65, 0x61, 0x64, 0x43, 0x6f, 0x75, 0x6e, 0x74, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73,
  1030. 0x65, 0x12, 0x12, 0x0a, 0x04, 0x63, 0x6f, 0x64, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x03, 0x52,
  1031. 0x04, 0x63, 0x6f, 0x64, 0x65, 0x12, 0x18, 0x0a, 0x07, 0x6d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65,
  1032. 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x07, 0x6d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 0x12,
  1033. 0x14, 0x0a, 0x05, 0x63, 0x6f, 0x75, 0x6e, 0x74, 0x18, 0x03, 0x20, 0x01, 0x28, 0x03, 0x52, 0x05,
  1034. 0x63, 0x6f, 0x75, 0x6e, 0x74, 0x22, 0xc6, 0x01, 0x0a, 0x0e, 0x46, 0x69, 0x6e, 0x64, 0x55, 0x73,
  1035. 0x65, 0x72, 0x4d, 0x73, 0x67, 0x52, 0x65, 0x71, 0x12, 0x16, 0x0a, 0x06, 0x75, 0x73, 0x65, 0x72,
  1036. 0x49, 0x64, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x06, 0x75, 0x73, 0x65, 0x72, 0x49, 0x64,
  1037. 0x12, 0x24, 0x0a, 0x0d, 0x72, 0x65, 0x63, 0x65, 0x69, 0x76, 0x65, 0x55, 0x73, 0x65, 0x72, 0x49,
  1038. 0x64, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0d, 0x72, 0x65, 0x63, 0x65, 0x69, 0x76, 0x65,
  1039. 0x55, 0x73, 0x65, 0x72, 0x49, 0x64, 0x12, 0x14, 0x0a, 0x05, 0x61, 0x70, 0x70, 0x69, 0x64, 0x18,
  1040. 0x03, 0x20, 0x01, 0x28, 0x09, 0x52, 0x05, 0x61, 0x70, 0x70, 0x69, 0x64, 0x12, 0x16, 0x0a, 0x06,
  1041. 0x6f, 0x66, 0x66, 0x53, 0x65, 0x74, 0x18, 0x04, 0x20, 0x01, 0x28, 0x03, 0x52, 0x06, 0x6f, 0x66,
  1042. 0x66, 0x53, 0x65, 0x74, 0x12, 0x1a, 0x0a, 0x08, 0x70, 0x61, 0x67, 0x65, 0x53, 0x69, 0x7a, 0x65,
  1043. 0x18, 0x05, 0x20, 0x01, 0x28, 0x03, 0x52, 0x08, 0x70, 0x61, 0x67, 0x65, 0x53, 0x69, 0x7a, 0x65,
  1044. 0x12, 0x18, 0x0a, 0x07, 0x6d, 0x73, 0x67, 0x54, 0x79, 0x70, 0x65, 0x18, 0x06, 0x20, 0x01, 0x28,
  1045. 0x03, 0x52, 0x07, 0x6d, 0x73, 0x67, 0x54, 0x79, 0x70, 0x65, 0x12, 0x12, 0x0a, 0x04, 0x72, 0x65,
  1046. 0x61, 0x64, 0x18, 0x07, 0x20, 0x01, 0x28, 0x03, 0x52, 0x04, 0x72, 0x65, 0x61, 0x64, 0x22, 0xd2,
  1047. 0x02, 0x0a, 0x08, 0x4d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 0x73, 0x12, 0x24, 0x0a, 0x0d, 0x72,
  1048. 0x65, 0x63, 0x65, 0x69, 0x76, 0x65, 0x55, 0x73, 0x65, 0x72, 0x49, 0x64, 0x18, 0x01, 0x20, 0x01,
  1049. 0x28, 0x09, 0x52, 0x0d, 0x72, 0x65, 0x63, 0x65, 0x69, 0x76, 0x65, 0x55, 0x73, 0x65, 0x72, 0x49,
  1050. 0x64, 0x12, 0x20, 0x0a, 0x0b, 0x72, 0x65, 0x63, 0x65, 0x69, 0x76, 0x65, 0x4e, 0x61, 0x6d, 0x65,
  1051. 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0b, 0x72, 0x65, 0x63, 0x65, 0x69, 0x76, 0x65, 0x4e,
  1052. 0x61, 0x6d, 0x65, 0x12, 0x1e, 0x0a, 0x0a, 0x73, 0x65, 0x6e, 0x64, 0x55, 0x73, 0x65, 0x72, 0x49,
  1053. 0x64, 0x18, 0x03, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0a, 0x73, 0x65, 0x6e, 0x64, 0x55, 0x73, 0x65,
  1054. 0x72, 0x49, 0x64, 0x12, 0x1a, 0x0a, 0x08, 0x73, 0x65, 0x6e, 0x64, 0x4e, 0x61, 0x6d, 0x65, 0x18,
  1055. 0x04, 0x20, 0x01, 0x28, 0x09, 0x52, 0x08, 0x73, 0x65, 0x6e, 0x64, 0x4e, 0x61, 0x6d, 0x65, 0x12,
  1056. 0x14, 0x0a, 0x05, 0x74, 0x69, 0x74, 0x6c, 0x65, 0x18, 0x05, 0x20, 0x01, 0x28, 0x09, 0x52, 0x05,
  1057. 0x74, 0x69, 0x74, 0x6c, 0x65, 0x12, 0x18, 0x0a, 0x07, 0x63, 0x6f, 0x6e, 0x74, 0x65, 0x6e, 0x74,
  1058. 0x18, 0x06, 0x20, 0x01, 0x28, 0x09, 0x52, 0x07, 0x63, 0x6f, 0x6e, 0x74, 0x65, 0x6e, 0x74, 0x12,
  1059. 0x18, 0x0a, 0x07, 0x6d, 0x73, 0x67, 0x54, 0x79, 0x70, 0x65, 0x18, 0x07, 0x20, 0x01, 0x28, 0x03,
  1060. 0x52, 0x07, 0x6d, 0x73, 0x67, 0x54, 0x79, 0x70, 0x65, 0x12, 0x12, 0x0a, 0x04, 0x6c, 0x69, 0x6e,
  1061. 0x6b, 0x18, 0x08, 0x20, 0x01, 0x28, 0x09, 0x52, 0x04, 0x6c, 0x69, 0x6e, 0x6b, 0x12, 0x16, 0x0a,
  1062. 0x06, 0x63, 0x69, 0x74, 0x65, 0x49, 0x64, 0x18, 0x09, 0x20, 0x01, 0x28, 0x03, 0x52, 0x06, 0x63,
  1063. 0x69, 0x74, 0x65, 0x49, 0x64, 0x12, 0x16, 0x0a, 0x06, 0x69, 0x73, 0x52, 0x65, 0x61, 0x64, 0x18,
  1064. 0x0a, 0x20, 0x01, 0x28, 0x03, 0x52, 0x06, 0x69, 0x73, 0x52, 0x65, 0x61, 0x64, 0x12, 0x1e, 0x0a,
  1065. 0x0a, 0x63, 0x72, 0x65, 0x61, 0x74, 0x65, 0x74, 0x69, 0x6d, 0x65, 0x18, 0x0b, 0x20, 0x01, 0x28,
  1066. 0x09, 0x52, 0x0a, 0x63, 0x72, 0x65, 0x61, 0x74, 0x65, 0x74, 0x69, 0x6d, 0x65, 0x12, 0x14, 0x0a,
  1067. 0x05, 0x61, 0x70, 0x70, 0x69, 0x64, 0x18, 0x0c, 0x20, 0x01, 0x28, 0x09, 0x52, 0x05, 0x61, 0x70,
  1068. 0x70, 0x69, 0x64, 0x22, 0x7b, 0x0a, 0x0e, 0x46, 0x69, 0x6e, 0x64, 0x55, 0x73, 0x65, 0x72, 0x4d,
  1069. 0x73, 0x67, 0x52, 0x65, 0x73, 0x12, 0x12, 0x0a, 0x04, 0x63, 0x6f, 0x64, 0x65, 0x18, 0x01, 0x20,
  1070. 0x01, 0x28, 0x03, 0x52, 0x04, 0x63, 0x6f, 0x64, 0x65, 0x12, 0x18, 0x0a, 0x07, 0x6d, 0x65, 0x73,
  1071. 0x73, 0x61, 0x67, 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x07, 0x6d, 0x65, 0x73, 0x73,
  1072. 0x61, 0x67, 0x65, 0x12, 0x25, 0x0a, 0x04, 0x64, 0x61, 0x74, 0x61, 0x18, 0x03, 0x20, 0x03, 0x28,
  1073. 0x0b, 0x32, 0x11, 0x2e, 0x6d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 0x2e, 0x4d, 0x65, 0x73, 0x73,
  1074. 0x61, 0x67, 0x65, 0x73, 0x52, 0x04, 0x64, 0x61, 0x74, 0x61, 0x12, 0x14, 0x0a, 0x05, 0x63, 0x6f,
  1075. 0x75, 0x6e, 0x74, 0x18, 0x04, 0x20, 0x01, 0x28, 0x03, 0x52, 0x05, 0x63, 0x6f, 0x75, 0x6e, 0x74,
  1076. 0x22, 0x60, 0x0a, 0x16, 0x47, 0x65, 0x74, 0x43, 0x6c, 0x61, 0x73, 0x73, 0x55, 0x6e, 0x72, 0x65,
  1077. 0x61, 0x64, 0x43, 0x6f, 0x75, 0x6e, 0x74, 0x52, 0x65, 0x71, 0x12, 0x16, 0x0a, 0x06, 0x75, 0x73,
  1078. 0x65, 0x72, 0x49, 0x64, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x06, 0x75, 0x73, 0x65, 0x72,
  1079. 0x49, 0x64, 0x12, 0x18, 0x0a, 0x07, 0x6d, 0x73, 0x67, 0x54, 0x79, 0x70, 0x65, 0x18, 0x02, 0x20,
  1080. 0x01, 0x28, 0x03, 0x52, 0x07, 0x6d, 0x73, 0x67, 0x54, 0x79, 0x70, 0x65, 0x12, 0x14, 0x0a, 0x05,
  1081. 0x61, 0x70, 0x70, 0x69, 0x64, 0x18, 0x03, 0x20, 0x01, 0x28, 0x09, 0x52, 0x05, 0x61, 0x70, 0x70,
  1082. 0x69, 0x64, 0x22, 0x22, 0x0a, 0x10, 0x4d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 0x44, 0x65, 0x74,
  1083. 0x61, 0x69, 0x6c, 0x52, 0x65, 0x71, 0x12, 0x0e, 0x0a, 0x02, 0x69, 0x64, 0x18, 0x01, 0x20, 0x01,
  1084. 0x28, 0x03, 0x52, 0x02, 0x69, 0x64, 0x22, 0x68, 0x0a, 0x11, 0x4d, 0x65, 0x73, 0x73, 0x61, 0x67,
  1085. 0x65, 0x44, 0x65, 0x74, 0x61, 0x69, 0x6c, 0x52, 0x65, 0x73, 0x70, 0x12, 0x12, 0x0a, 0x04, 0x63,
  1086. 0x6f, 0x64, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x03, 0x52, 0x04, 0x63, 0x6f, 0x64, 0x65, 0x12,
  1087. 0x18, 0x0a, 0x07, 0x6d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09,
  1088. 0x52, 0x07, 0x6d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 0x12, 0x25, 0x0a, 0x04, 0x64, 0x61, 0x74,
  1089. 0x61, 0x18, 0x03, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x11, 0x2e, 0x6d, 0x65, 0x73, 0x73, 0x61, 0x67,
  1090. 0x65, 0x2e, 0x4d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 0x73, 0x52, 0x04, 0x64, 0x61, 0x74, 0x61,
  1091. 0x22, 0x5b, 0x0a, 0x11, 0x47, 0x65, 0x74, 0x4c, 0x61, 0x73, 0x74, 0x4d, 0x65, 0x73, 0x73, 0x61,
  1092. 0x67, 0x65, 0x52, 0x65, 0x71, 0x12, 0x16, 0x0a, 0x06, 0x75, 0x73, 0x65, 0x72, 0x49, 0x64, 0x18,
  1093. 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x06, 0x75, 0x73, 0x65, 0x72, 0x49, 0x64, 0x12, 0x18, 0x0a,
  1094. 0x07, 0x6d, 0x73, 0x67, 0x54, 0x79, 0x70, 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x03, 0x52, 0x07,
  1095. 0x6d, 0x73, 0x67, 0x54, 0x79, 0x70, 0x65, 0x12, 0x14, 0x0a, 0x05, 0x61, 0x70, 0x70, 0x69, 0x64,
  1096. 0x18, 0x03, 0x20, 0x01, 0x28, 0x09, 0x52, 0x05, 0x61, 0x70, 0x70, 0x69, 0x64, 0x22, 0x68, 0x0a,
  1097. 0x11, 0x47, 0x65, 0x74, 0x4c, 0x61, 0x73, 0x74, 0x4d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 0x52,
  1098. 0x65, 0x73, 0x12, 0x12, 0x0a, 0x04, 0x63, 0x6f, 0x64, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x03,
  1099. 0x52, 0x04, 0x63, 0x6f, 0x64, 0x65, 0x12, 0x18, 0x0a, 0x07, 0x6d, 0x65, 0x73, 0x73, 0x61, 0x67,
  1100. 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x07, 0x6d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65,
  1101. 0x12, 0x25, 0x0a, 0x04, 0x64, 0x61, 0x74, 0x61, 0x18, 0x03, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x11,
  1102. 0x2e, 0x6d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 0x2e, 0x4d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65,
  1103. 0x73, 0x52, 0x04, 0x64, 0x61, 0x74, 0x61, 0x32, 0xb2, 0x05, 0x0a, 0x07, 0x4d, 0x65, 0x73, 0x73,
  1104. 0x61, 0x67, 0x65, 0x12, 0x47, 0x0a, 0x10, 0x43, 0x68, 0x61, 0x6e, 0x67, 0x65, 0x52, 0x65, 0x61,
  1105. 0x64, 0x53, 0x74, 0x61, 0x74, 0x75, 0x73, 0x12, 0x20, 0x2e, 0x6d, 0x65, 0x73, 0x73, 0x61, 0x67,
  1106. 0x65, 0x2e, 0x43, 0x68, 0x61, 0x6e, 0x67, 0x65, 0x52, 0x65, 0x61, 0x64, 0x53, 0x74, 0x61, 0x74,
  1107. 0x75, 0x73, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x11, 0x2e, 0x6d, 0x65, 0x73, 0x73,
  1108. 0x61, 0x67, 0x65, 0x2e, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x39, 0x0a, 0x0b,
  1109. 0x53, 0x65, 0x6e, 0x64, 0x55, 0x73, 0x65, 0x72, 0x4d, 0x73, 0x67, 0x12, 0x17, 0x2e, 0x6d, 0x65,
  1110. 0x73, 0x73, 0x61, 0x67, 0x65, 0x2e, 0x53, 0x65, 0x6e, 0x64, 0x4d, 0x73, 0x67, 0x52, 0x65, 0x71,
  1111. 0x75, 0x65, 0x73, 0x74, 0x1a, 0x11, 0x2e, 0x6d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 0x2e, 0x52,
  1112. 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x4d, 0x0a, 0x13, 0x44, 0x65, 0x6c, 0x65, 0x74,
  1113. 0x65, 0x53, 0x69, 0x6e, 0x67, 0x6c, 0x65, 0x4d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 0x12, 0x23,
  1114. 0x2e, 0x6d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 0x2e, 0x44, 0x65, 0x6c, 0x65, 0x74, 0x65, 0x53,
  1115. 0x69, 0x6e, 0x67, 0x6c, 0x65, 0x4d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 0x52, 0x65, 0x71, 0x75,
  1116. 0x65, 0x73, 0x74, 0x1a, 0x11, 0x2e, 0x6d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 0x2e, 0x52, 0x65,
  1117. 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x51, 0x0a, 0x15, 0x44, 0x65, 0x6c, 0x65, 0x74, 0x65,
  1118. 0x4d, 0x75, 0x6c, 0x74, 0x69, 0x70, 0x6c, 0x65, 0x4d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 0x12,
  1119. 0x25, 0x2e, 0x6d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 0x2e, 0x44, 0x65, 0x6c, 0x65, 0x74, 0x65,
  1120. 0x4d, 0x75, 0x6c, 0x74, 0x69, 0x70, 0x6c, 0x65, 0x4d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 0x52,
  1121. 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x11, 0x2e, 0x6d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65,
  1122. 0x2e, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x51, 0x0a, 0x0e, 0x47, 0x65, 0x74,
  1123. 0x55, 0x6e, 0x72, 0x65, 0x61, 0x64, 0x43, 0x6f, 0x75, 0x6e, 0x74, 0x12, 0x1e, 0x2e, 0x6d, 0x65,
  1124. 0x73, 0x73, 0x61, 0x67, 0x65, 0x2e, 0x47, 0x65, 0x74, 0x55, 0x6e, 0x72, 0x65, 0x61, 0x64, 0x43,
  1125. 0x6f, 0x75, 0x6e, 0x74, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x1f, 0x2e, 0x6d, 0x65,
  1126. 0x73, 0x73, 0x61, 0x67, 0x65, 0x2e, 0x47, 0x65, 0x74, 0x55, 0x6e, 0x72, 0x65, 0x61, 0x64, 0x43,
  1127. 0x6f, 0x75, 0x6e, 0x74, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x3f, 0x0a, 0x0b,
  1128. 0x46, 0x69, 0x6e, 0x64, 0x55, 0x73, 0x65, 0x72, 0x4d, 0x73, 0x67, 0x12, 0x17, 0x2e, 0x6d, 0x65,
  1129. 0x73, 0x73, 0x61, 0x67, 0x65, 0x2e, 0x46, 0x69, 0x6e, 0x64, 0x55, 0x73, 0x65, 0x72, 0x4d, 0x73,
  1130. 0x67, 0x52, 0x65, 0x71, 0x1a, 0x17, 0x2e, 0x6d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 0x2e, 0x46,
  1131. 0x69, 0x6e, 0x64, 0x55, 0x73, 0x65, 0x72, 0x4d, 0x73, 0x67, 0x52, 0x65, 0x73, 0x12, 0x57, 0x0a,
  1132. 0x13, 0x47, 0x65, 0x74, 0x43, 0x6c, 0x61, 0x73, 0x73, 0x55, 0x6e, 0x72, 0x65, 0x61, 0x64, 0x43,
  1133. 0x6f, 0x75, 0x6e, 0x74, 0x12, 0x1f, 0x2e, 0x6d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 0x2e, 0x47,
  1134. 0x65, 0x74, 0x43, 0x6c, 0x61, 0x73, 0x73, 0x55, 0x6e, 0x72, 0x65, 0x61, 0x64, 0x43, 0x6f, 0x75,
  1135. 0x6e, 0x74, 0x52, 0x65, 0x71, 0x1a, 0x1f, 0x2e, 0x6d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 0x2e,
  1136. 0x47, 0x65, 0x74, 0x55, 0x6e, 0x72, 0x65, 0x61, 0x64, 0x43, 0x6f, 0x75, 0x6e, 0x74, 0x52, 0x65,
  1137. 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x48, 0x0a, 0x0e, 0x47, 0x65, 0x74, 0x4c, 0x61, 0x73,
  1138. 0x74, 0x4d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 0x12, 0x1a, 0x2e, 0x6d, 0x65, 0x73, 0x73, 0x61,
  1139. 0x67, 0x65, 0x2e, 0x47, 0x65, 0x74, 0x4c, 0x61, 0x73, 0x74, 0x4d, 0x65, 0x73, 0x73, 0x61, 0x67,
  1140. 0x65, 0x52, 0x65, 0x71, 0x1a, 0x1a, 0x2e, 0x6d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 0x2e, 0x47,
  1141. 0x65, 0x74, 0x4c, 0x61, 0x73, 0x74, 0x4d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 0x52, 0x65, 0x73,
  1142. 0x12, 0x4a, 0x0a, 0x11, 0x46, 0x69, 0x6e, 0x64, 0x4d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 0x44,
  1143. 0x65, 0x74, 0x61, 0x69, 0x6c, 0x12, 0x19, 0x2e, 0x6d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 0x2e,
  1144. 0x4d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 0x44, 0x65, 0x74, 0x61, 0x69, 0x6c, 0x52, 0x65, 0x71,
  1145. 0x1a, 0x1a, 0x2e, 0x6d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 0x2e, 0x4d, 0x65, 0x73, 0x73, 0x61,
  1146. 0x67, 0x65, 0x44, 0x65, 0x74, 0x61, 0x69, 0x6c, 0x52, 0x65, 0x73, 0x70, 0x62, 0x06, 0x70, 0x72,
  1147. 0x6f, 0x74, 0x6f, 0x33,
  1148. }
  1149. var (
  1150. file_message_proto_rawDescOnce sync.Once
  1151. file_message_proto_rawDescData = file_message_proto_rawDesc
  1152. )
  1153. func file_message_proto_rawDescGZIP() []byte {
  1154. file_message_proto_rawDescOnce.Do(func() {
  1155. file_message_proto_rawDescData = protoimpl.X.CompressGZIP(file_message_proto_rawDescData)
  1156. })
  1157. return file_message_proto_rawDescData
  1158. }
  1159. var file_message_proto_msgTypes = make([]protoimpl.MessageInfo, 15)
  1160. var file_message_proto_goTypes = []interface{}{
  1161. (*SendMsgRequest)(nil), // 0: message.SendMsgRequest
  1162. (*ChangeReadStatusRequest)(nil), // 1: message.ChangeReadStatusRequest
  1163. (*DeleteSingleMessageRequest)(nil), // 2: message.DeleteSingleMessageRequest
  1164. (*DeleteMultipleMessageRequest)(nil), // 3: message.DeleteMultipleMessageRequest
  1165. (*GetUnreadCountRequest)(nil), // 4: message.GetUnreadCountRequest
  1166. (*Response)(nil), // 5: message.Response
  1167. (*GetUnreadCountResponse)(nil), // 6: message.GetUnreadCountResponse
  1168. (*FindUserMsgReq)(nil), // 7: message.FindUserMsgReq
  1169. (*Messages)(nil), // 8: message.Messages
  1170. (*FindUserMsgRes)(nil), // 9: message.FindUserMsgRes
  1171. (*GetClassUnreadCountReq)(nil), // 10: message.GetClassUnreadCountReq
  1172. (*MessageDetailReq)(nil), // 11: message.MessageDetailReq
  1173. (*MessageDetailResp)(nil), // 12: message.MessageDetailResp
  1174. (*GetLastMessageReq)(nil), // 13: message.GetLastMessageReq
  1175. (*GetLastMessageRes)(nil), // 14: message.GetLastMessageRes
  1176. }
  1177. var file_message_proto_depIdxs = []int32{
  1178. 8, // 0: message.FindUserMsgRes.data:type_name -> message.Messages
  1179. 8, // 1: message.MessageDetailResp.data:type_name -> message.Messages
  1180. 8, // 2: message.GetLastMessageRes.data:type_name -> message.Messages
  1181. 1, // 3: message.Message.ChangeReadStatus:input_type -> message.ChangeReadStatusRequest
  1182. 0, // 4: message.Message.SendUserMsg:input_type -> message.SendMsgRequest
  1183. 2, // 5: message.Message.DeleteSingleMessage:input_type -> message.DeleteSingleMessageRequest
  1184. 3, // 6: message.Message.DeleteMultipleMessage:input_type -> message.DeleteMultipleMessageRequest
  1185. 4, // 7: message.Message.GetUnreadCount:input_type -> message.GetUnreadCountRequest
  1186. 7, // 8: message.Message.FindUserMsg:input_type -> message.FindUserMsgReq
  1187. 10, // 9: message.Message.GetClassUnreadCount:input_type -> message.GetClassUnreadCountReq
  1188. 13, // 10: message.Message.GetLastMessage:input_type -> message.GetLastMessageReq
  1189. 11, // 11: message.Message.FindMessageDetail:input_type -> message.MessageDetailReq
  1190. 5, // 12: message.Message.ChangeReadStatus:output_type -> message.Response
  1191. 5, // 13: message.Message.SendUserMsg:output_type -> message.Response
  1192. 5, // 14: message.Message.DeleteSingleMessage:output_type -> message.Response
  1193. 5, // 15: message.Message.DeleteMultipleMessage:output_type -> message.Response
  1194. 6, // 16: message.Message.GetUnreadCount:output_type -> message.GetUnreadCountResponse
  1195. 9, // 17: message.Message.FindUserMsg:output_type -> message.FindUserMsgRes
  1196. 6, // 18: message.Message.GetClassUnreadCount:output_type -> message.GetUnreadCountResponse
  1197. 14, // 19: message.Message.GetLastMessage:output_type -> message.GetLastMessageRes
  1198. 12, // 20: message.Message.FindMessageDetail:output_type -> message.MessageDetailResp
  1199. 12, // [12:21] is the sub-list for method output_type
  1200. 3, // [3:12] is the sub-list for method input_type
  1201. 3, // [3:3] is the sub-list for extension type_name
  1202. 3, // [3:3] is the sub-list for extension extendee
  1203. 0, // [0:3] is the sub-list for field type_name
  1204. }
  1205. func init() { file_message_proto_init() }
  1206. func file_message_proto_init() {
  1207. if File_message_proto != nil {
  1208. return
  1209. }
  1210. if !protoimpl.UnsafeEnabled {
  1211. file_message_proto_msgTypes[0].Exporter = func(v interface{}, i int) interface{} {
  1212. switch v := v.(*SendMsgRequest); i {
  1213. case 0:
  1214. return &v.state
  1215. case 1:
  1216. return &v.sizeCache
  1217. case 2:
  1218. return &v.unknownFields
  1219. default:
  1220. return nil
  1221. }
  1222. }
  1223. file_message_proto_msgTypes[1].Exporter = func(v interface{}, i int) interface{} {
  1224. switch v := v.(*ChangeReadStatusRequest); i {
  1225. case 0:
  1226. return &v.state
  1227. case 1:
  1228. return &v.sizeCache
  1229. case 2:
  1230. return &v.unknownFields
  1231. default:
  1232. return nil
  1233. }
  1234. }
  1235. file_message_proto_msgTypes[2].Exporter = func(v interface{}, i int) interface{} {
  1236. switch v := v.(*DeleteSingleMessageRequest); i {
  1237. case 0:
  1238. return &v.state
  1239. case 1:
  1240. return &v.sizeCache
  1241. case 2:
  1242. return &v.unknownFields
  1243. default:
  1244. return nil
  1245. }
  1246. }
  1247. file_message_proto_msgTypes[3].Exporter = func(v interface{}, i int) interface{} {
  1248. switch v := v.(*DeleteMultipleMessageRequest); i {
  1249. case 0:
  1250. return &v.state
  1251. case 1:
  1252. return &v.sizeCache
  1253. case 2:
  1254. return &v.unknownFields
  1255. default:
  1256. return nil
  1257. }
  1258. }
  1259. file_message_proto_msgTypes[4].Exporter = func(v interface{}, i int) interface{} {
  1260. switch v := v.(*GetUnreadCountRequest); i {
  1261. case 0:
  1262. return &v.state
  1263. case 1:
  1264. return &v.sizeCache
  1265. case 2:
  1266. return &v.unknownFields
  1267. default:
  1268. return nil
  1269. }
  1270. }
  1271. file_message_proto_msgTypes[5].Exporter = func(v interface{}, i int) interface{} {
  1272. switch v := v.(*Response); i {
  1273. case 0:
  1274. return &v.state
  1275. case 1:
  1276. return &v.sizeCache
  1277. case 2:
  1278. return &v.unknownFields
  1279. default:
  1280. return nil
  1281. }
  1282. }
  1283. file_message_proto_msgTypes[6].Exporter = func(v interface{}, i int) interface{} {
  1284. switch v := v.(*GetUnreadCountResponse); i {
  1285. case 0:
  1286. return &v.state
  1287. case 1:
  1288. return &v.sizeCache
  1289. case 2:
  1290. return &v.unknownFields
  1291. default:
  1292. return nil
  1293. }
  1294. }
  1295. file_message_proto_msgTypes[7].Exporter = func(v interface{}, i int) interface{} {
  1296. switch v := v.(*FindUserMsgReq); i {
  1297. case 0:
  1298. return &v.state
  1299. case 1:
  1300. return &v.sizeCache
  1301. case 2:
  1302. return &v.unknownFields
  1303. default:
  1304. return nil
  1305. }
  1306. }
  1307. file_message_proto_msgTypes[8].Exporter = func(v interface{}, i int) interface{} {
  1308. switch v := v.(*Messages); i {
  1309. case 0:
  1310. return &v.state
  1311. case 1:
  1312. return &v.sizeCache
  1313. case 2:
  1314. return &v.unknownFields
  1315. default:
  1316. return nil
  1317. }
  1318. }
  1319. file_message_proto_msgTypes[9].Exporter = func(v interface{}, i int) interface{} {
  1320. switch v := v.(*FindUserMsgRes); i {
  1321. case 0:
  1322. return &v.state
  1323. case 1:
  1324. return &v.sizeCache
  1325. case 2:
  1326. return &v.unknownFields
  1327. default:
  1328. return nil
  1329. }
  1330. }
  1331. file_message_proto_msgTypes[10].Exporter = func(v interface{}, i int) interface{} {
  1332. switch v := v.(*GetClassUnreadCountReq); i {
  1333. case 0:
  1334. return &v.state
  1335. case 1:
  1336. return &v.sizeCache
  1337. case 2:
  1338. return &v.unknownFields
  1339. default:
  1340. return nil
  1341. }
  1342. }
  1343. file_message_proto_msgTypes[11].Exporter = func(v interface{}, i int) interface{} {
  1344. switch v := v.(*MessageDetailReq); i {
  1345. case 0:
  1346. return &v.state
  1347. case 1:
  1348. return &v.sizeCache
  1349. case 2:
  1350. return &v.unknownFields
  1351. default:
  1352. return nil
  1353. }
  1354. }
  1355. file_message_proto_msgTypes[12].Exporter = func(v interface{}, i int) interface{} {
  1356. switch v := v.(*MessageDetailResp); i {
  1357. case 0:
  1358. return &v.state
  1359. case 1:
  1360. return &v.sizeCache
  1361. case 2:
  1362. return &v.unknownFields
  1363. default:
  1364. return nil
  1365. }
  1366. }
  1367. file_message_proto_msgTypes[13].Exporter = func(v interface{}, i int) interface{} {
  1368. switch v := v.(*GetLastMessageReq); i {
  1369. case 0:
  1370. return &v.state
  1371. case 1:
  1372. return &v.sizeCache
  1373. case 2:
  1374. return &v.unknownFields
  1375. default:
  1376. return nil
  1377. }
  1378. }
  1379. file_message_proto_msgTypes[14].Exporter = func(v interface{}, i int) interface{} {
  1380. switch v := v.(*GetLastMessageRes); i {
  1381. case 0:
  1382. return &v.state
  1383. case 1:
  1384. return &v.sizeCache
  1385. case 2:
  1386. return &v.unknownFields
  1387. default:
  1388. return nil
  1389. }
  1390. }
  1391. }
  1392. type x struct{}
  1393. out := protoimpl.TypeBuilder{
  1394. File: protoimpl.DescBuilder{
  1395. GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
  1396. RawDescriptor: file_message_proto_rawDesc,
  1397. NumEnums: 0,
  1398. NumMessages: 15,
  1399. NumExtensions: 0,
  1400. NumServices: 1,
  1401. },
  1402. GoTypes: file_message_proto_goTypes,
  1403. DependencyIndexes: file_message_proto_depIdxs,
  1404. MessageInfos: file_message_proto_msgTypes,
  1405. }.Build()
  1406. File_message_proto = out.File
  1407. file_message_proto_rawDesc = nil
  1408. file_message_proto_goTypes = nil
  1409. file_message_proto_depIdxs = nil
  1410. }
  1411. // Reference imports to suppress errors if they are not otherwise used.
  1412. var _ context.Context
  1413. var _ grpc.ClientConnInterface
  1414. // This is a compile-time assertion to ensure that this generated file
  1415. // is compatible with the grpc package it is being compiled against.
  1416. const _ = grpc.SupportPackageIsVersion6
  1417. // MessageClient is the client API for Message service.
  1418. //
  1419. // For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
  1420. type MessageClient interface {
  1421. // 修改消息阅读状态
  1422. ChangeReadStatus(ctx context.Context, in *ChangeReadStatusRequest, opts ...grpc.CallOption) (*Response, error)
  1423. //指定用户发消息
  1424. SendUserMsg(ctx context.Context, in *SendMsgRequest, opts ...grpc.CallOption) (*Response, error)
  1425. // 删除单一消息
  1426. DeleteSingleMessage(ctx context.Context, in *DeleteSingleMessageRequest, opts ...grpc.CallOption) (*Response, error)
  1427. // 删除多条消息
  1428. DeleteMultipleMessage(ctx context.Context, in *DeleteMultipleMessageRequest, opts ...grpc.CallOption) (*Response, error)
  1429. // 查询指定用户未读消息合计
  1430. GetUnreadCount(ctx context.Context, in *GetUnreadCountRequest, opts ...grpc.CallOption) (*GetUnreadCountResponse, error)
  1431. // 查询指定用户的历史消息记录
  1432. FindUserMsg(ctx context.Context, in *FindUserMsgReq, opts ...grpc.CallOption) (*FindUserMsgRes, error)
  1433. // 查询指定用户指定分类的未读消息合计
  1434. GetClassUnreadCount(ctx context.Context, in *GetClassUnreadCountReq, opts ...grpc.CallOption) (*GetUnreadCountResponse, error)
  1435. // 获取指定用户指定分类的最新一条未读消息
  1436. GetLastMessage(ctx context.Context, in *GetLastMessageReq, opts ...grpc.CallOption) (*GetLastMessageRes, error)
  1437. //查看详细详情
  1438. FindMessageDetail(ctx context.Context, in *MessageDetailReq, opts ...grpc.CallOption) (*MessageDetailResp, error)
  1439. }
  1440. type messageClient struct {
  1441. cc grpc.ClientConnInterface
  1442. }
  1443. func NewMessageClient(cc grpc.ClientConnInterface) MessageClient {
  1444. return &messageClient{cc}
  1445. }
  1446. func (c *messageClient) ChangeReadStatus(ctx context.Context, in *ChangeReadStatusRequest, opts ...grpc.CallOption) (*Response, error) {
  1447. out := new(Response)
  1448. err := c.cc.Invoke(ctx, "/message.Message/ChangeReadStatus", in, out, opts...)
  1449. if err != nil {
  1450. return nil, err
  1451. }
  1452. return out, nil
  1453. }
  1454. func (c *messageClient) SendUserMsg(ctx context.Context, in *SendMsgRequest, opts ...grpc.CallOption) (*Response, error) {
  1455. out := new(Response)
  1456. err := c.cc.Invoke(ctx, "/message.Message/SendUserMsg", in, out, opts...)
  1457. if err != nil {
  1458. return nil, err
  1459. }
  1460. return out, nil
  1461. }
  1462. func (c *messageClient) DeleteSingleMessage(ctx context.Context, in *DeleteSingleMessageRequest, opts ...grpc.CallOption) (*Response, error) {
  1463. out := new(Response)
  1464. err := c.cc.Invoke(ctx, "/message.Message/DeleteSingleMessage", in, out, opts...)
  1465. if err != nil {
  1466. return nil, err
  1467. }
  1468. return out, nil
  1469. }
  1470. func (c *messageClient) DeleteMultipleMessage(ctx context.Context, in *DeleteMultipleMessageRequest, opts ...grpc.CallOption) (*Response, error) {
  1471. out := new(Response)
  1472. err := c.cc.Invoke(ctx, "/message.Message/DeleteMultipleMessage", in, out, opts...)
  1473. if err != nil {
  1474. return nil, err
  1475. }
  1476. return out, nil
  1477. }
  1478. func (c *messageClient) GetUnreadCount(ctx context.Context, in *GetUnreadCountRequest, opts ...grpc.CallOption) (*GetUnreadCountResponse, error) {
  1479. out := new(GetUnreadCountResponse)
  1480. err := c.cc.Invoke(ctx, "/message.Message/GetUnreadCount", in, out, opts...)
  1481. if err != nil {
  1482. return nil, err
  1483. }
  1484. return out, nil
  1485. }
  1486. func (c *messageClient) FindUserMsg(ctx context.Context, in *FindUserMsgReq, opts ...grpc.CallOption) (*FindUserMsgRes, error) {
  1487. out := new(FindUserMsgRes)
  1488. err := c.cc.Invoke(ctx, "/message.Message/FindUserMsg", in, out, opts...)
  1489. if err != nil {
  1490. return nil, err
  1491. }
  1492. return out, nil
  1493. }
  1494. func (c *messageClient) GetClassUnreadCount(ctx context.Context, in *GetClassUnreadCountReq, opts ...grpc.CallOption) (*GetUnreadCountResponse, error) {
  1495. out := new(GetUnreadCountResponse)
  1496. err := c.cc.Invoke(ctx, "/message.Message/GetClassUnreadCount", in, out, opts...)
  1497. if err != nil {
  1498. return nil, err
  1499. }
  1500. return out, nil
  1501. }
  1502. func (c *messageClient) GetLastMessage(ctx context.Context, in *GetLastMessageReq, opts ...grpc.CallOption) (*GetLastMessageRes, error) {
  1503. out := new(GetLastMessageRes)
  1504. err := c.cc.Invoke(ctx, "/message.Message/GetLastMessage", in, out, opts...)
  1505. if err != nil {
  1506. return nil, err
  1507. }
  1508. return out, nil
  1509. }
  1510. func (c *messageClient) FindMessageDetail(ctx context.Context, in *MessageDetailReq, opts ...grpc.CallOption) (*MessageDetailResp, error) {
  1511. out := new(MessageDetailResp)
  1512. err := c.cc.Invoke(ctx, "/message.Message/FindMessageDetail", in, out, opts...)
  1513. if err != nil {
  1514. return nil, err
  1515. }
  1516. return out, nil
  1517. }
  1518. // MessageServer is the server API for Message service.
  1519. type MessageServer interface {
  1520. // 修改消息阅读状态
  1521. ChangeReadStatus(context.Context, *ChangeReadStatusRequest) (*Response, error)
  1522. //指定用户发消息
  1523. SendUserMsg(context.Context, *SendMsgRequest) (*Response, error)
  1524. // 删除单一消息
  1525. DeleteSingleMessage(context.Context, *DeleteSingleMessageRequest) (*Response, error)
  1526. // 删除多条消息
  1527. DeleteMultipleMessage(context.Context, *DeleteMultipleMessageRequest) (*Response, error)
  1528. // 查询指定用户未读消息合计
  1529. GetUnreadCount(context.Context, *GetUnreadCountRequest) (*GetUnreadCountResponse, error)
  1530. // 查询指定用户的历史消息记录
  1531. FindUserMsg(context.Context, *FindUserMsgReq) (*FindUserMsgRes, error)
  1532. // 查询指定用户指定分类的未读消息合计
  1533. GetClassUnreadCount(context.Context, *GetClassUnreadCountReq) (*GetUnreadCountResponse, error)
  1534. // 获取指定用户指定分类的最新一条未读消息
  1535. GetLastMessage(context.Context, *GetLastMessageReq) (*GetLastMessageRes, error)
  1536. //查看详细详情
  1537. FindMessageDetail(context.Context, *MessageDetailReq) (*MessageDetailResp, error)
  1538. }
  1539. // UnimplementedMessageServer can be embedded to have forward compatible implementations.
  1540. type UnimplementedMessageServer struct {
  1541. }
  1542. func (*UnimplementedMessageServer) ChangeReadStatus(context.Context, *ChangeReadStatusRequest) (*Response, error) {
  1543. return nil, status.Errorf(codes.Unimplemented, "method ChangeReadStatus not implemented")
  1544. }
  1545. func (*UnimplementedMessageServer) SendUserMsg(context.Context, *SendMsgRequest) (*Response, error) {
  1546. return nil, status.Errorf(codes.Unimplemented, "method SendUserMsg not implemented")
  1547. }
  1548. func (*UnimplementedMessageServer) DeleteSingleMessage(context.Context, *DeleteSingleMessageRequest) (*Response, error) {
  1549. return nil, status.Errorf(codes.Unimplemented, "method DeleteSingleMessage not implemented")
  1550. }
  1551. func (*UnimplementedMessageServer) DeleteMultipleMessage(context.Context, *DeleteMultipleMessageRequest) (*Response, error) {
  1552. return nil, status.Errorf(codes.Unimplemented, "method DeleteMultipleMessage not implemented")
  1553. }
  1554. func (*UnimplementedMessageServer) GetUnreadCount(context.Context, *GetUnreadCountRequest) (*GetUnreadCountResponse, error) {
  1555. return nil, status.Errorf(codes.Unimplemented, "method GetUnreadCount not implemented")
  1556. }
  1557. func (*UnimplementedMessageServer) FindUserMsg(context.Context, *FindUserMsgReq) (*FindUserMsgRes, error) {
  1558. return nil, status.Errorf(codes.Unimplemented, "method FindUserMsg not implemented")
  1559. }
  1560. func (*UnimplementedMessageServer) GetClassUnreadCount(context.Context, *GetClassUnreadCountReq) (*GetUnreadCountResponse, error) {
  1561. return nil, status.Errorf(codes.Unimplemented, "method GetClassUnreadCount not implemented")
  1562. }
  1563. func (*UnimplementedMessageServer) GetLastMessage(context.Context, *GetLastMessageReq) (*GetLastMessageRes, error) {
  1564. return nil, status.Errorf(codes.Unimplemented, "method GetLastMessage not implemented")
  1565. }
  1566. func (*UnimplementedMessageServer) FindMessageDetail(context.Context, *MessageDetailReq) (*MessageDetailResp, error) {
  1567. return nil, status.Errorf(codes.Unimplemented, "method FindMessageDetail not implemented")
  1568. }
  1569. func RegisterMessageServer(s *grpc.Server, srv MessageServer) {
  1570. s.RegisterService(&_Message_serviceDesc, srv)
  1571. }
  1572. func _Message_ChangeReadStatus_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  1573. in := new(ChangeReadStatusRequest)
  1574. if err := dec(in); err != nil {
  1575. return nil, err
  1576. }
  1577. if interceptor == nil {
  1578. return srv.(MessageServer).ChangeReadStatus(ctx, in)
  1579. }
  1580. info := &grpc.UnaryServerInfo{
  1581. Server: srv,
  1582. FullMethod: "/message.Message/ChangeReadStatus",
  1583. }
  1584. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  1585. return srv.(MessageServer).ChangeReadStatus(ctx, req.(*ChangeReadStatusRequest))
  1586. }
  1587. return interceptor(ctx, in, info, handler)
  1588. }
  1589. func _Message_SendUserMsg_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  1590. in := new(SendMsgRequest)
  1591. if err := dec(in); err != nil {
  1592. return nil, err
  1593. }
  1594. if interceptor == nil {
  1595. return srv.(MessageServer).SendUserMsg(ctx, in)
  1596. }
  1597. info := &grpc.UnaryServerInfo{
  1598. Server: srv,
  1599. FullMethod: "/message.Message/SendUserMsg",
  1600. }
  1601. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  1602. return srv.(MessageServer).SendUserMsg(ctx, req.(*SendMsgRequest))
  1603. }
  1604. return interceptor(ctx, in, info, handler)
  1605. }
  1606. func _Message_DeleteSingleMessage_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  1607. in := new(DeleteSingleMessageRequest)
  1608. if err := dec(in); err != nil {
  1609. return nil, err
  1610. }
  1611. if interceptor == nil {
  1612. return srv.(MessageServer).DeleteSingleMessage(ctx, in)
  1613. }
  1614. info := &grpc.UnaryServerInfo{
  1615. Server: srv,
  1616. FullMethod: "/message.Message/DeleteSingleMessage",
  1617. }
  1618. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  1619. return srv.(MessageServer).DeleteSingleMessage(ctx, req.(*DeleteSingleMessageRequest))
  1620. }
  1621. return interceptor(ctx, in, info, handler)
  1622. }
  1623. func _Message_DeleteMultipleMessage_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  1624. in := new(DeleteMultipleMessageRequest)
  1625. if err := dec(in); err != nil {
  1626. return nil, err
  1627. }
  1628. if interceptor == nil {
  1629. return srv.(MessageServer).DeleteMultipleMessage(ctx, in)
  1630. }
  1631. info := &grpc.UnaryServerInfo{
  1632. Server: srv,
  1633. FullMethod: "/message.Message/DeleteMultipleMessage",
  1634. }
  1635. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  1636. return srv.(MessageServer).DeleteMultipleMessage(ctx, req.(*DeleteMultipleMessageRequest))
  1637. }
  1638. return interceptor(ctx, in, info, handler)
  1639. }
  1640. func _Message_GetUnreadCount_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  1641. in := new(GetUnreadCountRequest)
  1642. if err := dec(in); err != nil {
  1643. return nil, err
  1644. }
  1645. if interceptor == nil {
  1646. return srv.(MessageServer).GetUnreadCount(ctx, in)
  1647. }
  1648. info := &grpc.UnaryServerInfo{
  1649. Server: srv,
  1650. FullMethod: "/message.Message/GetUnreadCount",
  1651. }
  1652. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  1653. return srv.(MessageServer).GetUnreadCount(ctx, req.(*GetUnreadCountRequest))
  1654. }
  1655. return interceptor(ctx, in, info, handler)
  1656. }
  1657. func _Message_FindUserMsg_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  1658. in := new(FindUserMsgReq)
  1659. if err := dec(in); err != nil {
  1660. return nil, err
  1661. }
  1662. if interceptor == nil {
  1663. return srv.(MessageServer).FindUserMsg(ctx, in)
  1664. }
  1665. info := &grpc.UnaryServerInfo{
  1666. Server: srv,
  1667. FullMethod: "/message.Message/FindUserMsg",
  1668. }
  1669. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  1670. return srv.(MessageServer).FindUserMsg(ctx, req.(*FindUserMsgReq))
  1671. }
  1672. return interceptor(ctx, in, info, handler)
  1673. }
  1674. func _Message_GetClassUnreadCount_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  1675. in := new(GetClassUnreadCountReq)
  1676. if err := dec(in); err != nil {
  1677. return nil, err
  1678. }
  1679. if interceptor == nil {
  1680. return srv.(MessageServer).GetClassUnreadCount(ctx, in)
  1681. }
  1682. info := &grpc.UnaryServerInfo{
  1683. Server: srv,
  1684. FullMethod: "/message.Message/GetClassUnreadCount",
  1685. }
  1686. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  1687. return srv.(MessageServer).GetClassUnreadCount(ctx, req.(*GetClassUnreadCountReq))
  1688. }
  1689. return interceptor(ctx, in, info, handler)
  1690. }
  1691. func _Message_GetLastMessage_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  1692. in := new(GetLastMessageReq)
  1693. if err := dec(in); err != nil {
  1694. return nil, err
  1695. }
  1696. if interceptor == nil {
  1697. return srv.(MessageServer).GetLastMessage(ctx, in)
  1698. }
  1699. info := &grpc.UnaryServerInfo{
  1700. Server: srv,
  1701. FullMethod: "/message.Message/GetLastMessage",
  1702. }
  1703. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  1704. return srv.(MessageServer).GetLastMessage(ctx, req.(*GetLastMessageReq))
  1705. }
  1706. return interceptor(ctx, in, info, handler)
  1707. }
  1708. func _Message_FindMessageDetail_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  1709. in := new(MessageDetailReq)
  1710. if err := dec(in); err != nil {
  1711. return nil, err
  1712. }
  1713. if interceptor == nil {
  1714. return srv.(MessageServer).FindMessageDetail(ctx, in)
  1715. }
  1716. info := &grpc.UnaryServerInfo{
  1717. Server: srv,
  1718. FullMethod: "/message.Message/FindMessageDetail",
  1719. }
  1720. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  1721. return srv.(MessageServer).FindMessageDetail(ctx, req.(*MessageDetailReq))
  1722. }
  1723. return interceptor(ctx, in, info, handler)
  1724. }
  1725. var _Message_serviceDesc = grpc.ServiceDesc{
  1726. ServiceName: "message.Message",
  1727. HandlerType: (*MessageServer)(nil),
  1728. Methods: []grpc.MethodDesc{
  1729. {
  1730. MethodName: "ChangeReadStatus",
  1731. Handler: _Message_ChangeReadStatus_Handler,
  1732. },
  1733. {
  1734. MethodName: "SendUserMsg",
  1735. Handler: _Message_SendUserMsg_Handler,
  1736. },
  1737. {
  1738. MethodName: "DeleteSingleMessage",
  1739. Handler: _Message_DeleteSingleMessage_Handler,
  1740. },
  1741. {
  1742. MethodName: "DeleteMultipleMessage",
  1743. Handler: _Message_DeleteMultipleMessage_Handler,
  1744. },
  1745. {
  1746. MethodName: "GetUnreadCount",
  1747. Handler: _Message_GetUnreadCount_Handler,
  1748. },
  1749. {
  1750. MethodName: "FindUserMsg",
  1751. Handler: _Message_FindUserMsg_Handler,
  1752. },
  1753. {
  1754. MethodName: "GetClassUnreadCount",
  1755. Handler: _Message_GetClassUnreadCount_Handler,
  1756. },
  1757. {
  1758. MethodName: "GetLastMessage",
  1759. Handler: _Message_GetLastMessage_Handler,
  1760. },
  1761. {
  1762. MethodName: "FindMessageDetail",
  1763. Handler: _Message_FindMessageDetail_Handler,
  1764. },
  1765. },
  1766. Streams: []grpc.StreamDesc{},
  1767. Metadata: "message.proto",
  1768. }