adm_task_service.pb.go 8.0 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203
  1. // Code generated by protoc-gen-go. DO NOT EDIT.
  2. // source: adm_task_service.proto
  3. // package声明符,用来防止不同的消息类型有命名冲突
  4. package pb
  5. import (
  6. v1 "adm-ads/pb/v1"
  7. context "context"
  8. fmt "fmt"
  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. math "math"
  14. )
  15. // Reference imports to suppress errors if they are not otherwise used.
  16. var _ = proto.Marshal
  17. var _ = fmt.Errorf
  18. var _ = math.Inf
  19. // This is a compile-time assertion to ensure that this generated file
  20. // is compatible with the proto package it is being compiled against.
  21. // A compilation error at this line likely means your copy of the
  22. // proto package needs to be updated.
  23. const _ = proto.ProtoPackageIsVersion3 // please upgrade the proto package
  24. func init() {
  25. proto.RegisterFile("adm_task_service.proto", fileDescriptor_b888879dea74b804)
  26. }
  27. var fileDescriptor_b888879dea74b804 = []byte{
  28. // 198 bytes of a gzipped FileDescriptorProto
  29. 0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0xe2, 0x12, 0x4b, 0x4c, 0xc9, 0x8d,
  30. 0x2f, 0x49, 0x2c, 0xce, 0x8e, 0x2f, 0x4e, 0x2d, 0x2a, 0xcb, 0x4c, 0x4e, 0xd5, 0x2b, 0x28, 0xca,
  31. 0x2f, 0xc9, 0x17, 0xe2, 0x2a, 0x48, 0xd2, 0x83, 0x8a, 0x48, 0xf1, 0x96, 0x19, 0xea, 0x83, 0x94,
  32. 0x40, 0xa4, 0x8c, 0x3e, 0x30, 0x72, 0xb1, 0x3b, 0xa6, 0xe4, 0x86, 0x24, 0x16, 0x67, 0x0b, 0x85,
  33. 0x72, 0x09, 0xbb, 0xa7, 0x96, 0x80, 0x98, 0x4e, 0x95, 0xc1, 0xf9, 0xa5, 0x45, 0xc9, 0xa9, 0xce,
  34. 0xf9, 0x29, 0xa9, 0x42, 0x72, 0x7a, 0x65, 0x86, 0x7a, 0x58, 0x24, 0x82, 0x52, 0x0b, 0x4b, 0x53,
  35. 0x8b, 0x4b, 0xa4, 0x64, 0x70, 0xca, 0x17, 0xe4, 0x54, 0x2a, 0x31, 0x08, 0xf9, 0x73, 0x09, 0x86,
  36. 0x16, 0xa4, 0x24, 0x96, 0xa4, 0xfa, 0xa7, 0xa5, 0xe5, 0x64, 0xe6, 0xa5, 0x82, 0xed, 0x02, 0x6b,
  37. 0xc2, 0x10, 0x86, 0x19, 0x29, 0x85, 0x43, 0x16, 0x62, 0xa0, 0x2d, 0x17, 0xb7, 0x73, 0x46, 0x6a,
  38. 0x72, 0xb6, 0x5b, 0x7e, 0x51, 0x6e, 0x62, 0x89, 0x90, 0x18, 0x48, 0x31, 0x92, 0x00, 0xcc, 0x10,
  39. 0x11, 0x0c, 0x71, 0xb0, 0x76, 0x27, 0x9e, 0x28, 0xae, 0xc4, 0x94, 0x5c, 0xdd, 0xc4, 0x94, 0x62,
  40. 0xfd, 0x82, 0xa4, 0x24, 0x36, 0x70, 0x38, 0x18, 0x03, 0x02, 0x00, 0x00, 0xff, 0xff, 0x8f, 0x05,
  41. 0xa1, 0x14, 0x3c, 0x01, 0x00, 0x00,
  42. }
  43. // Reference imports to suppress errors if they are not otherwise used.
  44. var _ context.Context
  45. var _ grpc.ClientConnInterface
  46. // This is a compile-time assertion to ensure that this generated file
  47. // is compatible with the grpc package it is being compiled against.
  48. const _ = grpc.SupportPackageIsVersion6
  49. // AdmTaskClient is the client API for AdmTask service.
  50. //
  51. // For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
  52. type AdmTaskClient interface {
  53. // Sends a greeting
  54. GetTaskBySourceCode(ctx context.Context, in *v1.GetTaskBySourceCodeRequest, opts ...grpc.CallOption) (*v1.GetTaskBySourceCodeReply, error)
  55. UpdateOfflineTask(ctx context.Context, in *v1.UpdateOfflineTaskRequest, opts ...grpc.CallOption) (*v1.UpdateOfflineTaskReply, error)
  56. CheckFormat(ctx context.Context, in *v1.CheckFormatRequest, opts ...grpc.CallOption) (*v1.CheckFormatReply, error)
  57. }
  58. type admTaskClient struct {
  59. cc grpc.ClientConnInterface
  60. }
  61. func NewAdmTaskClient(cc grpc.ClientConnInterface) AdmTaskClient {
  62. return &admTaskClient{cc}
  63. }
  64. func (c *admTaskClient) GetTaskBySourceCode(ctx context.Context, in *v1.GetTaskBySourceCodeRequest, opts ...grpc.CallOption) (*v1.GetTaskBySourceCodeReply, error) {
  65. out := new(v1.GetTaskBySourceCodeReply)
  66. err := c.cc.Invoke(ctx, "/pb.service.AdmTask/GetTaskBySourceCode", in, out, opts...)
  67. if err != nil {
  68. return nil, err
  69. }
  70. return out, nil
  71. }
  72. func (c *admTaskClient) UpdateOfflineTask(ctx context.Context, in *v1.UpdateOfflineTaskRequest, opts ...grpc.CallOption) (*v1.UpdateOfflineTaskReply, error) {
  73. out := new(v1.UpdateOfflineTaskReply)
  74. err := c.cc.Invoke(ctx, "/pb.service.AdmTask/UpdateOfflineTask", in, out, opts...)
  75. if err != nil {
  76. return nil, err
  77. }
  78. return out, nil
  79. }
  80. func (c *admTaskClient) CheckFormat(ctx context.Context, in *v1.CheckFormatRequest, opts ...grpc.CallOption) (*v1.CheckFormatReply, error) {
  81. out := new(v1.CheckFormatReply)
  82. err := c.cc.Invoke(ctx, "/pb.service.AdmTask/CheckFormat", in, out, opts...)
  83. if err != nil {
  84. return nil, err
  85. }
  86. return out, nil
  87. }
  88. // AdmTaskServer is the server API for AdmTask service.
  89. type AdmTaskServer interface {
  90. // Sends a greeting
  91. GetTaskBySourceCode(context.Context, *v1.GetTaskBySourceCodeRequest) (*v1.GetTaskBySourceCodeReply, error)
  92. UpdateOfflineTask(context.Context, *v1.UpdateOfflineTaskRequest) (*v1.UpdateOfflineTaskReply, error)
  93. CheckFormat(context.Context, *v1.CheckFormatRequest) (*v1.CheckFormatReply, error)
  94. }
  95. // UnimplementedAdmTaskServer can be embedded to have forward compatible implementations.
  96. type UnimplementedAdmTaskServer struct {
  97. }
  98. func (*UnimplementedAdmTaskServer) GetTaskBySourceCode(ctx context.Context, req *v1.GetTaskBySourceCodeRequest) (*v1.GetTaskBySourceCodeReply, error) {
  99. return nil, status.Errorf(codes.Unimplemented, "method GetTaskBySourceCode not implemented")
  100. }
  101. func (*UnimplementedAdmTaskServer) UpdateOfflineTask(ctx context.Context, req *v1.UpdateOfflineTaskRequest) (*v1.UpdateOfflineTaskReply, error) {
  102. return nil, status.Errorf(codes.Unimplemented, "method UpdateOfflineTask not implemented")
  103. }
  104. func (*UnimplementedAdmTaskServer) CheckFormat(ctx context.Context, req *v1.CheckFormatRequest) (*v1.CheckFormatReply, error) {
  105. return nil, status.Errorf(codes.Unimplemented, "method CheckFormat not implemented")
  106. }
  107. func RegisterAdmTaskServer(s *grpc.Server, srv AdmTaskServer) {
  108. s.RegisterService(&_AdmTask_serviceDesc, srv)
  109. }
  110. func _AdmTask_GetTaskBySourceCode_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  111. in := new(v1.GetTaskBySourceCodeRequest)
  112. if err := dec(in); err != nil {
  113. return nil, err
  114. }
  115. if interceptor == nil {
  116. return srv.(AdmTaskServer).GetTaskBySourceCode(ctx, in)
  117. }
  118. info := &grpc.UnaryServerInfo{
  119. Server: srv,
  120. FullMethod: "/pb.service.AdmTask/GetTaskBySourceCode",
  121. }
  122. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  123. return srv.(AdmTaskServer).GetTaskBySourceCode(ctx, req.(*v1.GetTaskBySourceCodeRequest))
  124. }
  125. return interceptor(ctx, in, info, handler)
  126. }
  127. func _AdmTask_UpdateOfflineTask_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  128. in := new(v1.UpdateOfflineTaskRequest)
  129. if err := dec(in); err != nil {
  130. return nil, err
  131. }
  132. if interceptor == nil {
  133. return srv.(AdmTaskServer).UpdateOfflineTask(ctx, in)
  134. }
  135. info := &grpc.UnaryServerInfo{
  136. Server: srv,
  137. FullMethod: "/pb.service.AdmTask/UpdateOfflineTask",
  138. }
  139. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  140. return srv.(AdmTaskServer).UpdateOfflineTask(ctx, req.(*v1.UpdateOfflineTaskRequest))
  141. }
  142. return interceptor(ctx, in, info, handler)
  143. }
  144. func _AdmTask_CheckFormat_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  145. in := new(v1.CheckFormatRequest)
  146. if err := dec(in); err != nil {
  147. return nil, err
  148. }
  149. if interceptor == nil {
  150. return srv.(AdmTaskServer).CheckFormat(ctx, in)
  151. }
  152. info := &grpc.UnaryServerInfo{
  153. Server: srv,
  154. FullMethod: "/pb.service.AdmTask/CheckFormat",
  155. }
  156. handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  157. return srv.(AdmTaskServer).CheckFormat(ctx, req.(*v1.CheckFormatRequest))
  158. }
  159. return interceptor(ctx, in, info, handler)
  160. }
  161. var _AdmTask_serviceDesc = grpc.ServiceDesc{
  162. ServiceName: "pb.service.AdmTask",
  163. HandlerType: (*AdmTaskServer)(nil),
  164. Methods: []grpc.MethodDesc{
  165. {
  166. MethodName: "GetTaskBySourceCode",
  167. Handler: _AdmTask_GetTaskBySourceCode_Handler,
  168. },
  169. {
  170. MethodName: "UpdateOfflineTask",
  171. Handler: _AdmTask_UpdateOfflineTask_Handler,
  172. },
  173. {
  174. MethodName: "CheckFormat",
  175. Handler: _AdmTask_CheckFormat_Handler,
  176. },
  177. },
  178. Streams: []grpc.StreamDesc{},
  179. Metadata: "adm_task_service.proto",
  180. }