blob: 2fac739bd7c52fe9c0c679ae79aee8809b32e958 [file] [log] [blame]
William Kurkian1b363f42019-03-12 15:28:12 -04001// Code generated by protoc-gen-go. DO NOT EDIT.
2// source: voltha_protos/ponsim.proto
3
4package voltha // import "github.com/opencord/voltha-protos/go/voltha"
5
6import proto "github.com/golang/protobuf/proto"
7import fmt "fmt"
8import math "math"
9import empty "github.com/golang/protobuf/ptypes/empty"
10import openflow_13 "github.com/opencord/voltha-protos/go/openflow_13"
11
12import (
13 context "golang.org/x/net/context"
14 grpc "google.golang.org/grpc"
15)
16
17// Reference imports to suppress errors if they are not otherwise used.
18var _ = proto.Marshal
19var _ = fmt.Errorf
20var _ = math.Inf
21
22// This is a compile-time assertion to ensure that this generated file
23// is compatible with the proto package it is being compiled against.
24// A compilation error at this line likely means your copy of the
25// proto package needs to be updated.
26const _ = proto.ProtoPackageIsVersion2 // please upgrade the proto package
27
28type PonSimOnuDeviceInfo struct {
29 UniPort int32 `protobuf:"varint,1,opt,name=uni_port,json=uniPort,proto3" json:"uni_port,omitempty"`
30 SerialNumber string `protobuf:"bytes,2,opt,name=serial_number,json=serialNumber,proto3" json:"serial_number,omitempty"`
31 XXX_NoUnkeyedLiteral struct{} `json:"-"`
32 XXX_unrecognized []byte `json:"-"`
33 XXX_sizecache int32 `json:"-"`
34}
35
36func (m *PonSimOnuDeviceInfo) Reset() { *m = PonSimOnuDeviceInfo{} }
37func (m *PonSimOnuDeviceInfo) String() string { return proto.CompactTextString(m) }
38func (*PonSimOnuDeviceInfo) ProtoMessage() {}
39func (*PonSimOnuDeviceInfo) Descriptor() ([]byte, []int) {
40 return fileDescriptor_ponsim_bb56e7457209b09b, []int{0}
41}
42func (m *PonSimOnuDeviceInfo) XXX_Unmarshal(b []byte) error {
43 return xxx_messageInfo_PonSimOnuDeviceInfo.Unmarshal(m, b)
44}
45func (m *PonSimOnuDeviceInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
46 return xxx_messageInfo_PonSimOnuDeviceInfo.Marshal(b, m, deterministic)
47}
48func (dst *PonSimOnuDeviceInfo) XXX_Merge(src proto.Message) {
49 xxx_messageInfo_PonSimOnuDeviceInfo.Merge(dst, src)
50}
51func (m *PonSimOnuDeviceInfo) XXX_Size() int {
52 return xxx_messageInfo_PonSimOnuDeviceInfo.Size(m)
53}
54func (m *PonSimOnuDeviceInfo) XXX_DiscardUnknown() {
55 xxx_messageInfo_PonSimOnuDeviceInfo.DiscardUnknown(m)
56}
57
58var xxx_messageInfo_PonSimOnuDeviceInfo proto.InternalMessageInfo
59
60func (m *PonSimOnuDeviceInfo) GetUniPort() int32 {
61 if m != nil {
62 return m.UniPort
63 }
64 return 0
65}
66
67func (m *PonSimOnuDeviceInfo) GetSerialNumber() string {
68 if m != nil {
69 return m.SerialNumber
70 }
71 return ""
72}
73
74type PonSimDeviceInfo struct {
75 NniPort int32 `protobuf:"varint,1,opt,name=nni_port,json=nniPort,proto3" json:"nni_port,omitempty"`
76 Onus []*PonSimOnuDeviceInfo `protobuf:"bytes,2,rep,name=onus,proto3" json:"onus,omitempty"`
77 XXX_NoUnkeyedLiteral struct{} `json:"-"`
78 XXX_unrecognized []byte `json:"-"`
79 XXX_sizecache int32 `json:"-"`
80}
81
82func (m *PonSimDeviceInfo) Reset() { *m = PonSimDeviceInfo{} }
83func (m *PonSimDeviceInfo) String() string { return proto.CompactTextString(m) }
84func (*PonSimDeviceInfo) ProtoMessage() {}
85func (*PonSimDeviceInfo) Descriptor() ([]byte, []int) {
86 return fileDescriptor_ponsim_bb56e7457209b09b, []int{1}
87}
88func (m *PonSimDeviceInfo) XXX_Unmarshal(b []byte) error {
89 return xxx_messageInfo_PonSimDeviceInfo.Unmarshal(m, b)
90}
91func (m *PonSimDeviceInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
92 return xxx_messageInfo_PonSimDeviceInfo.Marshal(b, m, deterministic)
93}
94func (dst *PonSimDeviceInfo) XXX_Merge(src proto.Message) {
95 xxx_messageInfo_PonSimDeviceInfo.Merge(dst, src)
96}
97func (m *PonSimDeviceInfo) XXX_Size() int {
98 return xxx_messageInfo_PonSimDeviceInfo.Size(m)
99}
100func (m *PonSimDeviceInfo) XXX_DiscardUnknown() {
101 xxx_messageInfo_PonSimDeviceInfo.DiscardUnknown(m)
102}
103
104var xxx_messageInfo_PonSimDeviceInfo proto.InternalMessageInfo
105
106func (m *PonSimDeviceInfo) GetNniPort() int32 {
107 if m != nil {
108 return m.NniPort
109 }
110 return 0
111}
112
113func (m *PonSimDeviceInfo) GetOnus() []*PonSimOnuDeviceInfo {
114 if m != nil {
115 return m.Onus
116 }
117 return nil
118}
119
120type FlowTable struct {
121 Port int32 `protobuf:"varint,1,opt,name=port,proto3" json:"port,omitempty"`
122 Flows []*openflow_13.OfpFlowStats `protobuf:"bytes,2,rep,name=flows,proto3" json:"flows,omitempty"`
123 XXX_NoUnkeyedLiteral struct{} `json:"-"`
124 XXX_unrecognized []byte `json:"-"`
125 XXX_sizecache int32 `json:"-"`
126}
127
128func (m *FlowTable) Reset() { *m = FlowTable{} }
129func (m *FlowTable) String() string { return proto.CompactTextString(m) }
130func (*FlowTable) ProtoMessage() {}
131func (*FlowTable) Descriptor() ([]byte, []int) {
132 return fileDescriptor_ponsim_bb56e7457209b09b, []int{2}
133}
134func (m *FlowTable) XXX_Unmarshal(b []byte) error {
135 return xxx_messageInfo_FlowTable.Unmarshal(m, b)
136}
137func (m *FlowTable) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
138 return xxx_messageInfo_FlowTable.Marshal(b, m, deterministic)
139}
140func (dst *FlowTable) XXX_Merge(src proto.Message) {
141 xxx_messageInfo_FlowTable.Merge(dst, src)
142}
143func (m *FlowTable) XXX_Size() int {
144 return xxx_messageInfo_FlowTable.Size(m)
145}
146func (m *FlowTable) XXX_DiscardUnknown() {
147 xxx_messageInfo_FlowTable.DiscardUnknown(m)
148}
149
150var xxx_messageInfo_FlowTable proto.InternalMessageInfo
151
152func (m *FlowTable) GetPort() int32 {
153 if m != nil {
154 return m.Port
155 }
156 return 0
157}
158
159func (m *FlowTable) GetFlows() []*openflow_13.OfpFlowStats {
160 if m != nil {
161 return m.Flows
162 }
163 return nil
164}
165
166type PonSimFrame struct {
167 Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
168 Payload []byte `protobuf:"bytes,2,opt,name=payload,proto3" json:"payload,omitempty"`
169 OutPort int32 `protobuf:"varint,3,opt,name=out_port,json=outPort,proto3" json:"out_port,omitempty"`
170 XXX_NoUnkeyedLiteral struct{} `json:"-"`
171 XXX_unrecognized []byte `json:"-"`
172 XXX_sizecache int32 `json:"-"`
173}
174
175func (m *PonSimFrame) Reset() { *m = PonSimFrame{} }
176func (m *PonSimFrame) String() string { return proto.CompactTextString(m) }
177func (*PonSimFrame) ProtoMessage() {}
178func (*PonSimFrame) Descriptor() ([]byte, []int) {
179 return fileDescriptor_ponsim_bb56e7457209b09b, []int{3}
180}
181func (m *PonSimFrame) XXX_Unmarshal(b []byte) error {
182 return xxx_messageInfo_PonSimFrame.Unmarshal(m, b)
183}
184func (m *PonSimFrame) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
185 return xxx_messageInfo_PonSimFrame.Marshal(b, m, deterministic)
186}
187func (dst *PonSimFrame) XXX_Merge(src proto.Message) {
188 xxx_messageInfo_PonSimFrame.Merge(dst, src)
189}
190func (m *PonSimFrame) XXX_Size() int {
191 return xxx_messageInfo_PonSimFrame.Size(m)
192}
193func (m *PonSimFrame) XXX_DiscardUnknown() {
194 xxx_messageInfo_PonSimFrame.DiscardUnknown(m)
195}
196
197var xxx_messageInfo_PonSimFrame proto.InternalMessageInfo
198
199func (m *PonSimFrame) GetId() string {
200 if m != nil {
201 return m.Id
202 }
203 return ""
204}
205
206func (m *PonSimFrame) GetPayload() []byte {
207 if m != nil {
208 return m.Payload
209 }
210 return nil
211}
212
213func (m *PonSimFrame) GetOutPort() int32 {
214 if m != nil {
215 return m.OutPort
216 }
217 return 0
218}
219
220type PonSimPacketCounter struct {
221 Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
222 Value int64 `protobuf:"varint,2,opt,name=value,proto3" json:"value,omitempty"`
223 XXX_NoUnkeyedLiteral struct{} `json:"-"`
224 XXX_unrecognized []byte `json:"-"`
225 XXX_sizecache int32 `json:"-"`
226}
227
228func (m *PonSimPacketCounter) Reset() { *m = PonSimPacketCounter{} }
229func (m *PonSimPacketCounter) String() string { return proto.CompactTextString(m) }
230func (*PonSimPacketCounter) ProtoMessage() {}
231func (*PonSimPacketCounter) Descriptor() ([]byte, []int) {
232 return fileDescriptor_ponsim_bb56e7457209b09b, []int{4}
233}
234func (m *PonSimPacketCounter) XXX_Unmarshal(b []byte) error {
235 return xxx_messageInfo_PonSimPacketCounter.Unmarshal(m, b)
236}
237func (m *PonSimPacketCounter) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
238 return xxx_messageInfo_PonSimPacketCounter.Marshal(b, m, deterministic)
239}
240func (dst *PonSimPacketCounter) XXX_Merge(src proto.Message) {
241 xxx_messageInfo_PonSimPacketCounter.Merge(dst, src)
242}
243func (m *PonSimPacketCounter) XXX_Size() int {
244 return xxx_messageInfo_PonSimPacketCounter.Size(m)
245}
246func (m *PonSimPacketCounter) XXX_DiscardUnknown() {
247 xxx_messageInfo_PonSimPacketCounter.DiscardUnknown(m)
248}
249
250var xxx_messageInfo_PonSimPacketCounter proto.InternalMessageInfo
251
252func (m *PonSimPacketCounter) GetName() string {
253 if m != nil {
254 return m.Name
255 }
256 return ""
257}
258
259func (m *PonSimPacketCounter) GetValue() int64 {
260 if m != nil {
261 return m.Value
262 }
263 return 0
264}
265
266type PonSimPortMetrics struct {
267 PortName string `protobuf:"bytes,1,opt,name=port_name,json=portName,proto3" json:"port_name,omitempty"`
268 Packets []*PonSimPacketCounter `protobuf:"bytes,2,rep,name=packets,proto3" json:"packets,omitempty"`
269 XXX_NoUnkeyedLiteral struct{} `json:"-"`
270 XXX_unrecognized []byte `json:"-"`
271 XXX_sizecache int32 `json:"-"`
272}
273
274func (m *PonSimPortMetrics) Reset() { *m = PonSimPortMetrics{} }
275func (m *PonSimPortMetrics) String() string { return proto.CompactTextString(m) }
276func (*PonSimPortMetrics) ProtoMessage() {}
277func (*PonSimPortMetrics) Descriptor() ([]byte, []int) {
278 return fileDescriptor_ponsim_bb56e7457209b09b, []int{5}
279}
280func (m *PonSimPortMetrics) XXX_Unmarshal(b []byte) error {
281 return xxx_messageInfo_PonSimPortMetrics.Unmarshal(m, b)
282}
283func (m *PonSimPortMetrics) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
284 return xxx_messageInfo_PonSimPortMetrics.Marshal(b, m, deterministic)
285}
286func (dst *PonSimPortMetrics) XXX_Merge(src proto.Message) {
287 xxx_messageInfo_PonSimPortMetrics.Merge(dst, src)
288}
289func (m *PonSimPortMetrics) XXX_Size() int {
290 return xxx_messageInfo_PonSimPortMetrics.Size(m)
291}
292func (m *PonSimPortMetrics) XXX_DiscardUnknown() {
293 xxx_messageInfo_PonSimPortMetrics.DiscardUnknown(m)
294}
295
296var xxx_messageInfo_PonSimPortMetrics proto.InternalMessageInfo
297
298func (m *PonSimPortMetrics) GetPortName() string {
299 if m != nil {
300 return m.PortName
301 }
302 return ""
303}
304
305func (m *PonSimPortMetrics) GetPackets() []*PonSimPacketCounter {
306 if m != nil {
307 return m.Packets
308 }
309 return nil
310}
311
312type PonSimMetrics struct {
313 Device string `protobuf:"bytes,1,opt,name=device,proto3" json:"device,omitempty"`
314 Metrics []*PonSimPortMetrics `protobuf:"bytes,2,rep,name=metrics,proto3" json:"metrics,omitempty"`
315 XXX_NoUnkeyedLiteral struct{} `json:"-"`
316 XXX_unrecognized []byte `json:"-"`
317 XXX_sizecache int32 `json:"-"`
318}
319
320func (m *PonSimMetrics) Reset() { *m = PonSimMetrics{} }
321func (m *PonSimMetrics) String() string { return proto.CompactTextString(m) }
322func (*PonSimMetrics) ProtoMessage() {}
323func (*PonSimMetrics) Descriptor() ([]byte, []int) {
324 return fileDescriptor_ponsim_bb56e7457209b09b, []int{6}
325}
326func (m *PonSimMetrics) XXX_Unmarshal(b []byte) error {
327 return xxx_messageInfo_PonSimMetrics.Unmarshal(m, b)
328}
329func (m *PonSimMetrics) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
330 return xxx_messageInfo_PonSimMetrics.Marshal(b, m, deterministic)
331}
332func (dst *PonSimMetrics) XXX_Merge(src proto.Message) {
333 xxx_messageInfo_PonSimMetrics.Merge(dst, src)
334}
335func (m *PonSimMetrics) XXX_Size() int {
336 return xxx_messageInfo_PonSimMetrics.Size(m)
337}
338func (m *PonSimMetrics) XXX_DiscardUnknown() {
339 xxx_messageInfo_PonSimMetrics.DiscardUnknown(m)
340}
341
342var xxx_messageInfo_PonSimMetrics proto.InternalMessageInfo
343
344func (m *PonSimMetrics) GetDevice() string {
345 if m != nil {
346 return m.Device
347 }
348 return ""
349}
350
351func (m *PonSimMetrics) GetMetrics() []*PonSimPortMetrics {
352 if m != nil {
353 return m.Metrics
354 }
355 return nil
356}
357
358type PonSimMetricsRequest struct {
359 Port int32 `protobuf:"varint,1,opt,name=port,proto3" json:"port,omitempty"`
360 XXX_NoUnkeyedLiteral struct{} `json:"-"`
361 XXX_unrecognized []byte `json:"-"`
362 XXX_sizecache int32 `json:"-"`
363}
364
365func (m *PonSimMetricsRequest) Reset() { *m = PonSimMetricsRequest{} }
366func (m *PonSimMetricsRequest) String() string { return proto.CompactTextString(m) }
367func (*PonSimMetricsRequest) ProtoMessage() {}
368func (*PonSimMetricsRequest) Descriptor() ([]byte, []int) {
369 return fileDescriptor_ponsim_bb56e7457209b09b, []int{7}
370}
371func (m *PonSimMetricsRequest) XXX_Unmarshal(b []byte) error {
372 return xxx_messageInfo_PonSimMetricsRequest.Unmarshal(m, b)
373}
374func (m *PonSimMetricsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
375 return xxx_messageInfo_PonSimMetricsRequest.Marshal(b, m, deterministic)
376}
377func (dst *PonSimMetricsRequest) XXX_Merge(src proto.Message) {
378 xxx_messageInfo_PonSimMetricsRequest.Merge(dst, src)
379}
380func (m *PonSimMetricsRequest) XXX_Size() int {
381 return xxx_messageInfo_PonSimMetricsRequest.Size(m)
382}
383func (m *PonSimMetricsRequest) XXX_DiscardUnknown() {
384 xxx_messageInfo_PonSimMetricsRequest.DiscardUnknown(m)
385}
386
387var xxx_messageInfo_PonSimMetricsRequest proto.InternalMessageInfo
388
389func (m *PonSimMetricsRequest) GetPort() int32 {
390 if m != nil {
391 return m.Port
392 }
393 return 0
394}
395
396func init() {
397 proto.RegisterType((*PonSimOnuDeviceInfo)(nil), "voltha.PonSimOnuDeviceInfo")
398 proto.RegisterType((*PonSimDeviceInfo)(nil), "voltha.PonSimDeviceInfo")
399 proto.RegisterType((*FlowTable)(nil), "voltha.FlowTable")
400 proto.RegisterType((*PonSimFrame)(nil), "voltha.PonSimFrame")
401 proto.RegisterType((*PonSimPacketCounter)(nil), "voltha.PonSimPacketCounter")
402 proto.RegisterType((*PonSimPortMetrics)(nil), "voltha.PonSimPortMetrics")
403 proto.RegisterType((*PonSimMetrics)(nil), "voltha.PonSimMetrics")
404 proto.RegisterType((*PonSimMetricsRequest)(nil), "voltha.PonSimMetricsRequest")
405}
406
407// Reference imports to suppress errors if they are not otherwise used.
408var _ context.Context
409var _ grpc.ClientConn
410
411// This is a compile-time assertion to ensure that this generated file
412// is compatible with the grpc package it is being compiled against.
413const _ = grpc.SupportPackageIsVersion4
414
415// PonSimClient is the client API for PonSim service.
416//
417// For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
418type PonSimClient interface {
419 SendFrame(ctx context.Context, in *PonSimFrame, opts ...grpc.CallOption) (*empty.Empty, error)
420 ReceiveFrames(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (PonSim_ReceiveFramesClient, error)
421 GetDeviceInfo(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*PonSimDeviceInfo, error)
422 UpdateFlowTable(ctx context.Context, in *FlowTable, opts ...grpc.CallOption) (*empty.Empty, error)
423 GetStats(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*PonSimMetrics, error)
424}
425
426type ponSimClient struct {
427 cc *grpc.ClientConn
428}
429
430func NewPonSimClient(cc *grpc.ClientConn) PonSimClient {
431 return &ponSimClient{cc}
432}
433
434func (c *ponSimClient) SendFrame(ctx context.Context, in *PonSimFrame, opts ...grpc.CallOption) (*empty.Empty, error) {
435 out := new(empty.Empty)
436 err := c.cc.Invoke(ctx, "/voltha.PonSim/SendFrame", in, out, opts...)
437 if err != nil {
438 return nil, err
439 }
440 return out, nil
441}
442
443func (c *ponSimClient) ReceiveFrames(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (PonSim_ReceiveFramesClient, error) {
444 stream, err := c.cc.NewStream(ctx, &_PonSim_serviceDesc.Streams[0], "/voltha.PonSim/ReceiveFrames", opts...)
445 if err != nil {
446 return nil, err
447 }
448 x := &ponSimReceiveFramesClient{stream}
449 if err := x.ClientStream.SendMsg(in); err != nil {
450 return nil, err
451 }
452 if err := x.ClientStream.CloseSend(); err != nil {
453 return nil, err
454 }
455 return x, nil
456}
457
458type PonSim_ReceiveFramesClient interface {
459 Recv() (*PonSimFrame, error)
460 grpc.ClientStream
461}
462
463type ponSimReceiveFramesClient struct {
464 grpc.ClientStream
465}
466
467func (x *ponSimReceiveFramesClient) Recv() (*PonSimFrame, error) {
468 m := new(PonSimFrame)
469 if err := x.ClientStream.RecvMsg(m); err != nil {
470 return nil, err
471 }
472 return m, nil
473}
474
475func (c *ponSimClient) GetDeviceInfo(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*PonSimDeviceInfo, error) {
476 out := new(PonSimDeviceInfo)
477 err := c.cc.Invoke(ctx, "/voltha.PonSim/GetDeviceInfo", in, out, opts...)
478 if err != nil {
479 return nil, err
480 }
481 return out, nil
482}
483
484func (c *ponSimClient) UpdateFlowTable(ctx context.Context, in *FlowTable, opts ...grpc.CallOption) (*empty.Empty, error) {
485 out := new(empty.Empty)
486 err := c.cc.Invoke(ctx, "/voltha.PonSim/UpdateFlowTable", in, out, opts...)
487 if err != nil {
488 return nil, err
489 }
490 return out, nil
491}
492
493func (c *ponSimClient) GetStats(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*PonSimMetrics, error) {
494 out := new(PonSimMetrics)
495 err := c.cc.Invoke(ctx, "/voltha.PonSim/GetStats", in, out, opts...)
496 if err != nil {
497 return nil, err
498 }
499 return out, nil
500}
501
502// PonSimServer is the server API for PonSim service.
503type PonSimServer interface {
504 SendFrame(context.Context, *PonSimFrame) (*empty.Empty, error)
505 ReceiveFrames(*empty.Empty, PonSim_ReceiveFramesServer) error
506 GetDeviceInfo(context.Context, *empty.Empty) (*PonSimDeviceInfo, error)
507 UpdateFlowTable(context.Context, *FlowTable) (*empty.Empty, error)
508 GetStats(context.Context, *empty.Empty) (*PonSimMetrics, error)
509}
510
511func RegisterPonSimServer(s *grpc.Server, srv PonSimServer) {
512 s.RegisterService(&_PonSim_serviceDesc, srv)
513}
514
515func _PonSim_SendFrame_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
516 in := new(PonSimFrame)
517 if err := dec(in); err != nil {
518 return nil, err
519 }
520 if interceptor == nil {
521 return srv.(PonSimServer).SendFrame(ctx, in)
522 }
523 info := &grpc.UnaryServerInfo{
524 Server: srv,
525 FullMethod: "/voltha.PonSim/SendFrame",
526 }
527 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
528 return srv.(PonSimServer).SendFrame(ctx, req.(*PonSimFrame))
529 }
530 return interceptor(ctx, in, info, handler)
531}
532
533func _PonSim_ReceiveFrames_Handler(srv interface{}, stream grpc.ServerStream) error {
534 m := new(empty.Empty)
535 if err := stream.RecvMsg(m); err != nil {
536 return err
537 }
538 return srv.(PonSimServer).ReceiveFrames(m, &ponSimReceiveFramesServer{stream})
539}
540
541type PonSim_ReceiveFramesServer interface {
542 Send(*PonSimFrame) error
543 grpc.ServerStream
544}
545
546type ponSimReceiveFramesServer struct {
547 grpc.ServerStream
548}
549
550func (x *ponSimReceiveFramesServer) Send(m *PonSimFrame) error {
551 return x.ServerStream.SendMsg(m)
552}
553
554func _PonSim_GetDeviceInfo_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
555 in := new(empty.Empty)
556 if err := dec(in); err != nil {
557 return nil, err
558 }
559 if interceptor == nil {
560 return srv.(PonSimServer).GetDeviceInfo(ctx, in)
561 }
562 info := &grpc.UnaryServerInfo{
563 Server: srv,
564 FullMethod: "/voltha.PonSim/GetDeviceInfo",
565 }
566 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
567 return srv.(PonSimServer).GetDeviceInfo(ctx, req.(*empty.Empty))
568 }
569 return interceptor(ctx, in, info, handler)
570}
571
572func _PonSim_UpdateFlowTable_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
573 in := new(FlowTable)
574 if err := dec(in); err != nil {
575 return nil, err
576 }
577 if interceptor == nil {
578 return srv.(PonSimServer).UpdateFlowTable(ctx, in)
579 }
580 info := &grpc.UnaryServerInfo{
581 Server: srv,
582 FullMethod: "/voltha.PonSim/UpdateFlowTable",
583 }
584 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
585 return srv.(PonSimServer).UpdateFlowTable(ctx, req.(*FlowTable))
586 }
587 return interceptor(ctx, in, info, handler)
588}
589
590func _PonSim_GetStats_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
591 in := new(empty.Empty)
592 if err := dec(in); err != nil {
593 return nil, err
594 }
595 if interceptor == nil {
596 return srv.(PonSimServer).GetStats(ctx, in)
597 }
598 info := &grpc.UnaryServerInfo{
599 Server: srv,
600 FullMethod: "/voltha.PonSim/GetStats",
601 }
602 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
603 return srv.(PonSimServer).GetStats(ctx, req.(*empty.Empty))
604 }
605 return interceptor(ctx, in, info, handler)
606}
607
608var _PonSim_serviceDesc = grpc.ServiceDesc{
609 ServiceName: "voltha.PonSim",
610 HandlerType: (*PonSimServer)(nil),
611 Methods: []grpc.MethodDesc{
612 {
613 MethodName: "SendFrame",
614 Handler: _PonSim_SendFrame_Handler,
615 },
616 {
617 MethodName: "GetDeviceInfo",
618 Handler: _PonSim_GetDeviceInfo_Handler,
619 },
620 {
621 MethodName: "UpdateFlowTable",
622 Handler: _PonSim_UpdateFlowTable_Handler,
623 },
624 {
625 MethodName: "GetStats",
626 Handler: _PonSim_GetStats_Handler,
627 },
628 },
629 Streams: []grpc.StreamDesc{
630 {
631 StreamName: "ReceiveFrames",
632 Handler: _PonSim_ReceiveFrames_Handler,
633 ServerStreams: true,
634 },
635 },
636 Metadata: "voltha_protos/ponsim.proto",
637}
638
639func init() { proto.RegisterFile("voltha_protos/ponsim.proto", fileDescriptor_ponsim_bb56e7457209b09b) }
640
641var fileDescriptor_ponsim_bb56e7457209b09b = []byte{
642 // 555 bytes of a gzipped FileDescriptorProto
643 0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0x7c, 0x94, 0x41, 0x6f, 0xd3, 0x4e,
644 0x10, 0xc5, 0x93, 0xb4, 0x4d, 0x9b, 0x69, 0xf3, 0xff, 0xd3, 0x6d, 0xa9, 0xd2, 0xf4, 0x40, 0xb4,
645 0x5c, 0x22, 0x50, 0x1d, 0xda, 0x88, 0x0b, 0x48, 0x80, 0x28, 0xb4, 0xe2, 0x40, 0x89, 0x36, 0xf4,
646 0x82, 0x10, 0x96, 0x63, 0x4f, 0x52, 0x0b, 0x7b, 0xc7, 0xd8, 0xbb, 0xa9, 0xfa, 0x0d, 0xf9, 0x58,
647 0xc8, 0xbb, 0x36, 0x89, 0xab, 0x84, 0xdb, 0xee, 0xf8, 0xe5, 0xf7, 0xe6, 0x8d, 0x27, 0x86, 0xee,
648 0x9c, 0x22, 0x75, 0xeb, 0xb9, 0x49, 0x4a, 0x8a, 0xb2, 0x41, 0x42, 0x32, 0x0b, 0x63, 0xc7, 0xdc,
649 0x58, 0xd3, 0x3e, 0xeb, 0x9e, 0xcc, 0x88, 0x66, 0x11, 0x0e, 0x4c, 0x75, 0xa2, 0xa7, 0x03, 0x8c,
650 0x13, 0x75, 0x6f, 0x45, 0xdd, 0x27, 0x55, 0x00, 0x25, 0x28, 0xa7, 0x11, 0xdd, 0xb9, 0x67, 0x43,
651 0x2b, 0xe0, 0x37, 0x70, 0x30, 0x22, 0x39, 0x0e, 0xe3, 0x2f, 0x52, 0x7f, 0xc0, 0x79, 0xe8, 0xe3,
652 0x27, 0x39, 0x25, 0x76, 0x0c, 0x3b, 0x5a, 0x86, 0x6e, 0x42, 0xa9, 0xea, 0xd4, 0x7b, 0xf5, 0xfe,
653 0x96, 0xd8, 0xd6, 0x32, 0x1c, 0x51, 0xaa, 0xd8, 0x53, 0x68, 0x67, 0x98, 0x86, 0x5e, 0xe4, 0x4a,
654 0x1d, 0x4f, 0x30, 0xed, 0x34, 0x7a, 0xf5, 0x7e, 0x4b, 0xec, 0xd9, 0xe2, 0xb5, 0xa9, 0xf1, 0x1f,
655 0xf0, 0xc8, 0x62, 0xab, 0x4c, 0xf9, 0x80, 0x29, 0x0b, 0xe6, 0x00, 0x36, 0x49, 0xea, 0xac, 0xd3,
656 0xe8, 0x6d, 0xf4, 0x77, 0xcf, 0x4f, 0x1c, 0xdb, 0xb5, 0xb3, 0xa2, 0x33, 0x61, 0x84, 0x5c, 0x40,
657 0xeb, 0x32, 0xa2, 0xbb, 0xaf, 0xde, 0x24, 0x42, 0xc6, 0x60, 0x73, 0x09, 0x6a, 0xce, 0xec, 0x0c,
658 0xb6, 0xf2, 0xa0, 0x0b, 0xe4, 0x72, 0x74, 0x9a, 0x26, 0xae, 0x39, 0x67, 0xca, 0x53, 0x99, 0xb0,
659 0x4a, 0x2e, 0x60, 0xd7, 0x1a, 0x5e, 0xa6, 0x5e, 0x8c, 0xec, 0x3f, 0x68, 0x84, 0x81, 0x61, 0xb6,
660 0x44, 0x23, 0x0c, 0x58, 0x07, 0xb6, 0x13, 0xef, 0x3e, 0x22, 0x2f, 0x30, 0x89, 0xf7, 0x44, 0x79,
661 0xcd, 0x83, 0x91, 0x56, 0x36, 0xd8, 0x86, 0x0d, 0x46, 0x5a, 0xe5, 0xc1, 0xf8, 0xdb, 0x72, 0xbc,
662 0x23, 0xcf, 0xff, 0x89, 0xea, 0x82, 0xb4, 0x54, 0x98, 0xe6, 0x1d, 0x4b, 0x2f, 0xc6, 0x82, 0x6e,
663 0xce, 0xec, 0x10, 0xb6, 0xe6, 0x5e, 0xa4, 0xd1, 0xd0, 0x37, 0x84, 0xbd, 0xf0, 0x19, 0xec, 0x17,
664 0x00, 0x4a, 0xd5, 0x67, 0x54, 0x69, 0xe8, 0x67, 0xec, 0x04, 0x5a, 0xb9, 0x99, 0xbb, 0xc4, 0xd8,
665 0xc9, 0x0b, 0xd7, 0x39, 0xe7, 0x65, 0xde, 0x67, 0x6e, 0xb6, 0x66, 0x9c, 0x95, 0x4e, 0x44, 0xa9,
666 0xe5, 0xdf, 0xa1, 0x6d, 0x9f, 0x97, 0x26, 0x47, 0xd0, 0x0c, 0xcc, 0xd8, 0x0b, 0x87, 0xe2, 0xc6,
667 0x86, 0xb0, 0x1d, 0x5b, 0x49, 0xc1, 0x3f, 0x7e, 0xc0, 0x5f, 0x34, 0x2a, 0x4a, 0x25, 0x7f, 0x06,
668 0x87, 0x15, 0xba, 0xc0, 0x5f, 0x1a, 0x33, 0xb5, 0xea, 0xd5, 0x9d, 0xff, 0x6e, 0x40, 0xd3, 0x8a,
669 0xd9, 0x2b, 0x68, 0x8d, 0x51, 0x06, 0xf6, 0x85, 0x1c, 0x54, 0x7d, 0x4c, 0xb1, 0x7b, 0xe4, 0xd8,
670 0xf5, 0x77, 0xca, 0xf5, 0x77, 0x3e, 0xe6, 0xeb, 0xcf, 0x6b, 0xec, 0x1d, 0xb4, 0x05, 0xfa, 0x18,
671 0xce, 0xd1, 0x28, 0x33, 0xb6, 0x46, 0xda, 0x5d, 0xc5, 0xe5, 0xb5, 0x17, 0x75, 0x76, 0x01, 0xed,
672 0x2b, 0x54, 0x4b, 0x1b, 0xbc, 0x8e, 0xd0, 0xa9, 0x12, 0x16, 0xbf, 0xe0, 0x35, 0xf6, 0x06, 0xfe,
673 0xbf, 0x49, 0x02, 0x4f, 0xe1, 0x62, 0x5f, 0xf7, 0x4b, 0xf9, 0xdf, 0xd2, 0x3f, 0x62, 0xbc, 0x86,
674 0x9d, 0x2b, 0x54, 0xe3, 0x7c, 0x51, 0xd7, 0xfa, 0x3f, 0xae, 0xfa, 0x17, 0x33, 0xe6, 0xb5, 0xf7,
675 0xa7, 0xdf, 0x9e, 0xcf, 0x42, 0x75, 0xab, 0x27, 0x8e, 0x4f, 0xb1, 0xf9, 0xf7, 0xfb, 0x94, 0x06,
676 0x03, 0xab, 0x3e, 0x2d, 0x3e, 0x0a, 0x33, 0x2a, 0x0a, 0x93, 0xa6, 0xa9, 0x0c, 0xff, 0x04, 0x00,
677 0x00, 0xff, 0xff, 0x62, 0xcb, 0x74, 0xbe, 0x77, 0x04, 0x00, 0x00,
678}