You can not select more than 25 topics Topics must start with a chinese character,a letter or number, can include dashes ('-') and can be up to 35 characters long.

Services_grpc.pb.go 29 kB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785
  1. // Code generated by protoc-gen-go-grpc. DO NOT EDIT.
  2. // versions:
  3. // - protoc-gen-go-grpc v1.2.0
  4. // - protoc (unknown)
  5. // source: Services.proto
  6. package proto
  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. )
  13. // This is a compile-time assertion to ensure that this generated file
  14. // is compatible with the grpc package it is being compiled against.
  15. // Requires gRPC-Go v1.32.0 or later.
  16. const _ = grpc.SupportPackageIsVersion7
  17. // AvailableServiceClient is the client API for AvailableService service.
  18. //
  19. // 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.
  20. type AvailableServiceClient interface {
  21. TryConnection(ctx context.Context, in *IDMsg, opts ...grpc.CallOption) (*BoolRes, error)
  22. // 游戏开局调用一次的服务
  23. AddPlayer(ctx context.Context, in *PlayerMsg, opts ...grpc.CallOption) (AvailableService_AddPlayerClient, error)
  24. // 游戏过程中玩家执行操作的服务
  25. Move(ctx context.Context, in *MoveMsg, opts ...grpc.CallOption) (*MoveRes, error)
  26. PickProp(ctx context.Context, in *PropMsg, opts ...grpc.CallOption) (*BoolRes, error)
  27. UseProp(ctx context.Context, in *PropMsg, opts ...grpc.CallOption) (*BoolRes, error)
  28. ThrowProp(ctx context.Context, in *PropMsg, opts ...grpc.CallOption) (*BoolRes, error)
  29. UseSkill(ctx context.Context, in *SkillMsg, opts ...grpc.CallOption) (*BoolRes, error)
  30. SendMessage(ctx context.Context, in *SendMsg, opts ...grpc.CallOption) (*BoolRes, error)
  31. // rpc GetMessage (IDMsg) returns (stream MsgRes);
  32. StartLearning(ctx context.Context, in *IDMsg, opts ...grpc.CallOption) (*BoolRes, error)
  33. StartRescueMate(ctx context.Context, in *TreatAndRescueMsg, opts ...grpc.CallOption) (*BoolRes, error)
  34. StartTreatMate(ctx context.Context, in *TreatAndRescueMsg, opts ...grpc.CallOption) (*BoolRes, error)
  35. Attack(ctx context.Context, in *AttackMsg, opts ...grpc.CallOption) (*BoolRes, error)
  36. Graduate(ctx context.Context, in *IDMsg, opts ...grpc.CallOption) (*BoolRes, error)
  37. OpenDoor(ctx context.Context, in *IDMsg, opts ...grpc.CallOption) (*BoolRes, error)
  38. CloseDoor(ctx context.Context, in *IDMsg, opts ...grpc.CallOption) (*BoolRes, error)
  39. SkipWindow(ctx context.Context, in *IDMsg, opts ...grpc.CallOption) (*BoolRes, error)
  40. StartOpenGate(ctx context.Context, in *IDMsg, opts ...grpc.CallOption) (*BoolRes, error)
  41. StartOpenChest(ctx context.Context, in *IDMsg, opts ...grpc.CallOption) (*BoolRes, error)
  42. EndAllAction(ctx context.Context, in *IDMsg, opts ...grpc.CallOption) (*BoolRes, error)
  43. }
  44. type availableServiceClient struct {
  45. cc grpc.ClientConnInterface
  46. }
  47. func NewAvailableServiceClient(cc grpc.ClientConnInterface) AvailableServiceClient {
  48. return &availableServiceClient{cc}
  49. }
  50. func (c *availableServiceClient) TryConnection(ctx context.Context, in *IDMsg, opts ...grpc.CallOption) (*BoolRes, error) {
  51. out := new(BoolRes)
  52. err := c.cc.Invoke(ctx, "/protobuf.AvailableService/TryConnection", in, out, opts...)
  53. if err != nil {
  54. return nil, err
  55. }
  56. return out, nil
  57. }
  58. func (c *availableServiceClient) AddPlayer(ctx context.Context, in *PlayerMsg, opts ...grpc.CallOption) (AvailableService_AddPlayerClient, error) {
  59. stream, err := c.cc.NewStream(ctx, &AvailableService_ServiceDesc.Streams[0], "/protobuf.AvailableService/AddPlayer", opts...)
  60. if err != nil {
  61. return nil, err
  62. }
  63. x := &availableServiceAddPlayerClient{stream}
  64. if err := x.ClientStream.SendMsg(in); err != nil {
  65. return nil, err
  66. }
  67. if err := x.ClientStream.CloseSend(); err != nil {
  68. return nil, err
  69. }
  70. return x, nil
  71. }
  72. type AvailableService_AddPlayerClient interface {
  73. Recv() (*MessageToClient, error)
  74. grpc.ClientStream
  75. }
  76. type availableServiceAddPlayerClient struct {
  77. grpc.ClientStream
  78. }
  79. func (x *availableServiceAddPlayerClient) Recv() (*MessageToClient, error) {
  80. m := new(MessageToClient)
  81. if err := x.ClientStream.RecvMsg(m); err != nil {
  82. return nil, err
  83. }
  84. return m, nil
  85. }
  86. func (c *availableServiceClient) Move(ctx context.Context, in *MoveMsg, opts ...grpc.CallOption) (*MoveRes, error) {
  87. out := new(MoveRes)
  88. err := c.cc.Invoke(ctx, "/protobuf.AvailableService/Move", in, out, opts...)
  89. if err != nil {
  90. return nil, err
  91. }
  92. return out, nil
  93. }
  94. func (c *availableServiceClient) PickProp(ctx context.Context, in *PropMsg, opts ...grpc.CallOption) (*BoolRes, error) {
  95. out := new(BoolRes)
  96. err := c.cc.Invoke(ctx, "/protobuf.AvailableService/PickProp", in, out, opts...)
  97. if err != nil {
  98. return nil, err
  99. }
  100. return out, nil
  101. }
  102. func (c *availableServiceClient) UseProp(ctx context.Context, in *PropMsg, opts ...grpc.CallOption) (*BoolRes, error) {
  103. out := new(BoolRes)
  104. err := c.cc.Invoke(ctx, "/protobuf.AvailableService/UseProp", in, out, opts...)
  105. if err != nil {
  106. return nil, err
  107. }
  108. return out, nil
  109. }
  110. func (c *availableServiceClient) ThrowProp(ctx context.Context, in *PropMsg, opts ...grpc.CallOption) (*BoolRes, error) {
  111. out := new(BoolRes)
  112. err := c.cc.Invoke(ctx, "/protobuf.AvailableService/ThrowProp", in, out, opts...)
  113. if err != nil {
  114. return nil, err
  115. }
  116. return out, nil
  117. }
  118. func (c *availableServiceClient) UseSkill(ctx context.Context, in *SkillMsg, opts ...grpc.CallOption) (*BoolRes, error) {
  119. out := new(BoolRes)
  120. err := c.cc.Invoke(ctx, "/protobuf.AvailableService/UseSkill", in, out, opts...)
  121. if err != nil {
  122. return nil, err
  123. }
  124. return out, nil
  125. }
  126. func (c *availableServiceClient) SendMessage(ctx context.Context, in *SendMsg, opts ...grpc.CallOption) (*BoolRes, error) {
  127. out := new(BoolRes)
  128. err := c.cc.Invoke(ctx, "/protobuf.AvailableService/SendMessage", in, out, opts...)
  129. if err != nil {
  130. return nil, err
  131. }
  132. return out, nil
  133. }
  134. func (c *availableServiceClient) StartLearning(ctx context.Context, in *IDMsg, opts ...grpc.CallOption) (*BoolRes, error) {
  135. out := new(BoolRes)
  136. err := c.cc.Invoke(ctx, "/protobuf.AvailableService/StartLearning", in, out, opts...)
  137. if err != nil {
  138. return nil, err
  139. }
  140. return out, nil
  141. }
  142. func (c *availableServiceClient) StartRescueMate(ctx context.Context, in *TreatAndRescueMsg, opts ...grpc.CallOption) (*BoolRes, error) {
  143. out := new(BoolRes)
  144. err := c.cc.Invoke(ctx, "/protobuf.AvailableService/StartRescueMate", in, out, opts...)
  145. if err != nil {
  146. return nil, err
  147. }
  148. return out, nil
  149. }
  150. func (c *availableServiceClient) StartTreatMate(ctx context.Context, in *TreatAndRescueMsg, opts ...grpc.CallOption) (*BoolRes, error) {
  151. out := new(BoolRes)
  152. err := c.cc.Invoke(ctx, "/protobuf.AvailableService/StartTreatMate", in, out, opts...)
  153. if err != nil {
  154. return nil, err
  155. }
  156. return out, nil
  157. }
  158. func (c *availableServiceClient) Attack(ctx context.Context, in *AttackMsg, opts ...grpc.CallOption) (*BoolRes, error) {
  159. out := new(BoolRes)
  160. err := c.cc.Invoke(ctx, "/protobuf.AvailableService/Attack", in, out, opts...)
  161. if err != nil {
  162. return nil, err
  163. }
  164. return out, nil
  165. }
  166. func (c *availableServiceClient) Graduate(ctx context.Context, in *IDMsg, opts ...grpc.CallOption) (*BoolRes, error) {
  167. out := new(BoolRes)
  168. err := c.cc.Invoke(ctx, "/protobuf.AvailableService/Graduate", in, out, opts...)
  169. if err != nil {
  170. return nil, err
  171. }
  172. return out, nil
  173. }
  174. func (c *availableServiceClient) OpenDoor(ctx context.Context, in *IDMsg, opts ...grpc.CallOption) (*BoolRes, error) {
  175. out := new(BoolRes)
  176. err := c.cc.Invoke(ctx, "/protobuf.AvailableService/OpenDoor", in, out, opts...)
  177. if err != nil {
  178. return nil, err
  179. }
  180. return out, nil
  181. }
  182. func (c *availableServiceClient) CloseDoor(ctx context.Context, in *IDMsg, opts ...grpc.CallOption) (*BoolRes, error) {
  183. out := new(BoolRes)
  184. err := c.cc.Invoke(ctx, "/protobuf.AvailableService/CloseDoor", in, out, opts...)
  185. if err != nil {
  186. return nil, err
  187. }
  188. return out, nil
  189. }
  190. func (c *availableServiceClient) SkipWindow(ctx context.Context, in *IDMsg, opts ...grpc.CallOption) (*BoolRes, error) {
  191. out := new(BoolRes)
  192. err := c.cc.Invoke(ctx, "/protobuf.AvailableService/SkipWindow", in, out, opts...)
  193. if err != nil {
  194. return nil, err
  195. }
  196. return out, nil
  197. }
  198. func (c *availableServiceClient) StartOpenGate(ctx context.Context, in *IDMsg, opts ...grpc.CallOption) (*BoolRes, error) {
  199. out := new(BoolRes)
  200. err := c.cc.Invoke(ctx, "/protobuf.AvailableService/StartOpenGate", in, out, opts...)
  201. if err != nil {
  202. return nil, err
  203. }
  204. return out, nil
  205. }
  206. func (c *availableServiceClient) StartOpenChest(ctx context.Context, in *IDMsg, opts ...grpc.CallOption) (*BoolRes, error) {
  207. out := new(BoolRes)
  208. err := c.cc.Invoke(ctx, "/protobuf.AvailableService/StartOpenChest", in, out, opts...)
  209. if err != nil {
  210. return nil, err
  211. }
  212. return out, nil
  213. }
  214. func (c *availableServiceClient) EndAllAction(ctx context.Context, in *IDMsg, opts ...grpc.CallOption) (*BoolRes, error) {
  215. out := new(BoolRes)
  216. err := c.cc.Invoke(ctx, "/protobuf.AvailableService/EndAllAction", in, out, opts...)
  217. if err != nil {
  218. return nil, err
  219. }
  220. return out, nil
  221. }
  222. // AvailableServiceServer is the server API for AvailableService service.
  223. // All implementations should embed UnimplementedAvailableServiceServer
  224. // for forward compatibility
  225. type AvailableServiceServer interface {
  226. TryConnection(context.Context, *IDMsg) (*BoolRes, error)
  227. // 游戏开局调用一次的服务
  228. AddPlayer(*PlayerMsg, AvailableService_AddPlayerServer) error
  229. // 游戏过程中玩家执行操作的服务
  230. Move(context.Context, *MoveMsg) (*MoveRes, error)
  231. PickProp(context.Context, *PropMsg) (*BoolRes, error)
  232. UseProp(context.Context, *PropMsg) (*BoolRes, error)
  233. ThrowProp(context.Context, *PropMsg) (*BoolRes, error)
  234. UseSkill(context.Context, *SkillMsg) (*BoolRes, error)
  235. SendMessage(context.Context, *SendMsg) (*BoolRes, error)
  236. // rpc GetMessage (IDMsg) returns (stream MsgRes);
  237. StartLearning(context.Context, *IDMsg) (*BoolRes, error)
  238. StartRescueMate(context.Context, *TreatAndRescueMsg) (*BoolRes, error)
  239. StartTreatMate(context.Context, *TreatAndRescueMsg) (*BoolRes, error)
  240. Attack(context.Context, *AttackMsg) (*BoolRes, error)
  241. Graduate(context.Context, *IDMsg) (*BoolRes, error)
  242. OpenDoor(context.Context, *IDMsg) (*BoolRes, error)
  243. CloseDoor(context.Context, *IDMsg) (*BoolRes, error)
  244. SkipWindow(context.Context, *IDMsg) (*BoolRes, error)
  245. StartOpenGate(context.Context, *IDMsg) (*BoolRes, error)
  246. StartOpenChest(context.Context, *IDMsg) (*BoolRes, error)
  247. EndAllAction(context.Context, *IDMsg) (*BoolRes, error)
  248. }
  249. // UnimplementedAvailableServiceServer should be embedded to have forward compatible implementations.
  250. type UnimplementedAvailableServiceServer struct {
  251. }
  252. func (UnimplementedAvailableServiceServer) TryConnection(context.Context, *IDMsg) (*BoolRes, error) {
  253. return nil, status.Errorf(codes.Unimplemented, "method TryConnection not implemented")
  254. }
  255. func (UnimplementedAvailableServiceServer) AddPlayer(*PlayerMsg, AvailableService_AddPlayerServer) error {
  256. return status.Errorf(codes.Unimplemented, "method AddPlayer not implemented")
  257. }
  258. func (UnimplementedAvailableServiceServer) Move(context.Context, *MoveMsg) (*MoveRes, error) {
  259. return nil, status.Errorf(codes.Unimplemented, "method Move not implemented")
  260. }
  261. func (UnimplementedAvailableServiceServer) PickProp(context.Context, *PropMsg) (*BoolRes, error) {
  262. return nil, status.Errorf(codes.Unimplemented, "method PickProp not implemented")
  263. }
  264. func (UnimplementedAvailableServiceServer) UseProp(context.Context, *PropMsg) (*BoolRes, error) {
  265. return nil, status.Errorf(codes.Unimplemented, "method UseProp not implemented")
  266. }
  267. func (UnimplementedAvailableServiceServer) ThrowProp(context.Context, *PropMsg) (*BoolRes, error) {
  268. return nil, status.Errorf(codes.Unimplemented, "method ThrowProp not implemented")
  269. }
  270. func (UnimplementedAvailableServiceServer) UseSkill(context.Context, *SkillMsg) (*BoolRes, error) {
  271. return nil, status.Errorf(codes.Unimplemented, "method UseSkill not implemented")
  272. }
  273. func (UnimplementedAvailableServiceServer) SendMessage(context.Context, *SendMsg) (*BoolRes, error) {
  274. return nil, status.Errorf(codes.Unimplemented, "method SendMessage not implemented")
  275. }
  276. func (UnimplementedAvailableServiceServer) StartLearning(context.Context, *IDMsg) (*BoolRes, error) {
  277. return nil, status.Errorf(codes.Unimplemented, "method StartLearning not implemented")
  278. }
  279. func (UnimplementedAvailableServiceServer) StartRescueMate(context.Context, *TreatAndRescueMsg) (*BoolRes, error) {
  280. return nil, status.Errorf(codes.Unimplemented, "method StartRescueMate not implemented")
  281. }
  282. func (UnimplementedAvailableServiceServer) StartTreatMate(context.Context, *TreatAndRescueMsg) (*BoolRes, error) {
  283. return nil, status.Errorf(codes.Unimplemented, "method StartTreatMate not implemented")
  284. }
  285. func (UnimplementedAvailableServiceServer) Attack(context.Context, *AttackMsg) (*BoolRes, error) {
  286. return nil, status.Errorf(codes.Unimplemented, "method Attack not implemented")
  287. }
  288. func (UnimplementedAvailableServiceServer) Graduate(context.Context, *IDMsg) (*BoolRes, error) {
  289. return nil, status.Errorf(codes.Unimplemented, "method Graduate not implemented")
  290. }
  291. func (UnimplementedAvailableServiceServer) OpenDoor(context.Context, *IDMsg) (*BoolRes, error) {
  292. return nil, status.Errorf(codes.Unimplemented, "method OpenDoor not implemented")
  293. }
  294. func (UnimplementedAvailableServiceServer) CloseDoor(context.Context, *IDMsg) (*BoolRes, error) {
  295. return nil, status.Errorf(codes.Unimplemented, "method CloseDoor not implemented")
  296. }
  297. func (UnimplementedAvailableServiceServer) SkipWindow(context.Context, *IDMsg) (*BoolRes, error) {
  298. return nil, status.Errorf(codes.Unimplemented, "method SkipWindow not implemented")
  299. }
  300. func (UnimplementedAvailableServiceServer) StartOpenGate(context.Context, *IDMsg) (*BoolRes, error) {
  301. return nil, status.Errorf(codes.Unimplemented, "method StartOpenGate not implemented")
  302. }
  303. func (UnimplementedAvailableServiceServer) StartOpenChest(context.Context, *IDMsg) (*BoolRes, error) {
  304. return nil, status.Errorf(codes.Unimplemented, "method StartOpenChest not implemented")
  305. }
  306. func (UnimplementedAvailableServiceServer) EndAllAction(context.Context, *IDMsg) (*BoolRes, error) {
  307. return nil, status.Errorf(codes.Unimplemented, "method EndAllAction not implemented")
  308. }
  309. // UnsafeAvailableServiceServer may be embedded to opt out of forward compatibility for this service.
  310. // Use of this interface is not recommended, as added methods to AvailableServiceServer will
  311. // result in compilation errors.
  312. type UnsafeAvailableServiceServer interface {
  313. mustEmbedUnimplementedAvailableServiceServer()
  314. }
  315. func RegisterAvailableServiceServer(s grpc.ServiceRegistrar, srv AvailableServiceServer) {
  316. s.RegisterService(&AvailableService_ServiceDesc, srv)
  317. }
  318. func _AvailableService_TryConnection_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  319. in := new(IDMsg)
  320. if err := dec(in); err != nil {
  321. return nil, err
  322. }
  323. if interceptor == nil {
  324. return srv.(AvailableServiceServer).TryConnection(ctx, in)
  325. }
  326. info := &grpc.UnaryServerInfo{
  327. Server: srv,
  328. FullMethod: "/protobuf.AvailableService/TryConnection",
  329. }
  330. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  331. return srv.(AvailableServiceServer).TryConnection(ctx, req.(*IDMsg))
  332. }
  333. return interceptor(ctx, in, info, handler)
  334. }
  335. func _AvailableService_AddPlayer_Handler(srv interface{}, stream grpc.ServerStream) error {
  336. m := new(PlayerMsg)
  337. if err := stream.RecvMsg(m); err != nil {
  338. return err
  339. }
  340. return srv.(AvailableServiceServer).AddPlayer(m, &availableServiceAddPlayerServer{stream})
  341. }
  342. type AvailableService_AddPlayerServer interface {
  343. Send(*MessageToClient) error
  344. grpc.ServerStream
  345. }
  346. type availableServiceAddPlayerServer struct {
  347. grpc.ServerStream
  348. }
  349. func (x *availableServiceAddPlayerServer) Send(m *MessageToClient) error {
  350. return x.ServerStream.SendMsg(m)
  351. }
  352. func _AvailableService_Move_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  353. in := new(MoveMsg)
  354. if err := dec(in); err != nil {
  355. return nil, err
  356. }
  357. if interceptor == nil {
  358. return srv.(AvailableServiceServer).Move(ctx, in)
  359. }
  360. info := &grpc.UnaryServerInfo{
  361. Server: srv,
  362. FullMethod: "/protobuf.AvailableService/Move",
  363. }
  364. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  365. return srv.(AvailableServiceServer).Move(ctx, req.(*MoveMsg))
  366. }
  367. return interceptor(ctx, in, info, handler)
  368. }
  369. func _AvailableService_PickProp_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  370. in := new(PropMsg)
  371. if err := dec(in); err != nil {
  372. return nil, err
  373. }
  374. if interceptor == nil {
  375. return srv.(AvailableServiceServer).PickProp(ctx, in)
  376. }
  377. info := &grpc.UnaryServerInfo{
  378. Server: srv,
  379. FullMethod: "/protobuf.AvailableService/PickProp",
  380. }
  381. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  382. return srv.(AvailableServiceServer).PickProp(ctx, req.(*PropMsg))
  383. }
  384. return interceptor(ctx, in, info, handler)
  385. }
  386. func _AvailableService_UseProp_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  387. in := new(PropMsg)
  388. if err := dec(in); err != nil {
  389. return nil, err
  390. }
  391. if interceptor == nil {
  392. return srv.(AvailableServiceServer).UseProp(ctx, in)
  393. }
  394. info := &grpc.UnaryServerInfo{
  395. Server: srv,
  396. FullMethod: "/protobuf.AvailableService/UseProp",
  397. }
  398. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  399. return srv.(AvailableServiceServer).UseProp(ctx, req.(*PropMsg))
  400. }
  401. return interceptor(ctx, in, info, handler)
  402. }
  403. func _AvailableService_ThrowProp_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  404. in := new(PropMsg)
  405. if err := dec(in); err != nil {
  406. return nil, err
  407. }
  408. if interceptor == nil {
  409. return srv.(AvailableServiceServer).ThrowProp(ctx, in)
  410. }
  411. info := &grpc.UnaryServerInfo{
  412. Server: srv,
  413. FullMethod: "/protobuf.AvailableService/ThrowProp",
  414. }
  415. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  416. return srv.(AvailableServiceServer).ThrowProp(ctx, req.(*PropMsg))
  417. }
  418. return interceptor(ctx, in, info, handler)
  419. }
  420. func _AvailableService_UseSkill_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  421. in := new(SkillMsg)
  422. if err := dec(in); err != nil {
  423. return nil, err
  424. }
  425. if interceptor == nil {
  426. return srv.(AvailableServiceServer).UseSkill(ctx, in)
  427. }
  428. info := &grpc.UnaryServerInfo{
  429. Server: srv,
  430. FullMethod: "/protobuf.AvailableService/UseSkill",
  431. }
  432. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  433. return srv.(AvailableServiceServer).UseSkill(ctx, req.(*SkillMsg))
  434. }
  435. return interceptor(ctx, in, info, handler)
  436. }
  437. func _AvailableService_SendMessage_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  438. in := new(SendMsg)
  439. if err := dec(in); err != nil {
  440. return nil, err
  441. }
  442. if interceptor == nil {
  443. return srv.(AvailableServiceServer).SendMessage(ctx, in)
  444. }
  445. info := &grpc.UnaryServerInfo{
  446. Server: srv,
  447. FullMethod: "/protobuf.AvailableService/SendMessage",
  448. }
  449. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  450. return srv.(AvailableServiceServer).SendMessage(ctx, req.(*SendMsg))
  451. }
  452. return interceptor(ctx, in, info, handler)
  453. }
  454. func _AvailableService_StartLearning_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  455. in := new(IDMsg)
  456. if err := dec(in); err != nil {
  457. return nil, err
  458. }
  459. if interceptor == nil {
  460. return srv.(AvailableServiceServer).StartLearning(ctx, in)
  461. }
  462. info := &grpc.UnaryServerInfo{
  463. Server: srv,
  464. FullMethod: "/protobuf.AvailableService/StartLearning",
  465. }
  466. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  467. return srv.(AvailableServiceServer).StartLearning(ctx, req.(*IDMsg))
  468. }
  469. return interceptor(ctx, in, info, handler)
  470. }
  471. func _AvailableService_StartRescueMate_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  472. in := new(TreatAndRescueMsg)
  473. if err := dec(in); err != nil {
  474. return nil, err
  475. }
  476. if interceptor == nil {
  477. return srv.(AvailableServiceServer).StartRescueMate(ctx, in)
  478. }
  479. info := &grpc.UnaryServerInfo{
  480. Server: srv,
  481. FullMethod: "/protobuf.AvailableService/StartRescueMate",
  482. }
  483. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  484. return srv.(AvailableServiceServer).StartRescueMate(ctx, req.(*TreatAndRescueMsg))
  485. }
  486. return interceptor(ctx, in, info, handler)
  487. }
  488. func _AvailableService_StartTreatMate_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  489. in := new(TreatAndRescueMsg)
  490. if err := dec(in); err != nil {
  491. return nil, err
  492. }
  493. if interceptor == nil {
  494. return srv.(AvailableServiceServer).StartTreatMate(ctx, in)
  495. }
  496. info := &grpc.UnaryServerInfo{
  497. Server: srv,
  498. FullMethod: "/protobuf.AvailableService/StartTreatMate",
  499. }
  500. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  501. return srv.(AvailableServiceServer).StartTreatMate(ctx, req.(*TreatAndRescueMsg))
  502. }
  503. return interceptor(ctx, in, info, handler)
  504. }
  505. func _AvailableService_Attack_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  506. in := new(AttackMsg)
  507. if err := dec(in); err != nil {
  508. return nil, err
  509. }
  510. if interceptor == nil {
  511. return srv.(AvailableServiceServer).Attack(ctx, in)
  512. }
  513. info := &grpc.UnaryServerInfo{
  514. Server: srv,
  515. FullMethod: "/protobuf.AvailableService/Attack",
  516. }
  517. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  518. return srv.(AvailableServiceServer).Attack(ctx, req.(*AttackMsg))
  519. }
  520. return interceptor(ctx, in, info, handler)
  521. }
  522. func _AvailableService_Graduate_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  523. in := new(IDMsg)
  524. if err := dec(in); err != nil {
  525. return nil, err
  526. }
  527. if interceptor == nil {
  528. return srv.(AvailableServiceServer).Graduate(ctx, in)
  529. }
  530. info := &grpc.UnaryServerInfo{
  531. Server: srv,
  532. FullMethod: "/protobuf.AvailableService/Graduate",
  533. }
  534. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  535. return srv.(AvailableServiceServer).Graduate(ctx, req.(*IDMsg))
  536. }
  537. return interceptor(ctx, in, info, handler)
  538. }
  539. func _AvailableService_OpenDoor_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  540. in := new(IDMsg)
  541. if err := dec(in); err != nil {
  542. return nil, err
  543. }
  544. if interceptor == nil {
  545. return srv.(AvailableServiceServer).OpenDoor(ctx, in)
  546. }
  547. info := &grpc.UnaryServerInfo{
  548. Server: srv,
  549. FullMethod: "/protobuf.AvailableService/OpenDoor",
  550. }
  551. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  552. return srv.(AvailableServiceServer).OpenDoor(ctx, req.(*IDMsg))
  553. }
  554. return interceptor(ctx, in, info, handler)
  555. }
  556. func _AvailableService_CloseDoor_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  557. in := new(IDMsg)
  558. if err := dec(in); err != nil {
  559. return nil, err
  560. }
  561. if interceptor == nil {
  562. return srv.(AvailableServiceServer).CloseDoor(ctx, in)
  563. }
  564. info := &grpc.UnaryServerInfo{
  565. Server: srv,
  566. FullMethod: "/protobuf.AvailableService/CloseDoor",
  567. }
  568. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  569. return srv.(AvailableServiceServer).CloseDoor(ctx, req.(*IDMsg))
  570. }
  571. return interceptor(ctx, in, info, handler)
  572. }
  573. func _AvailableService_SkipWindow_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  574. in := new(IDMsg)
  575. if err := dec(in); err != nil {
  576. return nil, err
  577. }
  578. if interceptor == nil {
  579. return srv.(AvailableServiceServer).SkipWindow(ctx, in)
  580. }
  581. info := &grpc.UnaryServerInfo{
  582. Server: srv,
  583. FullMethod: "/protobuf.AvailableService/SkipWindow",
  584. }
  585. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  586. return srv.(AvailableServiceServer).SkipWindow(ctx, req.(*IDMsg))
  587. }
  588. return interceptor(ctx, in, info, handler)
  589. }
  590. func _AvailableService_StartOpenGate_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  591. in := new(IDMsg)
  592. if err := dec(in); err != nil {
  593. return nil, err
  594. }
  595. if interceptor == nil {
  596. return srv.(AvailableServiceServer).StartOpenGate(ctx, in)
  597. }
  598. info := &grpc.UnaryServerInfo{
  599. Server: srv,
  600. FullMethod: "/protobuf.AvailableService/StartOpenGate",
  601. }
  602. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  603. return srv.(AvailableServiceServer).StartOpenGate(ctx, req.(*IDMsg))
  604. }
  605. return interceptor(ctx, in, info, handler)
  606. }
  607. func _AvailableService_StartOpenChest_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  608. in := new(IDMsg)
  609. if err := dec(in); err != nil {
  610. return nil, err
  611. }
  612. if interceptor == nil {
  613. return srv.(AvailableServiceServer).StartOpenChest(ctx, in)
  614. }
  615. info := &grpc.UnaryServerInfo{
  616. Server: srv,
  617. FullMethod: "/protobuf.AvailableService/StartOpenChest",
  618. }
  619. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  620. return srv.(AvailableServiceServer).StartOpenChest(ctx, req.(*IDMsg))
  621. }
  622. return interceptor(ctx, in, info, handler)
  623. }
  624. func _AvailableService_EndAllAction_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  625. in := new(IDMsg)
  626. if err := dec(in); err != nil {
  627. return nil, err
  628. }
  629. if interceptor == nil {
  630. return srv.(AvailableServiceServer).EndAllAction(ctx, in)
  631. }
  632. info := &grpc.UnaryServerInfo{
  633. Server: srv,
  634. FullMethod: "/protobuf.AvailableService/EndAllAction",
  635. }
  636. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  637. return srv.(AvailableServiceServer).EndAllAction(ctx, req.(*IDMsg))
  638. }
  639. return interceptor(ctx, in, info, handler)
  640. }
  641. // AvailableService_ServiceDesc is the grpc.ServiceDesc for AvailableService service.
  642. // It's only intended for direct use with grpc.RegisterService,
  643. // and not to be introspected or modified (even as a copy)
  644. var AvailableService_ServiceDesc = grpc.ServiceDesc{
  645. ServiceName: "protobuf.AvailableService",
  646. HandlerType: (*AvailableServiceServer)(nil),
  647. Methods: []grpc.MethodDesc{
  648. {
  649. MethodName: "TryConnection",
  650. Handler: _AvailableService_TryConnection_Handler,
  651. },
  652. {
  653. MethodName: "Move",
  654. Handler: _AvailableService_Move_Handler,
  655. },
  656. {
  657. MethodName: "PickProp",
  658. Handler: _AvailableService_PickProp_Handler,
  659. },
  660. {
  661. MethodName: "UseProp",
  662. Handler: _AvailableService_UseProp_Handler,
  663. },
  664. {
  665. MethodName: "ThrowProp",
  666. Handler: _AvailableService_ThrowProp_Handler,
  667. },
  668. {
  669. MethodName: "UseSkill",
  670. Handler: _AvailableService_UseSkill_Handler,
  671. },
  672. {
  673. MethodName: "SendMessage",
  674. Handler: _AvailableService_SendMessage_Handler,
  675. },
  676. {
  677. MethodName: "StartLearning",
  678. Handler: _AvailableService_StartLearning_Handler,
  679. },
  680. {
  681. MethodName: "StartRescueMate",
  682. Handler: _AvailableService_StartRescueMate_Handler,
  683. },
  684. {
  685. MethodName: "StartTreatMate",
  686. Handler: _AvailableService_StartTreatMate_Handler,
  687. },
  688. {
  689. MethodName: "Attack",
  690. Handler: _AvailableService_Attack_Handler,
  691. },
  692. {
  693. MethodName: "Graduate",
  694. Handler: _AvailableService_Graduate_Handler,
  695. },
  696. {
  697. MethodName: "OpenDoor",
  698. Handler: _AvailableService_OpenDoor_Handler,
  699. },
  700. {
  701. MethodName: "CloseDoor",
  702. Handler: _AvailableService_CloseDoor_Handler,
  703. },
  704. {
  705. MethodName: "SkipWindow",
  706. Handler: _AvailableService_SkipWindow_Handler,
  707. },
  708. {
  709. MethodName: "StartOpenGate",
  710. Handler: _AvailableService_StartOpenGate_Handler,
  711. },
  712. {
  713. MethodName: "StartOpenChest",
  714. Handler: _AvailableService_StartOpenChest_Handler,
  715. },
  716. {
  717. MethodName: "EndAllAction",
  718. Handler: _AvailableService_EndAllAction_Handler,
  719. },
  720. },
  721. Streams: []grpc.StreamDesc{
  722. {
  723. StreamName: "AddPlayer",
  724. Handler: _AvailableService_AddPlayer_Handler,
  725. ServerStreams: true,
  726. },
  727. },
  728. Metadata: "Services.proto",
  729. }