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