蛋蛋星球 后台端

business.int.pb.go 17 KiB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490
  1. // Code generated by protoc-gen-go. DO NOT EDIT.
  2. // versions:
  3. // protoc-gen-go v1.28.1
  4. // protoc v3.20.0--rc2
  5. // source: business.int.proto
  6. package pb
  7. import (
  8. context "context"
  9. grpc "google.golang.org/grpc"
  10. codes "google.golang.org/grpc/codes"
  11. status "google.golang.org/grpc/status"
  12. protoreflect "google.golang.org/protobuf/reflect/protoreflect"
  13. protoimpl "google.golang.org/protobuf/runtime/protoimpl"
  14. reflect "reflect"
  15. sync "sync"
  16. )
  17. const (
  18. // Verify that this generated code is sufficiently up-to-date.
  19. _ = protoimpl.EnforceVersion(20 - protoimpl.MinVersion)
  20. // Verify that runtime/protoimpl is sufficiently up-to-date.
  21. _ = protoimpl.EnforceVersion(protoimpl.MaxVersion - 20)
  22. )
  23. type AuthReq struct {
  24. state protoimpl.MessageState
  25. sizeCache protoimpl.SizeCache
  26. unknownFields protoimpl.UnknownFields
  27. UserId int64 `protobuf:"varint,1,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"`
  28. DeviceId int64 `protobuf:"varint,2,opt,name=device_id,json=deviceId,proto3" json:"device_id,omitempty"`
  29. Token string `protobuf:"bytes,3,opt,name=token,proto3" json:"token,omitempty"`
  30. }
  31. func (x *AuthReq) Reset() {
  32. *x = AuthReq{}
  33. if protoimpl.UnsafeEnabled {
  34. mi := &file_business_int_proto_msgTypes[0]
  35. ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  36. ms.StoreMessageInfo(mi)
  37. }
  38. }
  39. func (x *AuthReq) String() string {
  40. return protoimpl.X.MessageStringOf(x)
  41. }
  42. func (*AuthReq) ProtoMessage() {}
  43. func (x *AuthReq) ProtoReflect() protoreflect.Message {
  44. mi := &file_business_int_proto_msgTypes[0]
  45. if protoimpl.UnsafeEnabled && x != nil {
  46. ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  47. if ms.LoadMessageInfo() == nil {
  48. ms.StoreMessageInfo(mi)
  49. }
  50. return ms
  51. }
  52. return mi.MessageOf(x)
  53. }
  54. // Deprecated: Use AuthReq.ProtoReflect.Descriptor instead.
  55. func (*AuthReq) Descriptor() ([]byte, []int) {
  56. return file_business_int_proto_rawDescGZIP(), []int{0}
  57. }
  58. func (x *AuthReq) GetUserId() int64 {
  59. if x != nil {
  60. return x.UserId
  61. }
  62. return 0
  63. }
  64. func (x *AuthReq) GetDeviceId() int64 {
  65. if x != nil {
  66. return x.DeviceId
  67. }
  68. return 0
  69. }
  70. func (x *AuthReq) GetToken() string {
  71. if x != nil {
  72. return x.Token
  73. }
  74. return ""
  75. }
  76. type GetUsersReq struct {
  77. state protoimpl.MessageState
  78. sizeCache protoimpl.SizeCache
  79. unknownFields protoimpl.UnknownFields
  80. UserIds map[int64]int32 `protobuf:"bytes,1,rep,name=user_ids,json=userIds,proto3" json:"user_ids,omitempty" protobuf_key:"varint,1,opt,name=key,proto3" protobuf_val:"varint,2,opt,name=value,proto3"` // 用户id
  81. }
  82. func (x *GetUsersReq) Reset() {
  83. *x = GetUsersReq{}
  84. if protoimpl.UnsafeEnabled {
  85. mi := &file_business_int_proto_msgTypes[1]
  86. ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  87. ms.StoreMessageInfo(mi)
  88. }
  89. }
  90. func (x *GetUsersReq) String() string {
  91. return protoimpl.X.MessageStringOf(x)
  92. }
  93. func (*GetUsersReq) ProtoMessage() {}
  94. func (x *GetUsersReq) ProtoReflect() protoreflect.Message {
  95. mi := &file_business_int_proto_msgTypes[1]
  96. if protoimpl.UnsafeEnabled && x != nil {
  97. ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  98. if ms.LoadMessageInfo() == nil {
  99. ms.StoreMessageInfo(mi)
  100. }
  101. return ms
  102. }
  103. return mi.MessageOf(x)
  104. }
  105. // Deprecated: Use GetUsersReq.ProtoReflect.Descriptor instead.
  106. func (*GetUsersReq) Descriptor() ([]byte, []int) {
  107. return file_business_int_proto_rawDescGZIP(), []int{1}
  108. }
  109. func (x *GetUsersReq) GetUserIds() map[int64]int32 {
  110. if x != nil {
  111. return x.UserIds
  112. }
  113. return nil
  114. }
  115. type GetUsersResp struct {
  116. state protoimpl.MessageState
  117. sizeCache protoimpl.SizeCache
  118. unknownFields protoimpl.UnknownFields
  119. Users map[int64]*User `protobuf:"bytes,1,rep,name=users,proto3" json:"users,omitempty" protobuf_key:"varint,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"` // 用户信息
  120. }
  121. func (x *GetUsersResp) Reset() {
  122. *x = GetUsersResp{}
  123. if protoimpl.UnsafeEnabled {
  124. mi := &file_business_int_proto_msgTypes[2]
  125. ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  126. ms.StoreMessageInfo(mi)
  127. }
  128. }
  129. func (x *GetUsersResp) String() string {
  130. return protoimpl.X.MessageStringOf(x)
  131. }
  132. func (*GetUsersResp) ProtoMessage() {}
  133. func (x *GetUsersResp) ProtoReflect() protoreflect.Message {
  134. mi := &file_business_int_proto_msgTypes[2]
  135. if protoimpl.UnsafeEnabled && x != nil {
  136. ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  137. if ms.LoadMessageInfo() == nil {
  138. ms.StoreMessageInfo(mi)
  139. }
  140. return ms
  141. }
  142. return mi.MessageOf(x)
  143. }
  144. // Deprecated: Use GetUsersResp.ProtoReflect.Descriptor instead.
  145. func (*GetUsersResp) Descriptor() ([]byte, []int) {
  146. return file_business_int_proto_rawDescGZIP(), []int{2}
  147. }
  148. func (x *GetUsersResp) GetUsers() map[int64]*User {
  149. if x != nil {
  150. return x.Users
  151. }
  152. return nil
  153. }
  154. var File_business_int_proto protoreflect.FileDescriptor
  155. var file_business_int_proto_rawDesc = []byte{
  156. 0x0a, 0x12, 0x62, 0x75, 0x73, 0x69, 0x6e, 0x65, 0x73, 0x73, 0x2e, 0x69, 0x6e, 0x74, 0x2e, 0x70,
  157. 0x72, 0x6f, 0x74, 0x6f, 0x12, 0x02, 0x70, 0x62, 0x1a, 0x10, 0x63, 0x6f, 0x6d, 0x6d, 0x6f, 0x6e,
  158. 0x2e, 0x65, 0x78, 0x74, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x12, 0x62, 0x75, 0x73, 0x69,
  159. 0x6e, 0x65, 0x73, 0x73, 0x2e, 0x65, 0x78, 0x74, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x22, 0x55,
  160. 0x0a, 0x07, 0x41, 0x75, 0x74, 0x68, 0x52, 0x65, 0x71, 0x12, 0x17, 0x0a, 0x07, 0x75, 0x73, 0x65,
  161. 0x72, 0x5f, 0x69, 0x64, 0x18, 0x01, 0x20, 0x01, 0x28, 0x03, 0x52, 0x06, 0x75, 0x73, 0x65, 0x72,
  162. 0x49, 0x64, 0x12, 0x1b, 0x0a, 0x09, 0x64, 0x65, 0x76, 0x69, 0x63, 0x65, 0x5f, 0x69, 0x64, 0x18,
  163. 0x02, 0x20, 0x01, 0x28, 0x03, 0x52, 0x08, 0x64, 0x65, 0x76, 0x69, 0x63, 0x65, 0x49, 0x64, 0x12,
  164. 0x14, 0x0a, 0x05, 0x74, 0x6f, 0x6b, 0x65, 0x6e, 0x18, 0x03, 0x20, 0x01, 0x28, 0x09, 0x52, 0x05,
  165. 0x74, 0x6f, 0x6b, 0x65, 0x6e, 0x22, 0x82, 0x01, 0x0a, 0x0b, 0x47, 0x65, 0x74, 0x55, 0x73, 0x65,
  166. 0x72, 0x73, 0x52, 0x65, 0x71, 0x12, 0x37, 0x0a, 0x08, 0x75, 0x73, 0x65, 0x72, 0x5f, 0x69, 0x64,
  167. 0x73, 0x18, 0x01, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x1c, 0x2e, 0x70, 0x62, 0x2e, 0x47, 0x65, 0x74,
  168. 0x55, 0x73, 0x65, 0x72, 0x73, 0x52, 0x65, 0x71, 0x2e, 0x55, 0x73, 0x65, 0x72, 0x49, 0x64, 0x73,
  169. 0x45, 0x6e, 0x74, 0x72, 0x79, 0x52, 0x07, 0x75, 0x73, 0x65, 0x72, 0x49, 0x64, 0x73, 0x1a, 0x3a,
  170. 0x0a, 0x0c, 0x55, 0x73, 0x65, 0x72, 0x49, 0x64, 0x73, 0x45, 0x6e, 0x74, 0x72, 0x79, 0x12, 0x10,
  171. 0x0a, 0x03, 0x6b, 0x65, 0x79, 0x18, 0x01, 0x20, 0x01, 0x28, 0x03, 0x52, 0x03, 0x6b, 0x65, 0x79,
  172. 0x12, 0x14, 0x0a, 0x05, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x05, 0x52,
  173. 0x05, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x3a, 0x02, 0x38, 0x01, 0x22, 0x85, 0x01, 0x0a, 0x0c, 0x47,
  174. 0x65, 0x74, 0x55, 0x73, 0x65, 0x72, 0x73, 0x52, 0x65, 0x73, 0x70, 0x12, 0x31, 0x0a, 0x05, 0x75,
  175. 0x73, 0x65, 0x72, 0x73, 0x18, 0x01, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x1b, 0x2e, 0x70, 0x62, 0x2e,
  176. 0x47, 0x65, 0x74, 0x55, 0x73, 0x65, 0x72, 0x73, 0x52, 0x65, 0x73, 0x70, 0x2e, 0x55, 0x73, 0x65,
  177. 0x72, 0x73, 0x45, 0x6e, 0x74, 0x72, 0x79, 0x52, 0x05, 0x75, 0x73, 0x65, 0x72, 0x73, 0x1a, 0x42,
  178. 0x0a, 0x0a, 0x55, 0x73, 0x65, 0x72, 0x73, 0x45, 0x6e, 0x74, 0x72, 0x79, 0x12, 0x10, 0x0a, 0x03,
  179. 0x6b, 0x65, 0x79, 0x18, 0x01, 0x20, 0x01, 0x28, 0x03, 0x52, 0x03, 0x6b, 0x65, 0x79, 0x12, 0x1e,
  180. 0x0a, 0x05, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x08, 0x2e,
  181. 0x70, 0x62, 0x2e, 0x55, 0x73, 0x65, 0x72, 0x52, 0x05, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x3a, 0x02,
  182. 0x38, 0x01, 0x32, 0x88, 0x01, 0x0a, 0x0b, 0x42, 0x75, 0x73, 0x69, 0x6e, 0x65, 0x73, 0x73, 0x49,
  183. 0x6e, 0x74, 0x12, 0x1e, 0x0a, 0x04, 0x41, 0x75, 0x74, 0x68, 0x12, 0x0b, 0x2e, 0x70, 0x62, 0x2e,
  184. 0x41, 0x75, 0x74, 0x68, 0x52, 0x65, 0x71, 0x1a, 0x09, 0x2e, 0x70, 0x62, 0x2e, 0x45, 0x6d, 0x70,
  185. 0x74, 0x79, 0x12, 0x2a, 0x0a, 0x07, 0x47, 0x65, 0x74, 0x55, 0x73, 0x65, 0x72, 0x12, 0x0e, 0x2e,
  186. 0x70, 0x62, 0x2e, 0x47, 0x65, 0x74, 0x55, 0x73, 0x65, 0x72, 0x52, 0x65, 0x71, 0x1a, 0x0f, 0x2e,
  187. 0x70, 0x62, 0x2e, 0x47, 0x65, 0x74, 0x55, 0x73, 0x65, 0x72, 0x52, 0x65, 0x73, 0x70, 0x12, 0x2d,
  188. 0x0a, 0x08, 0x47, 0x65, 0x74, 0x55, 0x73, 0x65, 0x72, 0x73, 0x12, 0x0f, 0x2e, 0x70, 0x62, 0x2e,
  189. 0x47, 0x65, 0x74, 0x55, 0x73, 0x65, 0x72, 0x73, 0x52, 0x65, 0x71, 0x1a, 0x10, 0x2e, 0x70, 0x62,
  190. 0x2e, 0x47, 0x65, 0x74, 0x55, 0x73, 0x65, 0x72, 0x73, 0x52, 0x65, 0x73, 0x70, 0x42, 0x0d, 0x5a,
  191. 0x0b, 0x67, 0x69, 0x6d, 0x2f, 0x70, 0x6b, 0x67, 0x2f, 0x70, 0x62, 0x2f, 0x62, 0x06, 0x70, 0x72,
  192. 0x6f, 0x74, 0x6f, 0x33,
  193. }
  194. var (
  195. file_business_int_proto_rawDescOnce sync.Once
  196. file_business_int_proto_rawDescData = file_business_int_proto_rawDesc
  197. )
  198. func file_business_int_proto_rawDescGZIP() []byte {
  199. file_business_int_proto_rawDescOnce.Do(func() {
  200. file_business_int_proto_rawDescData = protoimpl.X.CompressGZIP(file_business_int_proto_rawDescData)
  201. })
  202. return file_business_int_proto_rawDescData
  203. }
  204. var file_business_int_proto_msgTypes = make([]protoimpl.MessageInfo, 5)
  205. var file_business_int_proto_goTypes = []interface{}{
  206. (*AuthReq)(nil), // 0: pb.AuthReq
  207. (*GetUsersReq)(nil), // 1: pb.GetUsersReq
  208. (*GetUsersResp)(nil), // 2: pb.GetUsersResp
  209. nil, // 3: pb.GetUsersReq.UserIdsEntry
  210. nil, // 4: pb.GetUsersResp.UsersEntry
  211. (*User)(nil), // 5: pb.User
  212. (*GetUserReq)(nil), // 6: pb.GetUserReq
  213. (*Empty)(nil), // 7: pb.Empty
  214. (*GetUserResp)(nil), // 8: pb.GetUserResp
  215. }
  216. var file_business_int_proto_depIdxs = []int32{
  217. 3, // 0: pb.GetUsersReq.user_ids:type_name -> pb.GetUsersReq.UserIdsEntry
  218. 4, // 1: pb.GetUsersResp.users:type_name -> pb.GetUsersResp.UsersEntry
  219. 5, // 2: pb.GetUsersResp.UsersEntry.value:type_name -> pb.User
  220. 0, // 3: pb.BusinessInt.Auth:input_type -> pb.AuthReq
  221. 6, // 4: pb.BusinessInt.GetUser:input_type -> pb.GetUserReq
  222. 1, // 5: pb.BusinessInt.GetUsers:input_type -> pb.GetUsersReq
  223. 7, // 6: pb.BusinessInt.Auth:output_type -> pb.Empty
  224. 8, // 7: pb.BusinessInt.GetUser:output_type -> pb.GetUserResp
  225. 2, // 8: pb.BusinessInt.GetUsers:output_type -> pb.GetUsersResp
  226. 6, // [6:9] is the sub-list for method output_type
  227. 3, // [3:6] is the sub-list for method input_type
  228. 3, // [3:3] is the sub-list for extension type_name
  229. 3, // [3:3] is the sub-list for extension extendee
  230. 0, // [0:3] is the sub-list for field type_name
  231. }
  232. func init() { file_business_int_proto_init() }
  233. func file_business_int_proto_init() {
  234. if File_business_int_proto != nil {
  235. return
  236. }
  237. file_common_ext_proto_init()
  238. file_business_ext_proto_init()
  239. if !protoimpl.UnsafeEnabled {
  240. file_business_int_proto_msgTypes[0].Exporter = func(v interface{}, i int) interface{} {
  241. switch v := v.(*AuthReq); i {
  242. case 0:
  243. return &v.state
  244. case 1:
  245. return &v.sizeCache
  246. case 2:
  247. return &v.unknownFields
  248. default:
  249. return nil
  250. }
  251. }
  252. file_business_int_proto_msgTypes[1].Exporter = func(v interface{}, i int) interface{} {
  253. switch v := v.(*GetUsersReq); i {
  254. case 0:
  255. return &v.state
  256. case 1:
  257. return &v.sizeCache
  258. case 2:
  259. return &v.unknownFields
  260. default:
  261. return nil
  262. }
  263. }
  264. file_business_int_proto_msgTypes[2].Exporter = func(v interface{}, i int) interface{} {
  265. switch v := v.(*GetUsersResp); i {
  266. case 0:
  267. return &v.state
  268. case 1:
  269. return &v.sizeCache
  270. case 2:
  271. return &v.unknownFields
  272. default:
  273. return nil
  274. }
  275. }
  276. }
  277. type x struct{}
  278. out := protoimpl.TypeBuilder{
  279. File: protoimpl.DescBuilder{
  280. GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
  281. RawDescriptor: file_business_int_proto_rawDesc,
  282. NumEnums: 0,
  283. NumMessages: 5,
  284. NumExtensions: 0,
  285. NumServices: 1,
  286. },
  287. GoTypes: file_business_int_proto_goTypes,
  288. DependencyIndexes: file_business_int_proto_depIdxs,
  289. MessageInfos: file_business_int_proto_msgTypes,
  290. }.Build()
  291. File_business_int_proto = out.File
  292. file_business_int_proto_rawDesc = nil
  293. file_business_int_proto_goTypes = nil
  294. file_business_int_proto_depIdxs = nil
  295. }
  296. // This is a compile-time assertion to ensure that this generated file
  297. // is compatible with the grpc package it is being compiled against.
  298. // Requires gRPC-Go v1.32.0 or later.
  299. const _ = grpc.SupportPackageIsVersion7
  300. // BusinessIntClient is the client API for BusinessInt service.
  301. //
  302. // For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
  303. type BusinessIntClient interface {
  304. // 权限校验
  305. Auth(ctx context.Context, in *AuthReq, opts ...grpc.CallOption) (*Empty, error)
  306. // 批量获取用户信息
  307. GetUser(ctx context.Context, in *GetUserReq, opts ...grpc.CallOption) (*GetUserResp, error)
  308. // 批量获取用户信息
  309. GetUsers(ctx context.Context, in *GetUsersReq, opts ...grpc.CallOption) (*GetUsersResp, error)
  310. }
  311. type businessIntClient struct {
  312. cc grpc.ClientConnInterface
  313. }
  314. func NewBusinessIntClient(cc grpc.ClientConnInterface) BusinessIntClient {
  315. return &businessIntClient{cc}
  316. }
  317. func (c *businessIntClient) Auth(ctx context.Context, in *AuthReq, opts ...grpc.CallOption) (*Empty, error) {
  318. out := new(Empty)
  319. err := c.cc.Invoke(ctx, "/pb.BusinessInt/Auth", in, out, opts...)
  320. if err != nil {
  321. return nil, err
  322. }
  323. return out, nil
  324. }
  325. func (c *businessIntClient) GetUser(ctx context.Context, in *GetUserReq, opts ...grpc.CallOption) (*GetUserResp, error) {
  326. out := new(GetUserResp)
  327. err := c.cc.Invoke(ctx, "/pb.BusinessInt/GetUser", in, out, opts...)
  328. if err != nil {
  329. return nil, err
  330. }
  331. return out, nil
  332. }
  333. func (c *businessIntClient) GetUsers(ctx context.Context, in *GetUsersReq, opts ...grpc.CallOption) (*GetUsersResp, error) {
  334. out := new(GetUsersResp)
  335. err := c.cc.Invoke(ctx, "/pb.BusinessInt/GetUsers", in, out, opts...)
  336. if err != nil {
  337. return nil, err
  338. }
  339. return out, nil
  340. }
  341. // BusinessIntServer is the server API for BusinessInt service.
  342. // All implementations must embed UnimplementedBusinessIntServer
  343. // for forward compatibility
  344. type BusinessIntServer interface {
  345. // 权限校验
  346. Auth(context.Context, *AuthReq) (*Empty, error)
  347. // 批量获取用户信息
  348. GetUser(context.Context, *GetUserReq) (*GetUserResp, error)
  349. // 批量获取用户信息
  350. GetUsers(context.Context, *GetUsersReq) (*GetUsersResp, error)
  351. }
  352. // UnimplementedBusinessIntServer must be embedded to have forward compatible implementations.
  353. type UnimplementedBusinessIntServer struct {
  354. }
  355. func (UnimplementedBusinessIntServer) Auth(context.Context, *AuthReq) (*Empty, error) {
  356. return nil, status.Errorf(codes.Unimplemented, "method Auth not implemented")
  357. }
  358. func (UnimplementedBusinessIntServer) GetUser(context.Context, *GetUserReq) (*GetUserResp, error) {
  359. return nil, status.Errorf(codes.Unimplemented, "method GetUser not implemented")
  360. }
  361. func (UnimplementedBusinessIntServer) GetUsers(context.Context, *GetUsersReq) (*GetUsersResp, error) {
  362. return nil, status.Errorf(codes.Unimplemented, "method GetUsers not implemented")
  363. }
  364. func RegisterBusinessIntServer(s grpc.ServiceRegistrar, srv BusinessIntServer) {
  365. s.RegisterService(&BusinessInt_ServiceDesc, srv)
  366. }
  367. func _BusinessInt_Auth_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  368. in := new(AuthReq)
  369. if err := dec(in); err != nil {
  370. return nil, err
  371. }
  372. if interceptor == nil {
  373. return srv.(BusinessIntServer).Auth(ctx, in)
  374. }
  375. info := &grpc.UnaryServerInfo{
  376. Server: srv,
  377. FullMethod: "/pb.BusinessInt/Auth",
  378. }
  379. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  380. return srv.(BusinessIntServer).Auth(ctx, req.(*AuthReq))
  381. }
  382. return interceptor(ctx, in, info, handler)
  383. }
  384. func _BusinessInt_GetUser_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  385. in := new(GetUserReq)
  386. if err := dec(in); err != nil {
  387. return nil, err
  388. }
  389. if interceptor == nil {
  390. return srv.(BusinessIntServer).GetUser(ctx, in)
  391. }
  392. info := &grpc.UnaryServerInfo{
  393. Server: srv,
  394. FullMethod: "/pb.BusinessInt/GetUser",
  395. }
  396. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  397. return srv.(BusinessIntServer).GetUser(ctx, req.(*GetUserReq))
  398. }
  399. return interceptor(ctx, in, info, handler)
  400. }
  401. func _BusinessInt_GetUsers_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  402. in := new(GetUsersReq)
  403. if err := dec(in); err != nil {
  404. return nil, err
  405. }
  406. if interceptor == nil {
  407. return srv.(BusinessIntServer).GetUsers(ctx, in)
  408. }
  409. info := &grpc.UnaryServerInfo{
  410. Server: srv,
  411. FullMethod: "/pb.BusinessInt/GetUsers",
  412. }
  413. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  414. return srv.(BusinessIntServer).GetUsers(ctx, req.(*GetUsersReq))
  415. }
  416. return interceptor(ctx, in, info, handler)
  417. }
  418. // BusinessInt_ServiceDesc is the grpc.ServiceDesc for BusinessInt service.
  419. // It's only intended for direct use with grpc.RegisterService,
  420. // and not to be introspected or modified (even as a copy)
  421. var BusinessInt_ServiceDesc = grpc.ServiceDesc{
  422. ServiceName: "pb.BusinessInt",
  423. HandlerType: (*BusinessIntServer)(nil),
  424. Methods: []grpc.MethodDesc{
  425. {
  426. MethodName: "Auth",
  427. Handler: _BusinessInt_Auth_Handler,
  428. },
  429. {
  430. MethodName: "GetUser",
  431. Handler: _BusinessInt_GetUser_Handler,
  432. },
  433. {
  434. MethodName: "GetUsers",
  435. Handler: _BusinessInt_GetUsers_Handler,
  436. },
  437. },
  438. Streams: []grpc.StreamDesc{},
  439. Metadata: "business.int.proto",
  440. }