user.pb.gw.go 23 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556
  1. // Code generated by protoc-gen-grpc-gateway. DO NOT EDIT.
  2. // source: user.proto
  3. /*
  4. Package pb is a reverse proxy.
  5. It translates gRPC into RESTful JSON APIs.
  6. */
  7. package pb
  8. import (
  9. "context"
  10. "io"
  11. "net/http"
  12. "github.com/grpc-ecosystem/grpc-gateway/v2/runtime"
  13. "github.com/grpc-ecosystem/grpc-gateway/v2/utilities"
  14. "google.golang.org/grpc"
  15. "google.golang.org/grpc/codes"
  16. "google.golang.org/grpc/grpclog"
  17. "google.golang.org/grpc/metadata"
  18. "google.golang.org/grpc/status"
  19. "google.golang.org/protobuf/proto"
  20. )
  21. // Suppress "imported and not used" errors
  22. var _ codes.Code
  23. var _ io.Reader
  24. var _ status.Status
  25. var _ = runtime.String
  26. var _ = utilities.NewDoubleArray
  27. var _ = metadata.Join
  28. func request_UserService_List_0(ctx context.Context, marshaler runtime.Marshaler, client UserServiceClient, req *http.Request, pathParams map[string]string) (proto.Message, runtime.ServerMetadata, error) {
  29. var protoReq UserListRequest
  30. var metadata runtime.ServerMetadata
  31. msg, err := client.List(ctx, &protoReq, grpc.Header(&metadata.HeaderMD), grpc.Trailer(&metadata.TrailerMD))
  32. return msg, metadata, err
  33. }
  34. func local_request_UserService_List_0(ctx context.Context, marshaler runtime.Marshaler, server UserServiceServer, req *http.Request, pathParams map[string]string) (proto.Message, runtime.ServerMetadata, error) {
  35. var protoReq UserListRequest
  36. var metadata runtime.ServerMetadata
  37. msg, err := server.List(ctx, &protoReq)
  38. return msg, metadata, err
  39. }
  40. func request_UserService_Create_0(ctx context.Context, marshaler runtime.Marshaler, client UserServiceClient, req *http.Request, pathParams map[string]string) (proto.Message, runtime.ServerMetadata, error) {
  41. var protoReq UserCreateRequest
  42. var metadata runtime.ServerMetadata
  43. newReader, berr := utilities.IOReaderFactory(req.Body)
  44. if berr != nil {
  45. return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", berr)
  46. }
  47. if err := marshaler.NewDecoder(newReader()).Decode(&protoReq); err != nil && err != io.EOF {
  48. return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
  49. }
  50. msg, err := client.Create(ctx, &protoReq, grpc.Header(&metadata.HeaderMD), grpc.Trailer(&metadata.TrailerMD))
  51. return msg, metadata, err
  52. }
  53. func local_request_UserService_Create_0(ctx context.Context, marshaler runtime.Marshaler, server UserServiceServer, req *http.Request, pathParams map[string]string) (proto.Message, runtime.ServerMetadata, error) {
  54. var protoReq UserCreateRequest
  55. var metadata runtime.ServerMetadata
  56. newReader, berr := utilities.IOReaderFactory(req.Body)
  57. if berr != nil {
  58. return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", berr)
  59. }
  60. if err := marshaler.NewDecoder(newReader()).Decode(&protoReq); err != nil && err != io.EOF {
  61. return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
  62. }
  63. msg, err := server.Create(ctx, &protoReq)
  64. return msg, metadata, err
  65. }
  66. func request_UserService_Update_0(ctx context.Context, marshaler runtime.Marshaler, client UserServiceClient, req *http.Request, pathParams map[string]string) (proto.Message, runtime.ServerMetadata, error) {
  67. var protoReq UserUpdateRequest
  68. var metadata runtime.ServerMetadata
  69. newReader, berr := utilities.IOReaderFactory(req.Body)
  70. if berr != nil {
  71. return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", berr)
  72. }
  73. if err := marshaler.NewDecoder(newReader()).Decode(&protoReq); err != nil && err != io.EOF {
  74. return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
  75. }
  76. msg, err := client.Update(ctx, &protoReq, grpc.Header(&metadata.HeaderMD), grpc.Trailer(&metadata.TrailerMD))
  77. return msg, metadata, err
  78. }
  79. func local_request_UserService_Update_0(ctx context.Context, marshaler runtime.Marshaler, server UserServiceServer, req *http.Request, pathParams map[string]string) (proto.Message, runtime.ServerMetadata, error) {
  80. var protoReq UserUpdateRequest
  81. var metadata runtime.ServerMetadata
  82. newReader, berr := utilities.IOReaderFactory(req.Body)
  83. if berr != nil {
  84. return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", berr)
  85. }
  86. if err := marshaler.NewDecoder(newReader()).Decode(&protoReq); err != nil && err != io.EOF {
  87. return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
  88. }
  89. msg, err := server.Update(ctx, &protoReq)
  90. return msg, metadata, err
  91. }
  92. func request_UserService_Delete_0(ctx context.Context, marshaler runtime.Marshaler, client UserServiceClient, req *http.Request, pathParams map[string]string) (proto.Message, runtime.ServerMetadata, error) {
  93. var protoReq UserDeleteRequest
  94. var metadata runtime.ServerMetadata
  95. newReader, berr := utilities.IOReaderFactory(req.Body)
  96. if berr != nil {
  97. return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", berr)
  98. }
  99. if err := marshaler.NewDecoder(newReader()).Decode(&protoReq); err != nil && err != io.EOF {
  100. return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
  101. }
  102. msg, err := client.Delete(ctx, &protoReq, grpc.Header(&metadata.HeaderMD), grpc.Trailer(&metadata.TrailerMD))
  103. return msg, metadata, err
  104. }
  105. func local_request_UserService_Delete_0(ctx context.Context, marshaler runtime.Marshaler, server UserServiceServer, req *http.Request, pathParams map[string]string) (proto.Message, runtime.ServerMetadata, error) {
  106. var protoReq UserDeleteRequest
  107. var metadata runtime.ServerMetadata
  108. newReader, berr := utilities.IOReaderFactory(req.Body)
  109. if berr != nil {
  110. return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", berr)
  111. }
  112. if err := marshaler.NewDecoder(newReader()).Decode(&protoReq); err != nil && err != io.EOF {
  113. return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
  114. }
  115. msg, err := server.Delete(ctx, &protoReq)
  116. return msg, metadata, err
  117. }
  118. func request_UserService_Renew_0(ctx context.Context, marshaler runtime.Marshaler, client UserServiceClient, req *http.Request, pathParams map[string]string) (proto.Message, runtime.ServerMetadata, error) {
  119. var protoReq UserRenewRequest
  120. var metadata runtime.ServerMetadata
  121. newReader, berr := utilities.IOReaderFactory(req.Body)
  122. if berr != nil {
  123. return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", berr)
  124. }
  125. if err := marshaler.NewDecoder(newReader()).Decode(&protoReq); err != nil && err != io.EOF {
  126. return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
  127. }
  128. msg, err := client.Renew(ctx, &protoReq, grpc.Header(&metadata.HeaderMD), grpc.Trailer(&metadata.TrailerMD))
  129. return msg, metadata, err
  130. }
  131. func local_request_UserService_Renew_0(ctx context.Context, marshaler runtime.Marshaler, server UserServiceServer, req *http.Request, pathParams map[string]string) (proto.Message, runtime.ServerMetadata, error) {
  132. var protoReq UserRenewRequest
  133. var metadata runtime.ServerMetadata
  134. newReader, berr := utilities.IOReaderFactory(req.Body)
  135. if berr != nil {
  136. return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", berr)
  137. }
  138. if err := marshaler.NewDecoder(newReader()).Decode(&protoReq); err != nil && err != io.EOF {
  139. return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
  140. }
  141. msg, err := server.Renew(ctx, &protoReq)
  142. return msg, metadata, err
  143. }
  144. func request_UserService_GenConfig_0(ctx context.Context, marshaler runtime.Marshaler, client UserServiceClient, req *http.Request, pathParams map[string]string) (proto.Message, runtime.ServerMetadata, error) {
  145. var protoReq UserGenConfigRequest
  146. var metadata runtime.ServerMetadata
  147. newReader, berr := utilities.IOReaderFactory(req.Body)
  148. if berr != nil {
  149. return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", berr)
  150. }
  151. if err := marshaler.NewDecoder(newReader()).Decode(&protoReq); err != nil && err != io.EOF {
  152. return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
  153. }
  154. msg, err := client.GenConfig(ctx, &protoReq, grpc.Header(&metadata.HeaderMD), grpc.Trailer(&metadata.TrailerMD))
  155. return msg, metadata, err
  156. }
  157. func local_request_UserService_GenConfig_0(ctx context.Context, marshaler runtime.Marshaler, server UserServiceServer, req *http.Request, pathParams map[string]string) (proto.Message, runtime.ServerMetadata, error) {
  158. var protoReq UserGenConfigRequest
  159. var metadata runtime.ServerMetadata
  160. newReader, berr := utilities.IOReaderFactory(req.Body)
  161. if berr != nil {
  162. return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", berr)
  163. }
  164. if err := marshaler.NewDecoder(newReader()).Decode(&protoReq); err != nil && err != io.EOF {
  165. return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
  166. }
  167. msg, err := server.GenConfig(ctx, &protoReq)
  168. return msg, metadata, err
  169. }
  170. // RegisterUserServiceHandlerServer registers the http handlers for service UserService to "mux".
  171. // UnaryRPC :call UserServiceServer directly.
  172. // StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906.
  173. // Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterUserServiceHandlerFromEndpoint instead.
  174. func RegisterUserServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server UserServiceServer) error {
  175. mux.Handle("GET", pattern_UserService_List_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) {
  176. ctx, cancel := context.WithCancel(req.Context())
  177. defer cancel()
  178. var stream runtime.ServerTransportStream
  179. ctx = grpc.NewContextWithServerTransportStream(ctx, &stream)
  180. inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req)
  181. rctx, err := runtime.AnnotateIncomingContext(ctx, mux, req, "/pb.UserService/List")
  182. if err != nil {
  183. runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
  184. return
  185. }
  186. resp, md, err := local_request_UserService_List_0(rctx, inboundMarshaler, server, req, pathParams)
  187. md.HeaderMD, md.TrailerMD = metadata.Join(md.HeaderMD, stream.Header()), metadata.Join(md.TrailerMD, stream.Trailer())
  188. ctx = runtime.NewServerMetadataContext(ctx, md)
  189. if err != nil {
  190. runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
  191. return
  192. }
  193. forward_UserService_List_0(ctx, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)
  194. })
  195. mux.Handle("POST", pattern_UserService_Create_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) {
  196. ctx, cancel := context.WithCancel(req.Context())
  197. defer cancel()
  198. var stream runtime.ServerTransportStream
  199. ctx = grpc.NewContextWithServerTransportStream(ctx, &stream)
  200. inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req)
  201. rctx, err := runtime.AnnotateIncomingContext(ctx, mux, req, "/pb.UserService/Create")
  202. if err != nil {
  203. runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
  204. return
  205. }
  206. resp, md, err := local_request_UserService_Create_0(rctx, inboundMarshaler, server, req, pathParams)
  207. md.HeaderMD, md.TrailerMD = metadata.Join(md.HeaderMD, stream.Header()), metadata.Join(md.TrailerMD, stream.Trailer())
  208. ctx = runtime.NewServerMetadataContext(ctx, md)
  209. if err != nil {
  210. runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
  211. return
  212. }
  213. forward_UserService_Create_0(ctx, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)
  214. })
  215. mux.Handle("POST", pattern_UserService_Update_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) {
  216. ctx, cancel := context.WithCancel(req.Context())
  217. defer cancel()
  218. var stream runtime.ServerTransportStream
  219. ctx = grpc.NewContextWithServerTransportStream(ctx, &stream)
  220. inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req)
  221. rctx, err := runtime.AnnotateIncomingContext(ctx, mux, req, "/pb.UserService/Update")
  222. if err != nil {
  223. runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
  224. return
  225. }
  226. resp, md, err := local_request_UserService_Update_0(rctx, inboundMarshaler, server, req, pathParams)
  227. md.HeaderMD, md.TrailerMD = metadata.Join(md.HeaderMD, stream.Header()), metadata.Join(md.TrailerMD, stream.Trailer())
  228. ctx = runtime.NewServerMetadataContext(ctx, md)
  229. if err != nil {
  230. runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
  231. return
  232. }
  233. forward_UserService_Update_0(ctx, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)
  234. })
  235. mux.Handle("POST", pattern_UserService_Delete_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) {
  236. ctx, cancel := context.WithCancel(req.Context())
  237. defer cancel()
  238. var stream runtime.ServerTransportStream
  239. ctx = grpc.NewContextWithServerTransportStream(ctx, &stream)
  240. inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req)
  241. rctx, err := runtime.AnnotateIncomingContext(ctx, mux, req, "/pb.UserService/Delete")
  242. if err != nil {
  243. runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
  244. return
  245. }
  246. resp, md, err := local_request_UserService_Delete_0(rctx, inboundMarshaler, server, req, pathParams)
  247. md.HeaderMD, md.TrailerMD = metadata.Join(md.HeaderMD, stream.Header()), metadata.Join(md.TrailerMD, stream.Trailer())
  248. ctx = runtime.NewServerMetadataContext(ctx, md)
  249. if err != nil {
  250. runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
  251. return
  252. }
  253. forward_UserService_Delete_0(ctx, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)
  254. })
  255. mux.Handle("POST", pattern_UserService_Renew_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) {
  256. ctx, cancel := context.WithCancel(req.Context())
  257. defer cancel()
  258. var stream runtime.ServerTransportStream
  259. ctx = grpc.NewContextWithServerTransportStream(ctx, &stream)
  260. inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req)
  261. rctx, err := runtime.AnnotateIncomingContext(ctx, mux, req, "/pb.UserService/Renew")
  262. if err != nil {
  263. runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
  264. return
  265. }
  266. resp, md, err := local_request_UserService_Renew_0(rctx, inboundMarshaler, server, req, pathParams)
  267. md.HeaderMD, md.TrailerMD = metadata.Join(md.HeaderMD, stream.Header()), metadata.Join(md.TrailerMD, stream.Trailer())
  268. ctx = runtime.NewServerMetadataContext(ctx, md)
  269. if err != nil {
  270. runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
  271. return
  272. }
  273. forward_UserService_Renew_0(ctx, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)
  274. })
  275. mux.Handle("POST", pattern_UserService_GenConfig_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) {
  276. ctx, cancel := context.WithCancel(req.Context())
  277. defer cancel()
  278. var stream runtime.ServerTransportStream
  279. ctx = grpc.NewContextWithServerTransportStream(ctx, &stream)
  280. inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req)
  281. rctx, err := runtime.AnnotateIncomingContext(ctx, mux, req, "/pb.UserService/GenConfig")
  282. if err != nil {
  283. runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
  284. return
  285. }
  286. resp, md, err := local_request_UserService_GenConfig_0(rctx, inboundMarshaler, server, req, pathParams)
  287. md.HeaderMD, md.TrailerMD = metadata.Join(md.HeaderMD, stream.Header()), metadata.Join(md.TrailerMD, stream.Trailer())
  288. ctx = runtime.NewServerMetadataContext(ctx, md)
  289. if err != nil {
  290. runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
  291. return
  292. }
  293. forward_UserService_GenConfig_0(ctx, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)
  294. })
  295. return nil
  296. }
  297. // RegisterUserServiceHandlerFromEndpoint is same as RegisterUserServiceHandler but
  298. // automatically dials to "endpoint" and closes the connection when "ctx" gets done.
  299. func RegisterUserServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error) {
  300. conn, err := grpc.Dial(endpoint, opts...)
  301. if err != nil {
  302. return err
  303. }
  304. defer func() {
  305. if err != nil {
  306. if cerr := conn.Close(); cerr != nil {
  307. grpclog.Infof("Failed to close conn to %s: %v", endpoint, cerr)
  308. }
  309. return
  310. }
  311. go func() {
  312. <-ctx.Done()
  313. if cerr := conn.Close(); cerr != nil {
  314. grpclog.Infof("Failed to close conn to %s: %v", endpoint, cerr)
  315. }
  316. }()
  317. }()
  318. return RegisterUserServiceHandler(ctx, mux, conn)
  319. }
  320. // RegisterUserServiceHandler registers the http handlers for service UserService to "mux".
  321. // The handlers forward requests to the grpc endpoint over "conn".
  322. func RegisterUserServiceHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error {
  323. return RegisterUserServiceHandlerClient(ctx, mux, NewUserServiceClient(conn))
  324. }
  325. // RegisterUserServiceHandlerClient registers the http handlers for service UserService
  326. // to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "UserServiceClient".
  327. // Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "UserServiceClient"
  328. // doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in
  329. // "UserServiceClient" to call the correct interceptors.
  330. func RegisterUserServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client UserServiceClient) error {
  331. mux.Handle("GET", pattern_UserService_List_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) {
  332. ctx, cancel := context.WithCancel(req.Context())
  333. defer cancel()
  334. inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req)
  335. rctx, err := runtime.AnnotateContext(ctx, mux, req, "/pb.UserService/List")
  336. if err != nil {
  337. runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
  338. return
  339. }
  340. resp, md, err := request_UserService_List_0(rctx, inboundMarshaler, client, req, pathParams)
  341. ctx = runtime.NewServerMetadataContext(ctx, md)
  342. if err != nil {
  343. runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
  344. return
  345. }
  346. forward_UserService_List_0(ctx, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)
  347. })
  348. mux.Handle("POST", pattern_UserService_Create_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) {
  349. ctx, cancel := context.WithCancel(req.Context())
  350. defer cancel()
  351. inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req)
  352. rctx, err := runtime.AnnotateContext(ctx, mux, req, "/pb.UserService/Create")
  353. if err != nil {
  354. runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
  355. return
  356. }
  357. resp, md, err := request_UserService_Create_0(rctx, inboundMarshaler, client, req, pathParams)
  358. ctx = runtime.NewServerMetadataContext(ctx, md)
  359. if err != nil {
  360. runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
  361. return
  362. }
  363. forward_UserService_Create_0(ctx, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)
  364. })
  365. mux.Handle("POST", pattern_UserService_Update_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) {
  366. ctx, cancel := context.WithCancel(req.Context())
  367. defer cancel()
  368. inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req)
  369. rctx, err := runtime.AnnotateContext(ctx, mux, req, "/pb.UserService/Update")
  370. if err != nil {
  371. runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
  372. return
  373. }
  374. resp, md, err := request_UserService_Update_0(rctx, inboundMarshaler, client, req, pathParams)
  375. ctx = runtime.NewServerMetadataContext(ctx, md)
  376. if err != nil {
  377. runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
  378. return
  379. }
  380. forward_UserService_Update_0(ctx, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)
  381. })
  382. mux.Handle("POST", pattern_UserService_Delete_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) {
  383. ctx, cancel := context.WithCancel(req.Context())
  384. defer cancel()
  385. inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req)
  386. rctx, err := runtime.AnnotateContext(ctx, mux, req, "/pb.UserService/Delete")
  387. if err != nil {
  388. runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
  389. return
  390. }
  391. resp, md, err := request_UserService_Delete_0(rctx, inboundMarshaler, client, req, pathParams)
  392. ctx = runtime.NewServerMetadataContext(ctx, md)
  393. if err != nil {
  394. runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
  395. return
  396. }
  397. forward_UserService_Delete_0(ctx, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)
  398. })
  399. mux.Handle("POST", pattern_UserService_Renew_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) {
  400. ctx, cancel := context.WithCancel(req.Context())
  401. defer cancel()
  402. inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req)
  403. rctx, err := runtime.AnnotateContext(ctx, mux, req, "/pb.UserService/Renew")
  404. if err != nil {
  405. runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
  406. return
  407. }
  408. resp, md, err := request_UserService_Renew_0(rctx, inboundMarshaler, client, req, pathParams)
  409. ctx = runtime.NewServerMetadataContext(ctx, md)
  410. if err != nil {
  411. runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
  412. return
  413. }
  414. forward_UserService_Renew_0(ctx, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)
  415. })
  416. mux.Handle("POST", pattern_UserService_GenConfig_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) {
  417. ctx, cancel := context.WithCancel(req.Context())
  418. defer cancel()
  419. inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req)
  420. rctx, err := runtime.AnnotateContext(ctx, mux, req, "/pb.UserService/GenConfig")
  421. if err != nil {
  422. runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
  423. return
  424. }
  425. resp, md, err := request_UserService_GenConfig_0(rctx, inboundMarshaler, client, req, pathParams)
  426. ctx = runtime.NewServerMetadataContext(ctx, md)
  427. if err != nil {
  428. runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
  429. return
  430. }
  431. forward_UserService_GenConfig_0(ctx, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)
  432. })
  433. return nil
  434. }
  435. var (
  436. pattern_UserService_List_0 = runtime.MustPattern(runtime.NewPattern(1, []int{2, 0, 2, 1, 2, 2, 2, 3}, []string{"api", "v1", "user", "list"}, ""))
  437. pattern_UserService_Create_0 = runtime.MustPattern(runtime.NewPattern(1, []int{2, 0, 2, 1, 2, 2, 2, 3}, []string{"api", "v1", "user", "create"}, ""))
  438. pattern_UserService_Update_0 = runtime.MustPattern(runtime.NewPattern(1, []int{2, 0, 2, 1, 2, 2, 2, 3}, []string{"api", "v1", "user", "update"}, ""))
  439. pattern_UserService_Delete_0 = runtime.MustPattern(runtime.NewPattern(1, []int{2, 0, 2, 1, 2, 2, 2, 3}, []string{"api", "v1", "user", "delete"}, ""))
  440. pattern_UserService_Renew_0 = runtime.MustPattern(runtime.NewPattern(1, []int{2, 0, 2, 1, 2, 2, 2, 3}, []string{"api", "v1", "user", "renew"}, ""))
  441. pattern_UserService_GenConfig_0 = runtime.MustPattern(runtime.NewPattern(1, []int{2, 0, 2, 1, 2, 2, 2, 3}, []string{"api", "v1", "user", "genconfig"}, ""))
  442. )
  443. var (
  444. forward_UserService_List_0 = runtime.ForwardResponseMessage
  445. forward_UserService_Create_0 = runtime.ForwardResponseMessage
  446. forward_UserService_Update_0 = runtime.ForwardResponseMessage
  447. forward_UserService_Delete_0 = runtime.ForwardResponseMessage
  448. forward_UserService_Renew_0 = runtime.ForwardResponseMessage
  449. forward_UserService_GenConfig_0 = runtime.ForwardResponseMessage
  450. )