blob: b96f904b9a9511f611aad66459ee36d871ed1074 [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
Matteo Scandoloa6a3aee2019-11-26 13:30:14 -070016 "github.com/golang/protobuf/proto"
17 "github.com/grpc-ecosystem/grpc-gateway/runtime"
18 "github.com/grpc-ecosystem/grpc-gateway/utilities"
19 "google.golang.org/grpc"
20 "google.golang.org/grpc/codes"
21 "google.golang.org/grpc/grpclog"
22 "google.golang.org/grpc/status"
23)
24
Matteo Scandoloa6a3aee2019-11-26 13:30:14 -070025var _ codes.Code
26var _ io.Reader
27var _ status.Status
28var _ = runtime.String
29var _ = utilities.NewDoubleArray
Matteo Scandoloa6a3aee2019-11-26 13:30:14 -070030
31func request_BBSim_Version_0(ctx context.Context, marshaler runtime.Marshaler, client BBSimClient, req *http.Request, pathParams map[string]string) (proto.Message, runtime.ServerMetadata, error) {
32 var protoReq Empty
33 var metadata runtime.ServerMetadata
34
35 msg, err := client.Version(ctx, &protoReq, grpc.Header(&metadata.HeaderMD), grpc.Trailer(&metadata.TrailerMD))
36 return msg, metadata, err
37
38}
39
Pragya Arya1cbefa42020-01-13 12:15:29 +053040func 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) {
41 var protoReq Empty
42 var metadata runtime.ServerMetadata
43
44 msg, err := server.Version(ctx, &protoReq)
45 return msg, metadata, err
46
47}
48
Matteo Scandoloa6a3aee2019-11-26 13:30:14 -070049func request_BBSim_GetOlt_0(ctx context.Context, marshaler runtime.Marshaler, client BBSimClient, req *http.Request, pathParams map[string]string) (proto.Message, runtime.ServerMetadata, error) {
50 var protoReq Empty
51 var metadata runtime.ServerMetadata
52
53 msg, err := client.GetOlt(ctx, &protoReq, grpc.Header(&metadata.HeaderMD), grpc.Trailer(&metadata.TrailerMD))
54 return msg, metadata, err
55
56}
57
Pragya Arya1cbefa42020-01-13 12:15:29 +053058func 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) {
59 var protoReq Empty
60 var metadata runtime.ServerMetadata
61
62 msg, err := server.GetOlt(ctx, &protoReq)
63 return msg, metadata, err
64
65}
66
Matteo Scandoloa6a3aee2019-11-26 13:30:14 -070067func request_BBSim_GetOlt_1(ctx context.Context, marshaler runtime.Marshaler, client BBSimClient, req *http.Request, pathParams map[string]string) (proto.Message, runtime.ServerMetadata, error) {
68 var protoReq Empty
69 var metadata runtime.ServerMetadata
70
71 msg, err := client.GetOlt(ctx, &protoReq, grpc.Header(&metadata.HeaderMD), grpc.Trailer(&metadata.TrailerMD))
72 return msg, metadata, err
73
74}
75
Pragya Arya1cbefa42020-01-13 12:15:29 +053076func 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) {
77 var protoReq Empty
78 var metadata runtime.ServerMetadata
79
80 msg, err := server.GetOlt(ctx, &protoReq)
81 return msg, metadata, err
82
83}
84
Matteo Scandoloa6a3aee2019-11-26 13:30:14 -070085func request_BBSim_GetONUs_0(ctx context.Context, marshaler runtime.Marshaler, client BBSimClient, req *http.Request, pathParams map[string]string) (proto.Message, runtime.ServerMetadata, error) {
86 var protoReq Empty
87 var metadata runtime.ServerMetadata
88
89 msg, err := client.GetONUs(ctx, &protoReq, grpc.Header(&metadata.HeaderMD), grpc.Trailer(&metadata.TrailerMD))
90 return msg, metadata, err
91
92}
93
Pragya Arya1cbefa42020-01-13 12:15:29 +053094func 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) {
95 var protoReq Empty
96 var metadata runtime.ServerMetadata
97
98 msg, err := server.GetONUs(ctx, &protoReq)
99 return msg, metadata, err
100
101}
102
Matteo Scandoloa6a3aee2019-11-26 13:30:14 -0700103func request_BBSim_GetONU_0(ctx context.Context, marshaler runtime.Marshaler, client BBSimClient, req *http.Request, pathParams map[string]string) (proto.Message, runtime.ServerMetadata, error) {
104 var protoReq ONURequest
105 var metadata runtime.ServerMetadata
106
107 var (
108 val string
109 ok bool
110 err error
111 _ = err
112 )
113
114 val, ok = pathParams["SerialNumber"]
115 if !ok {
116 return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "SerialNumber")
117 }
118
119 protoReq.SerialNumber, err = runtime.String(val)
120
121 if err != nil {
122 return nil, metadata, status.Errorf(codes.InvalidArgument, "type mismatch, parameter: %s, error: %v", "SerialNumber", err)
123 }
124
125 msg, err := client.GetONU(ctx, &protoReq, grpc.Header(&metadata.HeaderMD), grpc.Trailer(&metadata.TrailerMD))
126 return msg, metadata, err
127
128}
129
Pragya Arya1cbefa42020-01-13 12:15:29 +0530130func 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) {
131 var protoReq ONURequest
132 var metadata runtime.ServerMetadata
133
134 var (
135 val string
136 ok bool
137 err error
138 _ = err
139 )
140
141 val, ok = pathParams["SerialNumber"]
142 if !ok {
143 return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "SerialNumber")
144 }
145
146 protoReq.SerialNumber, err = runtime.String(val)
147
148 if err != nil {
149 return nil, metadata, status.Errorf(codes.InvalidArgument, "type mismatch, parameter: %s, error: %v", "SerialNumber", err)
150 }
151
152 msg, err := server.GetONU(ctx, &protoReq)
153 return msg, metadata, err
154
155}
156
157func request_BBSim_ShutdownONU_0(ctx context.Context, marshaler runtime.Marshaler, client BBSimClient, req *http.Request, pathParams map[string]string) (proto.Message, runtime.ServerMetadata, error) {
158 var protoReq ONURequest
159 var metadata runtime.ServerMetadata
160
161 var (
162 val string
163 ok bool
164 err error
165 _ = err
166 )
167
168 val, ok = pathParams["SerialNumber"]
169 if !ok {
170 return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "SerialNumber")
171 }
172
173 protoReq.SerialNumber, err = runtime.String(val)
174
175 if err != nil {
176 return nil, metadata, status.Errorf(codes.InvalidArgument, "type mismatch, parameter: %s, error: %v", "SerialNumber", err)
177 }
178
179 msg, err := client.ShutdownONU(ctx, &protoReq, grpc.Header(&metadata.HeaderMD), grpc.Trailer(&metadata.TrailerMD))
180 return msg, metadata, err
181
182}
183
184func local_request_BBSim_ShutdownONU_0(ctx context.Context, marshaler runtime.Marshaler, server BBSimServer, req *http.Request, pathParams map[string]string) (proto.Message, runtime.ServerMetadata, error) {
185 var protoReq ONURequest
186 var metadata runtime.ServerMetadata
187
188 var (
189 val string
190 ok bool
191 err error
192 _ = err
193 )
194
195 val, ok = pathParams["SerialNumber"]
196 if !ok {
197 return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "SerialNumber")
198 }
199
200 protoReq.SerialNumber, err = runtime.String(val)
201
202 if err != nil {
203 return nil, metadata, status.Errorf(codes.InvalidArgument, "type mismatch, parameter: %s, error: %v", "SerialNumber", err)
204 }
205
206 msg, err := server.ShutdownONU(ctx, &protoReq)
207 return msg, metadata, err
208
209}
210
211func request_BBSim_PoweronONU_0(ctx context.Context, marshaler runtime.Marshaler, client BBSimClient, req *http.Request, pathParams map[string]string) (proto.Message, runtime.ServerMetadata, error) {
212 var protoReq ONURequest
213 var metadata runtime.ServerMetadata
214
215 var (
216 val string
217 ok bool
218 err error
219 _ = err
220 )
221
222 val, ok = pathParams["SerialNumber"]
223 if !ok {
224 return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "SerialNumber")
225 }
226
227 protoReq.SerialNumber, err = runtime.String(val)
228
229 if err != nil {
230 return nil, metadata, status.Errorf(codes.InvalidArgument, "type mismatch, parameter: %s, error: %v", "SerialNumber", err)
231 }
232
233 msg, err := client.PoweronONU(ctx, &protoReq, grpc.Header(&metadata.HeaderMD), grpc.Trailer(&metadata.TrailerMD))
234 return msg, metadata, err
235
236}
237
238func local_request_BBSim_PoweronONU_0(ctx context.Context, marshaler runtime.Marshaler, server BBSimServer, req *http.Request, pathParams map[string]string) (proto.Message, runtime.ServerMetadata, error) {
239 var protoReq ONURequest
240 var metadata runtime.ServerMetadata
241
242 var (
243 val string
244 ok bool
245 err error
246 _ = err
247 )
248
249 val, ok = pathParams["SerialNumber"]
250 if !ok {
251 return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "SerialNumber")
252 }
253
254 protoReq.SerialNumber, err = runtime.String(val)
255
256 if err != nil {
257 return nil, metadata, status.Errorf(codes.InvalidArgument, "type mismatch, parameter: %s, error: %v", "SerialNumber", err)
258 }
259
260 msg, err := server.PoweronONU(ctx, &protoReq)
261 return msg, metadata, err
262
263}
264
Pragya Arya694ece02020-02-07 13:03:47 +0530265var (
Anand S Katti86552f92020-03-03 21:56:32 +0530266 filter_BBSim_SetOnuAlarmIndication_0 = &utilities.DoubleArray{Encoding: map[string]int{"SerialNumber": 0, "AlarmType": 1, "Status": 2}, Base: []int{1, 1, 2, 3, 0, 0, 0}, Check: []int{0, 1, 1, 1, 2, 3, 4}}
Pragya Arya694ece02020-02-07 13:03:47 +0530267)
268
Anand S Katti86552f92020-03-03 21:56:32 +0530269func request_BBSim_SetOnuAlarmIndication_0(ctx context.Context, marshaler runtime.Marshaler, client BBSimClient, req *http.Request, pathParams map[string]string) (proto.Message, runtime.ServerMetadata, error) {
270 var protoReq ONUAlarmRequest
Pragya Arya694ece02020-02-07 13:03:47 +0530271 var metadata runtime.ServerMetadata
272
273 var (
274 val string
275 ok bool
276 err error
277 _ = err
278 )
279
280 val, ok = pathParams["SerialNumber"]
281 if !ok {
282 return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "SerialNumber")
283 }
284
285 protoReq.SerialNumber, err = runtime.String(val)
286
287 if err != nil {
288 return nil, metadata, status.Errorf(codes.InvalidArgument, "type mismatch, parameter: %s, error: %v", "SerialNumber", err)
289 }
290
291 val, ok = pathParams["AlarmType"]
292 if !ok {
293 return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "AlarmType")
294 }
295
296 protoReq.AlarmType, err = runtime.String(val)
297
298 if err != nil {
299 return nil, metadata, status.Errorf(codes.InvalidArgument, "type mismatch, parameter: %s, error: %v", "AlarmType", err)
300 }
301
302 val, ok = pathParams["Status"]
303 if !ok {
304 return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "Status")
305 }
306
307 protoReq.Status, err = runtime.String(val)
308
309 if err != nil {
310 return nil, metadata, status.Errorf(codes.InvalidArgument, "type mismatch, parameter: %s, error: %v", "Status", err)
311 }
312
313 if err := req.ParseForm(); err != nil {
314 return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
315 }
Anand S Katti86552f92020-03-03 21:56:32 +0530316 if err := runtime.PopulateQueryParameters(&protoReq, req.Form, filter_BBSim_SetOnuAlarmIndication_0); err != nil {
Pragya Arya694ece02020-02-07 13:03:47 +0530317 return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
318 }
319
Anand S Katti86552f92020-03-03 21:56:32 +0530320 msg, err := client.SetOnuAlarmIndication(ctx, &protoReq, grpc.Header(&metadata.HeaderMD), grpc.Trailer(&metadata.TrailerMD))
Pragya Arya694ece02020-02-07 13:03:47 +0530321 return msg, metadata, err
322
323}
324
Anand S Katti86552f92020-03-03 21:56:32 +0530325func local_request_BBSim_SetOnuAlarmIndication_0(ctx context.Context, marshaler runtime.Marshaler, server BBSimServer, req *http.Request, pathParams map[string]string) (proto.Message, runtime.ServerMetadata, error) {
326 var protoReq ONUAlarmRequest
Pragya Arya694ece02020-02-07 13:03:47 +0530327 var metadata runtime.ServerMetadata
328
329 var (
330 val string
331 ok bool
332 err error
333 _ = err
334 )
335
336 val, ok = pathParams["SerialNumber"]
337 if !ok {
338 return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "SerialNumber")
339 }
340
341 protoReq.SerialNumber, err = runtime.String(val)
342
343 if err != nil {
344 return nil, metadata, status.Errorf(codes.InvalidArgument, "type mismatch, parameter: %s, error: %v", "SerialNumber", err)
345 }
346
347 val, ok = pathParams["AlarmType"]
348 if !ok {
349 return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "AlarmType")
350 }
351
352 protoReq.AlarmType, err = runtime.String(val)
353
354 if err != nil {
355 return nil, metadata, status.Errorf(codes.InvalidArgument, "type mismatch, parameter: %s, error: %v", "AlarmType", err)
356 }
357
358 val, ok = pathParams["Status"]
359 if !ok {
360 return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "Status")
361 }
362
363 protoReq.Status, err = runtime.String(val)
364
365 if err != nil {
366 return nil, metadata, status.Errorf(codes.InvalidArgument, "type mismatch, parameter: %s, error: %v", "Status", err)
367 }
368
Anand S Katti86552f92020-03-03 21:56:32 +0530369 if err := runtime.PopulateQueryParameters(&protoReq, req.URL.Query(), filter_BBSim_SetOnuAlarmIndication_0); err != nil {
Pragya Arya694ece02020-02-07 13:03:47 +0530370 return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
371 }
372
Anand S Katti86552f92020-03-03 21:56:32 +0530373 msg, err := server.SetOnuAlarmIndication(ctx, &protoReq)
374 return msg, metadata, err
375
376}
377
378func request_BBSim_SetOltAlarmIndication_0(ctx context.Context, marshaler runtime.Marshaler, client BBSimClient, req *http.Request, pathParams map[string]string) (proto.Message, runtime.ServerMetadata, error) {
379 var protoReq OLTAlarmRequest
380 var metadata runtime.ServerMetadata
381
382 var (
383 val string
384 ok bool
385 err error
386 _ = err
387 )
388
389 val, ok = pathParams["InterfaceType"]
390 if !ok {
391 return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "InterfaceType")
392 }
393
394 protoReq.InterfaceType, err = runtime.String(val)
395
396 if err != nil {
397 return nil, metadata, status.Errorf(codes.InvalidArgument, "type mismatch, parameter: %s, error: %v", "InterfaceType", err)
398 }
399
400 val, ok = pathParams["InterfaceID"]
401 if !ok {
402 return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "InterfaceID")
403 }
404
405 protoReq.InterfaceID, err = runtime.Uint32(val)
406
407 if err != nil {
408 return nil, metadata, status.Errorf(codes.InvalidArgument, "type mismatch, parameter: %s, error: %v", "InterfaceID", err)
409 }
410
411 val, ok = pathParams["Status"]
412 if !ok {
413 return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "Status")
414 }
415
416 protoReq.Status, err = runtime.String(val)
417
418 if err != nil {
419 return nil, metadata, status.Errorf(codes.InvalidArgument, "type mismatch, parameter: %s, error: %v", "Status", err)
420 }
421
422 msg, err := client.SetOltAlarmIndication(ctx, &protoReq, grpc.Header(&metadata.HeaderMD), grpc.Trailer(&metadata.TrailerMD))
423 return msg, metadata, err
424
425}
426
427func local_request_BBSim_SetOltAlarmIndication_0(ctx context.Context, marshaler runtime.Marshaler, server BBSimServer, req *http.Request, pathParams map[string]string) (proto.Message, runtime.ServerMetadata, error) {
428 var protoReq OLTAlarmRequest
429 var metadata runtime.ServerMetadata
430
431 var (
432 val string
433 ok bool
434 err error
435 _ = err
436 )
437
438 val, ok = pathParams["InterfaceType"]
439 if !ok {
440 return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "InterfaceType")
441 }
442
443 protoReq.InterfaceType, err = runtime.String(val)
444
445 if err != nil {
446 return nil, metadata, status.Errorf(codes.InvalidArgument, "type mismatch, parameter: %s, error: %v", "InterfaceType", err)
447 }
448
449 val, ok = pathParams["InterfaceID"]
450 if !ok {
451 return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "InterfaceID")
452 }
453
454 protoReq.InterfaceID, err = runtime.Uint32(val)
455
456 if err != nil {
457 return nil, metadata, status.Errorf(codes.InvalidArgument, "type mismatch, parameter: %s, error: %v", "InterfaceID", err)
458 }
459
460 val, ok = pathParams["Status"]
461 if !ok {
462 return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "Status")
463 }
464
465 protoReq.Status, err = runtime.String(val)
466
467 if err != nil {
468 return nil, metadata, status.Errorf(codes.InvalidArgument, "type mismatch, parameter: %s, error: %v", "Status", err)
469 }
470
471 msg, err := server.SetOltAlarmIndication(ctx, &protoReq)
Pragya Arya694ece02020-02-07 13:03:47 +0530472 return msg, metadata, err
473
474}
475
Pragya Arya8bdb4532020-03-02 17:08:09 +0530476func request_BBSim_GetFlows_0(ctx context.Context, marshaler runtime.Marshaler, client BBSimClient, req *http.Request, pathParams map[string]string) (proto.Message, runtime.ServerMetadata, error) {
477 var protoReq ONURequest
478 var metadata runtime.ServerMetadata
479
480 var (
481 val string
482 ok bool
483 err error
484 _ = err
485 )
486
487 val, ok = pathParams["SerialNumber"]
488 if !ok {
489 return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "SerialNumber")
490 }
491
492 protoReq.SerialNumber, err = runtime.String(val)
493
494 if err != nil {
495 return nil, metadata, status.Errorf(codes.InvalidArgument, "type mismatch, parameter: %s, error: %v", "SerialNumber", err)
496 }
497
498 msg, err := client.GetFlows(ctx, &protoReq, grpc.Header(&metadata.HeaderMD), grpc.Trailer(&metadata.TrailerMD))
499 return msg, metadata, err
500
501}
502
503func local_request_BBSim_GetFlows_0(ctx context.Context, marshaler runtime.Marshaler, server BBSimServer, req *http.Request, pathParams map[string]string) (proto.Message, runtime.ServerMetadata, error) {
504 var protoReq ONURequest
505 var metadata runtime.ServerMetadata
506
507 var (
508 val string
509 ok bool
510 err error
511 _ = err
512 )
513
514 val, ok = pathParams["SerialNumber"]
515 if !ok {
516 return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "SerialNumber")
517 }
518
519 protoReq.SerialNumber, err = runtime.String(val)
520
521 if err != nil {
522 return nil, metadata, status.Errorf(codes.InvalidArgument, "type mismatch, parameter: %s, error: %v", "SerialNumber", err)
523 }
524
525 msg, err := server.GetFlows(ctx, &protoReq)
526 return msg, metadata, err
527
528}
529
530var (
531 filter_BBSim_GetFlows_1 = &utilities.DoubleArray{Encoding: map[string]int{}, Base: []int(nil), Check: []int(nil)}
532)
533
534func request_BBSim_GetFlows_1(ctx context.Context, marshaler runtime.Marshaler, client BBSimClient, req *http.Request, pathParams map[string]string) (proto.Message, runtime.ServerMetadata, error) {
535 var protoReq ONURequest
536 var metadata runtime.ServerMetadata
537
538 if err := req.ParseForm(); err != nil {
539 return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
540 }
541 if err := runtime.PopulateQueryParameters(&protoReq, req.Form, filter_BBSim_GetFlows_1); err != nil {
542 return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
543 }
544
545 msg, err := client.GetFlows(ctx, &protoReq, grpc.Header(&metadata.HeaderMD), grpc.Trailer(&metadata.TrailerMD))
546 return msg, metadata, err
547
548}
549
550func local_request_BBSim_GetFlows_1(ctx context.Context, marshaler runtime.Marshaler, server BBSimServer, req *http.Request, pathParams map[string]string) (proto.Message, runtime.ServerMetadata, error) {
551 var protoReq ONURequest
552 var metadata runtime.ServerMetadata
553
554 if err := runtime.PopulateQueryParameters(&protoReq, req.URL.Query(), filter_BBSim_GetFlows_1); err != nil {
555 return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
556 }
557
558 msg, err := server.GetFlows(ctx, &protoReq)
559 return msg, metadata, err
560
561}
562
Anand S Katti09541352020-01-29 15:54:01 +0530563func request_BBSim_GetOnuTrafficSchedulers_0(ctx context.Context, marshaler runtime.Marshaler, client BBSimClient, req *http.Request, pathParams map[string]string) (proto.Message, runtime.ServerMetadata, error) {
564 var protoReq ONURequest
565 var metadata runtime.ServerMetadata
566
567 var (
568 val string
569 ok bool
570 err error
571 _ = err
572 )
573
574 val, ok = pathParams["SerialNumber"]
575 if !ok {
576 return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "SerialNumber")
577 }
578
579 protoReq.SerialNumber, err = runtime.String(val)
580
581 if err != nil {
582 return nil, metadata, status.Errorf(codes.InvalidArgument, "type mismatch, parameter: %s, error: %v", "SerialNumber", err)
583 }
584
585 msg, err := client.GetOnuTrafficSchedulers(ctx, &protoReq, grpc.Header(&metadata.HeaderMD), grpc.Trailer(&metadata.TrailerMD))
586 return msg, metadata, err
587
588}
589
590func local_request_BBSim_GetOnuTrafficSchedulers_0(ctx context.Context, marshaler runtime.Marshaler, server BBSimServer, req *http.Request, pathParams map[string]string) (proto.Message, runtime.ServerMetadata, error) {
591 var protoReq ONURequest
592 var metadata runtime.ServerMetadata
593
594 var (
595 val string
596 ok bool
597 err error
598 _ = err
599 )
600
601 val, ok = pathParams["SerialNumber"]
602 if !ok {
603 return nil, metadata, status.Errorf(codes.InvalidArgument, "missing parameter %s", "SerialNumber")
604 }
605
606 protoReq.SerialNumber, err = runtime.String(val)
607
608 if err != nil {
609 return nil, metadata, status.Errorf(codes.InvalidArgument, "type mismatch, parameter: %s, error: %v", "SerialNumber", err)
610 }
611
612 msg, err := server.GetOnuTrafficSchedulers(ctx, &protoReq)
613 return msg, metadata, err
614
615}
616
Pragya Arya1cbefa42020-01-13 12:15:29 +0530617// RegisterBBSimHandlerServer registers the http handlers for service BBSim to "mux".
618// UnaryRPC :call BBSimServer directly.
619// StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906.
620func RegisterBBSimHandlerServer(ctx context.Context, mux *runtime.ServeMux, server BBSimServer) error {
621
622 mux.Handle("GET", pattern_BBSim_Version_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) {
623 ctx, cancel := context.WithCancel(req.Context())
624 defer cancel()
625 inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req)
626 rctx, err := runtime.AnnotateIncomingContext(ctx, mux, req)
627 if err != nil {
628 runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
629 return
630 }
631 resp, md, err := local_request_BBSim_Version_0(rctx, inboundMarshaler, server, req, pathParams)
632 ctx = runtime.NewServerMetadataContext(ctx, md)
633 if err != nil {
634 runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
635 return
636 }
637
638 forward_BBSim_Version_0(ctx, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)
639
640 })
641
642 mux.Handle("GET", pattern_BBSim_GetOlt_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) {
643 ctx, cancel := context.WithCancel(req.Context())
644 defer cancel()
645 inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req)
646 rctx, err := runtime.AnnotateIncomingContext(ctx, mux, req)
647 if err != nil {
648 runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
649 return
650 }
651 resp, md, err := local_request_BBSim_GetOlt_0(rctx, inboundMarshaler, server, req, pathParams)
652 ctx = runtime.NewServerMetadataContext(ctx, md)
653 if err != nil {
654 runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
655 return
656 }
657
658 forward_BBSim_GetOlt_0(ctx, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)
659
660 })
661
662 mux.Handle("GET", pattern_BBSim_GetOlt_1, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) {
663 ctx, cancel := context.WithCancel(req.Context())
664 defer cancel()
665 inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req)
666 rctx, err := runtime.AnnotateIncomingContext(ctx, mux, req)
667 if err != nil {
668 runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
669 return
670 }
671 resp, md, err := local_request_BBSim_GetOlt_1(rctx, inboundMarshaler, server, req, pathParams)
672 ctx = runtime.NewServerMetadataContext(ctx, md)
673 if err != nil {
674 runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
675 return
676 }
677
678 forward_BBSim_GetOlt_1(ctx, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)
679
680 })
681
682 mux.Handle("GET", pattern_BBSim_GetONUs_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) {
683 ctx, cancel := context.WithCancel(req.Context())
684 defer cancel()
685 inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req)
686 rctx, err := runtime.AnnotateIncomingContext(ctx, mux, req)
687 if err != nil {
688 runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
689 return
690 }
691 resp, md, err := local_request_BBSim_GetONUs_0(rctx, inboundMarshaler, server, req, pathParams)
692 ctx = runtime.NewServerMetadataContext(ctx, md)
693 if err != nil {
694 runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
695 return
696 }
697
698 forward_BBSim_GetONUs_0(ctx, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)
699
700 })
701
702 mux.Handle("GET", pattern_BBSim_GetONU_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) {
703 ctx, cancel := context.WithCancel(req.Context())
704 defer cancel()
705 inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req)
706 rctx, err := runtime.AnnotateIncomingContext(ctx, mux, req)
707 if err != nil {
708 runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
709 return
710 }
711 resp, md, err := local_request_BBSim_GetONU_0(rctx, inboundMarshaler, server, req, pathParams)
712 ctx = runtime.NewServerMetadataContext(ctx, md)
713 if err != nil {
714 runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
715 return
716 }
717
718 forward_BBSim_GetONU_0(ctx, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)
719
720 })
721
722 mux.Handle("DELETE", pattern_BBSim_ShutdownONU_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) {
723 ctx, cancel := context.WithCancel(req.Context())
724 defer cancel()
725 inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req)
726 rctx, err := runtime.AnnotateIncomingContext(ctx, mux, req)
727 if err != nil {
728 runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
729 return
730 }
731 resp, md, err := local_request_BBSim_ShutdownONU_0(rctx, inboundMarshaler, server, req, pathParams)
732 ctx = runtime.NewServerMetadataContext(ctx, md)
733 if err != nil {
734 runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
735 return
736 }
737
738 forward_BBSim_ShutdownONU_0(ctx, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)
739
740 })
741
742 mux.Handle("POST", pattern_BBSim_PoweronONU_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) {
743 ctx, cancel := context.WithCancel(req.Context())
744 defer cancel()
745 inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req)
746 rctx, err := runtime.AnnotateIncomingContext(ctx, mux, req)
747 if err != nil {
748 runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
749 return
750 }
751 resp, md, err := local_request_BBSim_PoweronONU_0(rctx, inboundMarshaler, server, req, pathParams)
752 ctx = runtime.NewServerMetadataContext(ctx, md)
753 if err != nil {
754 runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
755 return
756 }
757
758 forward_BBSim_PoweronONU_0(ctx, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)
759
760 })
761
Anand S Katti86552f92020-03-03 21:56:32 +0530762 mux.Handle("POST", pattern_BBSim_SetOnuAlarmIndication_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) {
Pragya Arya694ece02020-02-07 13:03:47 +0530763 ctx, cancel := context.WithCancel(req.Context())
764 defer cancel()
765 inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req)
766 rctx, err := runtime.AnnotateIncomingContext(ctx, mux, req)
767 if err != nil {
768 runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
769 return
770 }
Anand S Katti86552f92020-03-03 21:56:32 +0530771 resp, md, err := local_request_BBSim_SetOnuAlarmIndication_0(rctx, inboundMarshaler, server, req, pathParams)
Pragya Arya694ece02020-02-07 13:03:47 +0530772 ctx = runtime.NewServerMetadataContext(ctx, md)
773 if err != nil {
774 runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
775 return
776 }
777
Anand S Katti86552f92020-03-03 21:56:32 +0530778 forward_BBSim_SetOnuAlarmIndication_0(ctx, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)
779
780 })
781
782 mux.Handle("POST", pattern_BBSim_SetOltAlarmIndication_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) {
783 ctx, cancel := context.WithCancel(req.Context())
784 defer cancel()
785 inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req)
786 rctx, err := runtime.AnnotateIncomingContext(ctx, mux, req)
787 if err != nil {
788 runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
789 return
790 }
791 resp, md, err := local_request_BBSim_SetOltAlarmIndication_0(rctx, inboundMarshaler, server, req, pathParams)
792 ctx = runtime.NewServerMetadataContext(ctx, md)
793 if err != nil {
794 runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
795 return
796 }
797
798 forward_BBSim_SetOltAlarmIndication_0(ctx, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)
Pragya Arya694ece02020-02-07 13:03:47 +0530799
800 })
801
Pragya Arya8bdb4532020-03-02 17:08:09 +0530802 mux.Handle("GET", pattern_BBSim_GetFlows_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) {
803 ctx, cancel := context.WithCancel(req.Context())
804 defer cancel()
805 inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req)
806 rctx, err := runtime.AnnotateIncomingContext(ctx, mux, req)
807 if err != nil {
808 runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
809 return
810 }
811 resp, md, err := local_request_BBSim_GetFlows_0(rctx, inboundMarshaler, server, req, pathParams)
812 ctx = runtime.NewServerMetadataContext(ctx, md)
813 if err != nil {
814 runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
815 return
816 }
817
818 forward_BBSim_GetFlows_0(ctx, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)
819
820 })
821
822 mux.Handle("GET", pattern_BBSim_GetFlows_1, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) {
823 ctx, cancel := context.WithCancel(req.Context())
824 defer cancel()
825 inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req)
826 rctx, err := runtime.AnnotateIncomingContext(ctx, mux, req)
827 if err != nil {
828 runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
829 return
830 }
831 resp, md, err := local_request_BBSim_GetFlows_1(rctx, inboundMarshaler, server, req, pathParams)
832 ctx = runtime.NewServerMetadataContext(ctx, md)
833 if err != nil {
834 runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
835 return
836 }
837
838 forward_BBSim_GetFlows_1(ctx, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)
839
840 })
841
Anand S Katti09541352020-01-29 15:54:01 +0530842 mux.Handle("GET", pattern_BBSim_GetOnuTrafficSchedulers_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) {
843 ctx, cancel := context.WithCancel(req.Context())
844 defer cancel()
845 inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req)
846 rctx, err := runtime.AnnotateIncomingContext(ctx, mux, req)
847 if err != nil {
848 runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
849 return
850 }
851 resp, md, err := local_request_BBSim_GetOnuTrafficSchedulers_0(rctx, inboundMarshaler, server, req, pathParams)
852 ctx = runtime.NewServerMetadataContext(ctx, md)
853 if err != nil {
854 runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
855 return
856 }
857
858 forward_BBSim_GetOnuTrafficSchedulers_0(ctx, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)
859
860 })
861
Pragya Arya1cbefa42020-01-13 12:15:29 +0530862 return nil
863}
864
Matteo Scandoloa6a3aee2019-11-26 13:30:14 -0700865// RegisterBBSimHandlerFromEndpoint is same as RegisterBBSimHandler but
866// automatically dials to "endpoint" and closes the connection when "ctx" gets done.
867func RegisterBBSimHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error) {
868 conn, err := grpc.Dial(endpoint, opts...)
869 if err != nil {
870 return err
871 }
872 defer func() {
873 if err != nil {
874 if cerr := conn.Close(); cerr != nil {
875 grpclog.Infof("Failed to close conn to %s: %v", endpoint, cerr)
876 }
877 return
878 }
879 go func() {
880 <-ctx.Done()
881 if cerr := conn.Close(); cerr != nil {
882 grpclog.Infof("Failed to close conn to %s: %v", endpoint, cerr)
883 }
884 }()
885 }()
886
887 return RegisterBBSimHandler(ctx, mux, conn)
888}
889
890// RegisterBBSimHandler registers the http handlers for service BBSim to "mux".
891// The handlers forward requests to the grpc endpoint over "conn".
892func RegisterBBSimHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error {
893 return RegisterBBSimHandlerClient(ctx, mux, NewBBSimClient(conn))
894}
895
896// RegisterBBSimHandlerClient registers the http handlers for service BBSim
897// to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "BBSimClient".
898// Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "BBSimClient"
899// doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in
900// "BBSimClient" to call the correct interceptors.
901func RegisterBBSimHandlerClient(ctx context.Context, mux *runtime.ServeMux, client BBSimClient) error {
902
903 mux.Handle("GET", pattern_BBSim_Version_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) {
904 ctx, cancel := context.WithCancel(req.Context())
905 defer cancel()
906 inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req)
907 rctx, err := runtime.AnnotateContext(ctx, mux, req)
908 if err != nil {
909 runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
910 return
911 }
912 resp, md, err := request_BBSim_Version_0(rctx, inboundMarshaler, client, req, pathParams)
913 ctx = runtime.NewServerMetadataContext(ctx, md)
914 if err != nil {
915 runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
916 return
917 }
918
919 forward_BBSim_Version_0(ctx, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)
920
921 })
922
923 mux.Handle("GET", pattern_BBSim_GetOlt_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) {
924 ctx, cancel := context.WithCancel(req.Context())
925 defer cancel()
926 inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req)
927 rctx, err := runtime.AnnotateContext(ctx, mux, req)
928 if err != nil {
929 runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
930 return
931 }
932 resp, md, err := request_BBSim_GetOlt_0(rctx, inboundMarshaler, client, req, pathParams)
933 ctx = runtime.NewServerMetadataContext(ctx, md)
934 if err != nil {
935 runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
936 return
937 }
938
939 forward_BBSim_GetOlt_0(ctx, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)
940
941 })
942
943 mux.Handle("GET", pattern_BBSim_GetOlt_1, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) {
944 ctx, cancel := context.WithCancel(req.Context())
945 defer cancel()
946 inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req)
947 rctx, err := runtime.AnnotateContext(ctx, mux, req)
948 if err != nil {
949 runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
950 return
951 }
952 resp, md, err := request_BBSim_GetOlt_1(rctx, inboundMarshaler, client, req, pathParams)
953 ctx = runtime.NewServerMetadataContext(ctx, md)
954 if err != nil {
955 runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
956 return
957 }
958
959 forward_BBSim_GetOlt_1(ctx, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)
960
961 })
962
963 mux.Handle("GET", pattern_BBSim_GetONUs_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) {
964 ctx, cancel := context.WithCancel(req.Context())
965 defer cancel()
966 inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req)
967 rctx, err := runtime.AnnotateContext(ctx, mux, req)
968 if err != nil {
969 runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
970 return
971 }
972 resp, md, err := request_BBSim_GetONUs_0(rctx, inboundMarshaler, client, req, pathParams)
973 ctx = runtime.NewServerMetadataContext(ctx, md)
974 if err != nil {
975 runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
976 return
977 }
978
979 forward_BBSim_GetONUs_0(ctx, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)
980
981 })
982
983 mux.Handle("GET", pattern_BBSim_GetONU_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) {
984 ctx, cancel := context.WithCancel(req.Context())
985 defer cancel()
986 inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req)
987 rctx, err := runtime.AnnotateContext(ctx, mux, req)
988 if err != nil {
989 runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
990 return
991 }
992 resp, md, err := request_BBSim_GetONU_0(rctx, inboundMarshaler, client, req, pathParams)
993 ctx = runtime.NewServerMetadataContext(ctx, md)
994 if err != nil {
995 runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
996 return
997 }
998
999 forward_BBSim_GetONU_0(ctx, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)
1000
1001 })
1002
Pragya Arya1cbefa42020-01-13 12:15:29 +05301003 mux.Handle("DELETE", pattern_BBSim_ShutdownONU_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) {
1004 ctx, cancel := context.WithCancel(req.Context())
1005 defer cancel()
1006 inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req)
1007 rctx, err := runtime.AnnotateContext(ctx, mux, req)
1008 if err != nil {
1009 runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
1010 return
1011 }
1012 resp, md, err := request_BBSim_ShutdownONU_0(rctx, inboundMarshaler, client, req, pathParams)
1013 ctx = runtime.NewServerMetadataContext(ctx, md)
1014 if err != nil {
1015 runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
1016 return
1017 }
1018
1019 forward_BBSim_ShutdownONU_0(ctx, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)
1020
1021 })
1022
1023 mux.Handle("POST", pattern_BBSim_PoweronONU_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) {
1024 ctx, cancel := context.WithCancel(req.Context())
1025 defer cancel()
1026 inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req)
1027 rctx, err := runtime.AnnotateContext(ctx, mux, req)
1028 if err != nil {
1029 runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
1030 return
1031 }
1032 resp, md, err := request_BBSim_PoweronONU_0(rctx, inboundMarshaler, client, req, pathParams)
1033 ctx = runtime.NewServerMetadataContext(ctx, md)
1034 if err != nil {
1035 runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
1036 return
1037 }
1038
1039 forward_BBSim_PoweronONU_0(ctx, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)
1040
1041 })
1042
Anand S Katti86552f92020-03-03 21:56:32 +05301043 mux.Handle("POST", pattern_BBSim_SetOnuAlarmIndication_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) {
Pragya Arya694ece02020-02-07 13:03:47 +05301044 ctx, cancel := context.WithCancel(req.Context())
1045 defer cancel()
1046 inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req)
1047 rctx, err := runtime.AnnotateContext(ctx, mux, req)
1048 if err != nil {
1049 runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
1050 return
1051 }
Anand S Katti86552f92020-03-03 21:56:32 +05301052 resp, md, err := request_BBSim_SetOnuAlarmIndication_0(rctx, inboundMarshaler, client, req, pathParams)
Pragya Arya694ece02020-02-07 13:03:47 +05301053 ctx = runtime.NewServerMetadataContext(ctx, md)
1054 if err != nil {
1055 runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
1056 return
1057 }
1058
Anand S Katti86552f92020-03-03 21:56:32 +05301059 forward_BBSim_SetOnuAlarmIndication_0(ctx, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)
1060
1061 })
1062
1063 mux.Handle("POST", pattern_BBSim_SetOltAlarmIndication_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) {
1064 ctx, cancel := context.WithCancel(req.Context())
1065 defer cancel()
1066 inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req)
1067 rctx, err := runtime.AnnotateContext(ctx, mux, req)
1068 if err != nil {
1069 runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
1070 return
1071 }
1072 resp, md, err := request_BBSim_SetOltAlarmIndication_0(rctx, inboundMarshaler, client, req, pathParams)
1073 ctx = runtime.NewServerMetadataContext(ctx, md)
1074 if err != nil {
1075 runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
1076 return
1077 }
1078
1079 forward_BBSim_SetOltAlarmIndication_0(ctx, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)
Pragya Arya694ece02020-02-07 13:03:47 +05301080
1081 })
1082
Pragya Arya8bdb4532020-03-02 17:08:09 +05301083 mux.Handle("GET", pattern_BBSim_GetFlows_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) {
1084 ctx, cancel := context.WithCancel(req.Context())
1085 defer cancel()
1086 inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req)
1087 rctx, err := runtime.AnnotateContext(ctx, mux, req)
1088 if err != nil {
1089 runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
1090 return
1091 }
1092 resp, md, err := request_BBSim_GetFlows_0(rctx, inboundMarshaler, client, req, pathParams)
1093 ctx = runtime.NewServerMetadataContext(ctx, md)
1094 if err != nil {
1095 runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
1096 return
1097 }
1098
1099 forward_BBSim_GetFlows_0(ctx, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)
1100
1101 })
1102
1103 mux.Handle("GET", pattern_BBSim_GetFlows_1, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) {
1104 ctx, cancel := context.WithCancel(req.Context())
1105 defer cancel()
1106 inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req)
1107 rctx, err := runtime.AnnotateContext(ctx, mux, req)
1108 if err != nil {
1109 runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
1110 return
1111 }
1112 resp, md, err := request_BBSim_GetFlows_1(rctx, inboundMarshaler, client, req, pathParams)
1113 ctx = runtime.NewServerMetadataContext(ctx, md)
1114 if err != nil {
1115 runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
1116 return
1117 }
1118
1119 forward_BBSim_GetFlows_1(ctx, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)
1120
1121 })
1122
Anand S Katti09541352020-01-29 15:54:01 +05301123 mux.Handle("GET", pattern_BBSim_GetOnuTrafficSchedulers_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) {
1124 ctx, cancel := context.WithCancel(req.Context())
1125 defer cancel()
1126 inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req)
1127 rctx, err := runtime.AnnotateContext(ctx, mux, req)
1128 if err != nil {
1129 runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
1130 return
1131 }
1132 resp, md, err := request_BBSim_GetOnuTrafficSchedulers_0(rctx, inboundMarshaler, client, req, pathParams)
1133 ctx = runtime.NewServerMetadataContext(ctx, md)
1134 if err != nil {
1135 runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
1136 return
1137 }
1138
1139 forward_BBSim_GetOnuTrafficSchedulers_0(ctx, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)
1140
1141 })
1142
Matteo Scandoloa6a3aee2019-11-26 13:30:14 -07001143 return nil
1144}
1145
1146var (
1147 pattern_BBSim_Version_0 = runtime.MustPattern(runtime.NewPattern(1, []int{2, 0, 2, 1}, []string{"v1", "version"}, "", runtime.AssumeColonVerbOpt(true)))
1148
1149 pattern_BBSim_GetOlt_0 = runtime.MustPattern(runtime.NewPattern(1, []int{2, 0, 2, 1}, []string{"v1", "olt"}, "", runtime.AssumeColonVerbOpt(true)))
1150
1151 pattern_BBSim_GetOlt_1 = runtime.MustPattern(runtime.NewPattern(1, []int{2, 0, 2, 1, 2, 2}, []string{"v1", "olt", "status"}, "", runtime.AssumeColonVerbOpt(true)))
1152
1153 pattern_BBSim_GetONUs_0 = runtime.MustPattern(runtime.NewPattern(1, []int{2, 0, 2, 1, 2, 2}, []string{"v1", "olt", "onus"}, "", runtime.AssumeColonVerbOpt(true)))
1154
1155 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)))
Pragya Arya1cbefa42020-01-13 12:15:29 +05301156
1157 pattern_BBSim_ShutdownONU_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)))
1158
1159 pattern_BBSim_PoweronONU_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)))
Pragya Arya694ece02020-02-07 13:03:47 +05301160
Anand S Katti86552f92020-03-03 21:56:32 +05301161 pattern_BBSim_SetOnuAlarmIndication_0 = runtime.MustPattern(runtime.NewPattern(1, []int{2, 0, 2, 1, 2, 2, 1, 0, 4, 1, 5, 3, 2, 4, 1, 0, 4, 1, 5, 5, 1, 0, 4, 1, 5, 6}, []string{"v1", "olt", "onus", "SerialNumber", "alarms", "AlarmType", "Status"}, "", runtime.AssumeColonVerbOpt(true)))
1162
1163 pattern_BBSim_SetOltAlarmIndication_0 = runtime.MustPattern(runtime.NewPattern(1, []int{2, 0, 2, 1, 2, 2, 1, 0, 4, 1, 5, 3, 1, 0, 4, 1, 5, 4, 2, 5, 2, 6, 1, 0, 4, 1, 5, 7}, []string{"v1", "olt", "ports", "InterfaceType", "InterfaceID", "alarms", "los", "Status"}, "", runtime.AssumeColonVerbOpt(true)))
Anand S Katti09541352020-01-29 15:54:01 +05301164
Pragya Arya8bdb4532020-03-02 17:08:09 +05301165 pattern_BBSim_GetFlows_0 = runtime.MustPattern(runtime.NewPattern(1, []int{2, 0, 2, 1, 2, 2, 1, 0, 4, 1, 5, 3, 2, 4}, []string{"v1", "olt", "onus", "SerialNumber", "flows"}, "", runtime.AssumeColonVerbOpt(true)))
1166
1167 pattern_BBSim_GetFlows_1 = runtime.MustPattern(runtime.NewPattern(1, []int{2, 0, 2, 1, 2, 2}, []string{"v1", "olt", "flows"}, "", runtime.AssumeColonVerbOpt(true)))
1168
Anand S Katti09541352020-01-29 15:54:01 +05301169 pattern_BBSim_GetOnuTrafficSchedulers_0 = runtime.MustPattern(runtime.NewPattern(1, []int{2, 0, 2, 1, 2, 2, 1, 0, 4, 1, 5, 3, 2, 4}, []string{"v1", "olt", "onus", "SerialNumber", "trafficschedulers"}, "", runtime.AssumeColonVerbOpt(true)))
Matteo Scandoloa6a3aee2019-11-26 13:30:14 -07001170)
1171
1172var (
1173 forward_BBSim_Version_0 = runtime.ForwardResponseMessage
1174
1175 forward_BBSim_GetOlt_0 = runtime.ForwardResponseMessage
1176
1177 forward_BBSim_GetOlt_1 = runtime.ForwardResponseMessage
1178
1179 forward_BBSim_GetONUs_0 = runtime.ForwardResponseMessage
1180
1181 forward_BBSim_GetONU_0 = runtime.ForwardResponseMessage
Pragya Arya1cbefa42020-01-13 12:15:29 +05301182
1183 forward_BBSim_ShutdownONU_0 = runtime.ForwardResponseMessage
1184
1185 forward_BBSim_PoweronONU_0 = runtime.ForwardResponseMessage
Pragya Arya694ece02020-02-07 13:03:47 +05301186
Anand S Katti86552f92020-03-03 21:56:32 +05301187 forward_BBSim_SetOnuAlarmIndication_0 = runtime.ForwardResponseMessage
1188
1189 forward_BBSim_SetOltAlarmIndication_0 = runtime.ForwardResponseMessage
Anand S Katti09541352020-01-29 15:54:01 +05301190
Pragya Arya8bdb4532020-03-02 17:08:09 +05301191 forward_BBSim_GetFlows_0 = runtime.ForwardResponseMessage
1192
1193 forward_BBSim_GetFlows_1 = runtime.ForwardResponseMessage
1194
Anand S Katti09541352020-01-29 15:54:01 +05301195 forward_BBSim_GetOnuTrafficSchedulers_0 = runtime.ForwardResponseMessage
Matteo Scandoloa6a3aee2019-11-26 13:30:14 -07001196)