1
2
3
4
9 package examplepb
10
11 import (
12 "context"
13 "io"
14 "net/http"
15
16 "github.com/grpc-ecosystem/grpc-gateway/v2/runtime"
17 "github.com/grpc-ecosystem/grpc-gateway/v2/utilities"
18 "google.golang.org/grpc"
19 "google.golang.org/grpc/codes"
20 "google.golang.org/grpc/grpclog"
21 "google.golang.org/grpc/metadata"
22 "google.golang.org/grpc/status"
23 "google.golang.org/protobuf/proto"
24 )
25
26
27 var _ codes.Code
28 var _ io.Reader
29 var _ status.Status
30 var _ = runtime.String
31 var _ = utilities.NewDoubleArray
32 var _ = metadata.Join
33
34 func request_GenerateUnboundMethodsEchoService_Echo_0(ctx context.Context, marshaler runtime.Marshaler, client GenerateUnboundMethodsEchoServiceClient, req *http.Request, pathParams map[string]string) (proto.Message, runtime.ServerMetadata, error) {
35 var protoReq GenerateUnboundMethodsSimpleMessage
36 var metadata runtime.ServerMetadata
37
38 if err := marshaler.NewDecoder(req.Body).Decode(&protoReq); err != nil && err != io.EOF {
39 return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
40 }
41
42 msg, err := client.Echo(ctx, &protoReq, grpc.Header(&metadata.HeaderMD), grpc.Trailer(&metadata.TrailerMD))
43 return msg, metadata, err
44
45 }
46
47 func local_request_GenerateUnboundMethodsEchoService_Echo_0(ctx context.Context, marshaler runtime.Marshaler, server GenerateUnboundMethodsEchoServiceServer, req *http.Request, pathParams map[string]string) (proto.Message, runtime.ServerMetadata, error) {
48 var protoReq GenerateUnboundMethodsSimpleMessage
49 var metadata runtime.ServerMetadata
50
51 if err := marshaler.NewDecoder(req.Body).Decode(&protoReq); err != nil && err != io.EOF {
52 return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
53 }
54
55 msg, err := server.Echo(ctx, &protoReq)
56 return msg, metadata, err
57
58 }
59
60 func request_GenerateUnboundMethodsEchoService_EchoBody_0(ctx context.Context, marshaler runtime.Marshaler, client GenerateUnboundMethodsEchoServiceClient, req *http.Request, pathParams map[string]string) (proto.Message, runtime.ServerMetadata, error) {
61 var protoReq GenerateUnboundMethodsSimpleMessage
62 var metadata runtime.ServerMetadata
63
64 if err := marshaler.NewDecoder(req.Body).Decode(&protoReq); err != nil && err != io.EOF {
65 return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
66 }
67
68 msg, err := client.EchoBody(ctx, &protoReq, grpc.Header(&metadata.HeaderMD), grpc.Trailer(&metadata.TrailerMD))
69 return msg, metadata, err
70
71 }
72
73 func local_request_GenerateUnboundMethodsEchoService_EchoBody_0(ctx context.Context, marshaler runtime.Marshaler, server GenerateUnboundMethodsEchoServiceServer, req *http.Request, pathParams map[string]string) (proto.Message, runtime.ServerMetadata, error) {
74 var protoReq GenerateUnboundMethodsSimpleMessage
75 var metadata runtime.ServerMetadata
76
77 if err := marshaler.NewDecoder(req.Body).Decode(&protoReq); err != nil && err != io.EOF {
78 return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
79 }
80
81 msg, err := server.EchoBody(ctx, &protoReq)
82 return msg, metadata, err
83
84 }
85
86 func request_GenerateUnboundMethodsEchoService_EchoDelete_0(ctx context.Context, marshaler runtime.Marshaler, client GenerateUnboundMethodsEchoServiceClient, req *http.Request, pathParams map[string]string) (proto.Message, runtime.ServerMetadata, error) {
87 var protoReq GenerateUnboundMethodsSimpleMessage
88 var metadata runtime.ServerMetadata
89
90 if err := marshaler.NewDecoder(req.Body).Decode(&protoReq); err != nil && err != io.EOF {
91 return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
92 }
93
94 msg, err := client.EchoDelete(ctx, &protoReq, grpc.Header(&metadata.HeaderMD), grpc.Trailer(&metadata.TrailerMD))
95 return msg, metadata, err
96
97 }
98
99 func local_request_GenerateUnboundMethodsEchoService_EchoDelete_0(ctx context.Context, marshaler runtime.Marshaler, server GenerateUnboundMethodsEchoServiceServer, req *http.Request, pathParams map[string]string) (proto.Message, runtime.ServerMetadata, error) {
100 var protoReq GenerateUnboundMethodsSimpleMessage
101 var metadata runtime.ServerMetadata
102
103 if err := marshaler.NewDecoder(req.Body).Decode(&protoReq); err != nil && err != io.EOF {
104 return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
105 }
106
107 msg, err := server.EchoDelete(ctx, &protoReq)
108 return msg, metadata, err
109
110 }
111
112
113
114
115
116 func RegisterGenerateUnboundMethodsEchoServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server GenerateUnboundMethodsEchoServiceServer) error {
117
118 mux.Handle("POST", pattern_GenerateUnboundMethodsEchoService_Echo_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) {
119 ctx, cancel := context.WithCancel(req.Context())
120 defer cancel()
121 var stream runtime.ServerTransportStream
122 ctx = grpc.NewContextWithServerTransportStream(ctx, &stream)
123 inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req)
124 var err error
125 var annotatedContext context.Context
126 annotatedContext, err = runtime.AnnotateIncomingContext(ctx, mux, req, "/grpc.gateway.examples.internal.proto.examplepb.GenerateUnboundMethodsEchoService/Echo", runtime.WithHTTPPathPattern("/grpc.gateway.examples.internal.proto.examplepb.GenerateUnboundMethodsEchoService/Echo"))
127 if err != nil {
128 runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
129 return
130 }
131 resp, md, err := local_request_GenerateUnboundMethodsEchoService_Echo_0(annotatedContext, inboundMarshaler, server, req, pathParams)
132 md.HeaderMD, md.TrailerMD = metadata.Join(md.HeaderMD, stream.Header()), metadata.Join(md.TrailerMD, stream.Trailer())
133 annotatedContext = runtime.NewServerMetadataContext(annotatedContext, md)
134 if err != nil {
135 runtime.HTTPError(annotatedContext, mux, outboundMarshaler, w, req, err)
136 return
137 }
138
139 forward_GenerateUnboundMethodsEchoService_Echo_0(annotatedContext, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)
140
141 })
142
143 mux.Handle("POST", pattern_GenerateUnboundMethodsEchoService_EchoBody_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) {
144 ctx, cancel := context.WithCancel(req.Context())
145 defer cancel()
146 var stream runtime.ServerTransportStream
147 ctx = grpc.NewContextWithServerTransportStream(ctx, &stream)
148 inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req)
149 var err error
150 var annotatedContext context.Context
151 annotatedContext, err = runtime.AnnotateIncomingContext(ctx, mux, req, "/grpc.gateway.examples.internal.proto.examplepb.GenerateUnboundMethodsEchoService/EchoBody", runtime.WithHTTPPathPattern("/grpc.gateway.examples.internal.proto.examplepb.GenerateUnboundMethodsEchoService/EchoBody"))
152 if err != nil {
153 runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
154 return
155 }
156 resp, md, err := local_request_GenerateUnboundMethodsEchoService_EchoBody_0(annotatedContext, inboundMarshaler, server, req, pathParams)
157 md.HeaderMD, md.TrailerMD = metadata.Join(md.HeaderMD, stream.Header()), metadata.Join(md.TrailerMD, stream.Trailer())
158 annotatedContext = runtime.NewServerMetadataContext(annotatedContext, md)
159 if err != nil {
160 runtime.HTTPError(annotatedContext, mux, outboundMarshaler, w, req, err)
161 return
162 }
163
164 forward_GenerateUnboundMethodsEchoService_EchoBody_0(annotatedContext, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)
165
166 })
167
168 mux.Handle("POST", pattern_GenerateUnboundMethodsEchoService_EchoDelete_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) {
169 ctx, cancel := context.WithCancel(req.Context())
170 defer cancel()
171 var stream runtime.ServerTransportStream
172 ctx = grpc.NewContextWithServerTransportStream(ctx, &stream)
173 inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req)
174 var err error
175 var annotatedContext context.Context
176 annotatedContext, err = runtime.AnnotateIncomingContext(ctx, mux, req, "/grpc.gateway.examples.internal.proto.examplepb.GenerateUnboundMethodsEchoService/EchoDelete", runtime.WithHTTPPathPattern("/grpc.gateway.examples.internal.proto.examplepb.GenerateUnboundMethodsEchoService/EchoDelete"))
177 if err != nil {
178 runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
179 return
180 }
181 resp, md, err := local_request_GenerateUnboundMethodsEchoService_EchoDelete_0(annotatedContext, inboundMarshaler, server, req, pathParams)
182 md.HeaderMD, md.TrailerMD = metadata.Join(md.HeaderMD, stream.Header()), metadata.Join(md.TrailerMD, stream.Trailer())
183 annotatedContext = runtime.NewServerMetadataContext(annotatedContext, md)
184 if err != nil {
185 runtime.HTTPError(annotatedContext, mux, outboundMarshaler, w, req, err)
186 return
187 }
188
189 forward_GenerateUnboundMethodsEchoService_EchoDelete_0(annotatedContext, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)
190
191 })
192
193 return nil
194 }
195
196
197
198 func RegisterGenerateUnboundMethodsEchoServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error) {
199 conn, err := grpc.DialContext(ctx, endpoint, opts...)
200 if err != nil {
201 return err
202 }
203 defer func() {
204 if err != nil {
205 if cerr := conn.Close(); cerr != nil {
206 grpclog.Infof("Failed to close conn to %s: %v", endpoint, cerr)
207 }
208 return
209 }
210 go func() {
211 <-ctx.Done()
212 if cerr := conn.Close(); cerr != nil {
213 grpclog.Infof("Failed to close conn to %s: %v", endpoint, cerr)
214 }
215 }()
216 }()
217
218 return RegisterGenerateUnboundMethodsEchoServiceHandler(ctx, mux, conn)
219 }
220
221
222
223 func RegisterGenerateUnboundMethodsEchoServiceHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error {
224 return RegisterGenerateUnboundMethodsEchoServiceHandlerClient(ctx, mux, NewGenerateUnboundMethodsEchoServiceClient(conn))
225 }
226
227
228
229
230
231
232 func RegisterGenerateUnboundMethodsEchoServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client GenerateUnboundMethodsEchoServiceClient) error {
233
234 mux.Handle("POST", pattern_GenerateUnboundMethodsEchoService_Echo_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) {
235 ctx, cancel := context.WithCancel(req.Context())
236 defer cancel()
237 inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req)
238 var err error
239 var annotatedContext context.Context
240 annotatedContext, err = runtime.AnnotateContext(ctx, mux, req, "/grpc.gateway.examples.internal.proto.examplepb.GenerateUnboundMethodsEchoService/Echo", runtime.WithHTTPPathPattern("/grpc.gateway.examples.internal.proto.examplepb.GenerateUnboundMethodsEchoService/Echo"))
241 if err != nil {
242 runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
243 return
244 }
245 resp, md, err := request_GenerateUnboundMethodsEchoService_Echo_0(annotatedContext, inboundMarshaler, client, req, pathParams)
246 annotatedContext = runtime.NewServerMetadataContext(annotatedContext, md)
247 if err != nil {
248 runtime.HTTPError(annotatedContext, mux, outboundMarshaler, w, req, err)
249 return
250 }
251
252 forward_GenerateUnboundMethodsEchoService_Echo_0(annotatedContext, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)
253
254 })
255
256 mux.Handle("POST", pattern_GenerateUnboundMethodsEchoService_EchoBody_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) {
257 ctx, cancel := context.WithCancel(req.Context())
258 defer cancel()
259 inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req)
260 var err error
261 var annotatedContext context.Context
262 annotatedContext, err = runtime.AnnotateContext(ctx, mux, req, "/grpc.gateway.examples.internal.proto.examplepb.GenerateUnboundMethodsEchoService/EchoBody", runtime.WithHTTPPathPattern("/grpc.gateway.examples.internal.proto.examplepb.GenerateUnboundMethodsEchoService/EchoBody"))
263 if err != nil {
264 runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
265 return
266 }
267 resp, md, err := request_GenerateUnboundMethodsEchoService_EchoBody_0(annotatedContext, inboundMarshaler, client, req, pathParams)
268 annotatedContext = runtime.NewServerMetadataContext(annotatedContext, md)
269 if err != nil {
270 runtime.HTTPError(annotatedContext, mux, outboundMarshaler, w, req, err)
271 return
272 }
273
274 forward_GenerateUnboundMethodsEchoService_EchoBody_0(annotatedContext, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)
275
276 })
277
278 mux.Handle("POST", pattern_GenerateUnboundMethodsEchoService_EchoDelete_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) {
279 ctx, cancel := context.WithCancel(req.Context())
280 defer cancel()
281 inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req)
282 var err error
283 var annotatedContext context.Context
284 annotatedContext, err = runtime.AnnotateContext(ctx, mux, req, "/grpc.gateway.examples.internal.proto.examplepb.GenerateUnboundMethodsEchoService/EchoDelete", runtime.WithHTTPPathPattern("/grpc.gateway.examples.internal.proto.examplepb.GenerateUnboundMethodsEchoService/EchoDelete"))
285 if err != nil {
286 runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
287 return
288 }
289 resp, md, err := request_GenerateUnboundMethodsEchoService_EchoDelete_0(annotatedContext, inboundMarshaler, client, req, pathParams)
290 annotatedContext = runtime.NewServerMetadataContext(annotatedContext, md)
291 if err != nil {
292 runtime.HTTPError(annotatedContext, mux, outboundMarshaler, w, req, err)
293 return
294 }
295
296 forward_GenerateUnboundMethodsEchoService_EchoDelete_0(annotatedContext, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)
297
298 })
299
300 return nil
301 }
302
303 var (
304 pattern_GenerateUnboundMethodsEchoService_Echo_0 = runtime.MustPattern(runtime.NewPattern(1, []int{2, 0, 2, 1}, []string{"grpc.gateway.examples.internal.proto.examplepb.GenerateUnboundMethodsEchoService", "Echo"}, ""))
305
306 pattern_GenerateUnboundMethodsEchoService_EchoBody_0 = runtime.MustPattern(runtime.NewPattern(1, []int{2, 0, 2, 1}, []string{"grpc.gateway.examples.internal.proto.examplepb.GenerateUnboundMethodsEchoService", "EchoBody"}, ""))
307
308 pattern_GenerateUnboundMethodsEchoService_EchoDelete_0 = runtime.MustPattern(runtime.NewPattern(1, []int{2, 0, 2, 1}, []string{"grpc.gateway.examples.internal.proto.examplepb.GenerateUnboundMethodsEchoService", "EchoDelete"}, ""))
309 )
310
311 var (
312 forward_GenerateUnboundMethodsEchoService_Echo_0 = runtime.ForwardResponseMessage
313
314 forward_GenerateUnboundMethodsEchoService_EchoBody_0 = runtime.ForwardResponseMessage
315
316 forward_GenerateUnboundMethodsEchoService_EchoDelete_0 = runtime.ForwardResponseMessage
317 )
318
View as plain text