blob: 31f5673cdb70b7311d1449097b022f981addb022 [file] [log] [blame]
khenaidoo4c6543e2021-10-19 17:25:58 -04001// Code generated by protoc-gen-go. DO NOT EDIT.
2// source: voltha_protos/adapter_service.proto
3
4package adapter_service
5
6import (
7 context "context"
8 fmt "fmt"
9 proto "github.com/golang/protobuf/proto"
10 empty "github.com/golang/protobuf/ptypes/empty"
11 common "github.com/opencord/voltha-protos/v5/go/common"
12 core_adapter "github.com/opencord/voltha-protos/v5/go/core_adapter"
13 extension "github.com/opencord/voltha-protos/v5/go/extension"
14 health "github.com/opencord/voltha-protos/v5/go/health"
15 omci "github.com/opencord/voltha-protos/v5/go/omci"
16 voltha "github.com/opencord/voltha-protos/v5/go/voltha"
17 grpc "google.golang.org/grpc"
18 codes "google.golang.org/grpc/codes"
19 status "google.golang.org/grpc/status"
20 math "math"
21)
22
23// Reference imports to suppress errors if they are not otherwise used.
24var _ = proto.Marshal
25var _ = fmt.Errorf
26var _ = math.Inf
27
28// This is a compile-time assertion to ensure that this generated file
29// is compatible with the proto package it is being compiled against.
30// A compilation error at this line likely means your copy of the
31// proto package needs to be updated.
32const _ = proto.ProtoPackageIsVersion3 // please upgrade the proto package
33
34func init() {
35 proto.RegisterFile("voltha_protos/adapter_service.proto", fileDescriptor_038e6ec340f67698)
36}
37
38var fileDescriptor_038e6ec340f67698 = []byte{
khenaidoo257f3192021-12-15 16:46:37 -050039 // 853 bytes of a gzipped FileDescriptorProto
40 0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0xac, 0x96, 0xdf, 0x6e, 0xdb, 0x36,
41 0x14, 0xc6, 0x91, 0x0d, 0xd8, 0xc5, 0x49, 0x6c, 0x27, 0x6c, 0x96, 0x0e, 0x0a, 0x56, 0x74, 0xed,
42 0xcd, 0x6e, 0x2a, 0x0f, 0x2d, 0xda, 0x6e, 0x18, 0x86, 0xcd, 0xff, 0xea, 0x7a, 0x6b, 0xe1, 0xc0,
43 0x9a, 0x8b, 0x61, 0x37, 0x01, 0x2d, 0x1d, 0xcb, 0x44, 0x29, 0x52, 0x13, 0x8f, 0x9c, 0xf6, 0x0d,
44 0xf6, 0x08, 0x7b, 0xdc, 0x41, 0x12, 0xe5, 0x58, 0xaa, 0xdd, 0xd6, 0x4e, 0xee, 0xac, 0xf3, 0xf1,
45 0xfb, 0xf1, 0xf0, 0x1c, 0x9a, 0x24, 0x3c, 0x5c, 0x6a, 0x49, 0x0b, 0x7e, 0x19, 0x27, 0x9a, 0xb4,
46 0x69, 0xf3, 0x80, 0xc7, 0x84, 0xc9, 0xa5, 0xc1, 0x64, 0x29, 0x7c, 0x74, 0xf3, 0x30, 0x6b, 0xd5,
47 0xc2, 0xce, 0x79, 0xa8, 0x75, 0x28, 0xb1, 0x9d, 0xcb, 0xb3, 0x74, 0xde, 0xc6, 0x28, 0xa6, 0xf7,
48 0xc5, 0x68, 0xc7, 0xa9, 0x22, 0x7d, 0x1d, 0x45, 0x5a, 0x59, 0xed, 0x7e, 0x5d, 0x4b, 0xf0, 0xd2,
49 0xc2, 0x37, 0xbb, 0x03, 0xbc, 0xce, 0xc3, 0xb9, 0x57, 0xd5, 0xf0, 0x1d, 0xa1, 0x32, 0x42, 0x2b,
50 0xb3, 0xd9, 0xbb, 0x40, 0x2e, 0x69, 0xb1, 0x59, 0x2b, 0xbe, 0xac, 0xf6, 0x6d, 0x55, 0xd3, 0x91,
51 0x2f, 0x2e, 0x09, 0x0d, 0x6d, 0xb6, 0xe2, 0x12, 0x15, 0xd9, 0x29, 0x1f, 0xff, 0x77, 0x07, 0x9a,
52 0x9d, 0x62, 0x01, 0x5e, 0x51, 0x1c, 0xf6, 0x2b, 0xb4, 0x86, 0x48, 0x2f, 0xf3, 0xc9, 0x3d, 0xe2,
53 0x94, 0x1a, 0xc6, 0x5c, 0x5b, 0x85, 0x9e, 0x56, 0x0a, 0x7d, 0x12, 0x5a, 0x39, 0xa7, 0xae, 0xcd,
54 0x6f, 0x7d, 0xe4, 0xf7, 0x07, 0x3f, 0x1c, 0xb0, 0xa7, 0x70, 0xd8, 0x09, 0x74, 0x4c, 0xfd, 0x7c,
55 0xed, 0xac, 0xe9, 0xda, 0x22, 0x14, 0xdf, 0xce, 0x99, 0x5b, 0x54, 0xdf, 0x2d, 0xab, 0xef, 0x0e,
56 0xb2, 0xea, 0xb3, 0x9f, 0xa0, 0x35, 0x41, 0x5f, 0x2b, 0x5f, 0x48, 0xdc, 0xd1, 0xfa, 0x0c, 0x8e,
57 0xfa, 0x28, 0x91, 0x76, 0xf5, 0x3d, 0x87, 0x46, 0x5f, 0x18, 0x3e, 0xdb, 0x79, 0xc2, 0x1f, 0xa1,
58 0x39, 0xc1, 0x81, 0xda, 0xc3, 0xf9, 0x0c, 0x8e, 0x26, 0x38, 0xd3, 0x9a, 0x76, 0x9f, 0xd1, 0x43,
59 0x39, 0xff, 0x13, 0xcd, 0xae, 0xce, 0x2e, 0x1c, 0x0f, 0x91, 0xc6, 0xf3, 0xb8, 0x18, 0x37, 0x52,
60 0x73, 0xfd, 0x81, 0xf7, 0x9e, 0x5b, 0xd9, 0xca, 0xde, 0x95, 0x20, 0x7f, 0xd1, 0xe3, 0x31, 0x9f,
61 0x09, 0x29, 0x8a, 0xde, 0xf4, 0x16, 0x42, 0x06, 0xc5, 0xf0, 0x57, 0xda, 0xd0, 0x67, 0x4f, 0xff,
62 0x18, 0xa0, 0x28, 0xd4, 0x85, 0x4e, 0x88, 0x1d, 0x95, 0xae, 0xec, 0x6b, 0xab, 0xe7, 0x09, 0x1c,
63 0xda, 0xbe, 0xec, 0x60, 0xea, 0x42, 0x6b, 0x1a, 0x07, 0x9c, 0xf0, 0x85, 0xd4, 0x57, 0xa6, 0x9b,
64 0xca, 0xb7, 0xec, 0x6e, 0x75, 0x59, 0x59, 0x2c, 0x17, 0xb7, 0x32, 0x26, 0xf0, 0xcd, 0x1a, 0x63,
65 0xa4, 0xfc, 0x04, 0x23, 0x54, 0xc4, 0xa5, 0x7c, 0xcf, 0x6a, 0x35, 0x5a, 0x13, 0x3f, 0xce, 0xfc,
66 0x0d, 0x1a, 0x1e, 0xaa, 0xe0, 0x82, 0xfb, 0x6f, 0x91, 0xc6, 0x29, 0xd5, 0xb3, 0x5a, 0x09, 0x5b,
67 0x09, 0x03, 0x68, 0x16, 0x59, 0x5d, 0x44, 0x3d, 0xad, 0xe6, 0x22, 0x64, 0xe7, 0x35, 0x84, 0x8d,
68 0x9b, 0xac, 0xb9, 0x5b, 0x31, 0x1e, 0x1c, 0xf7, 0xf5, 0x95, 0x92, 0x9a, 0x07, 0x63, 0x95, 0x8e,
69 0x22, 0x1e, 0x22, 0x7b, 0x50, 0xed, 0x62, 0x1e, 0x2c, 0x07, 0x4d, 0xf0, 0x9f, 0x14, 0x0d, 0x39,
70 0xe7, 0x1b, 0xc6, 0x4c, 0xd0, 0xc4, 0x5a, 0x19, 0x64, 0xaf, 0xe0, 0x24, 0xdb, 0x5d, 0x96, 0x67,
71 0xcf, 0x0b, 0x67, 0xa3, 0xe3, 0x33, 0x68, 0x63, 0x38, 0xed, 0xcc, 0x74, 0xb2, 0xe2, 0x4d, 0xe3,
72 0x30, 0xe1, 0x01, 0xee, 0x0f, 0x7c, 0x04, 0x47, 0x6b, 0xe9, 0x19, 0x06, 0xe5, 0x49, 0x36, 0xea,
73 0x3b, 0x27, 0xa5, 0xf1, 0x5a, 0xfe, 0x03, 0x8e, 0x3b, 0x3e, 0x89, 0x25, 0x27, 0x5c, 0x95, 0x68,
74 0xef, 0xb9, 0x47, 0xd0, 0xec, 0xe9, 0x28, 0x12, 0x74, 0x73, 0xd4, 0x18, 0x1a, 0x65, 0x57, 0xca,
75 0xbe, 0x55, 0x37, 0xe3, 0x7a, 0xdf, 0x5e, 0xa3, 0x31, 0x3c, 0x44, 0xe7, 0xeb, 0x92, 0x58, 0x51,
76 0x1f, 0x7c, 0xf9, 0xef, 0x17, 0x07, 0xec, 0x2f, 0x38, 0x1b, 0x22, 0x55, 0x04, 0xdb, 0xbb, 0x9b,
77 0x92, 0xa7, 0x70, 0xa7, 0xc7, 0x95, 0x8f, 0xb2, 0xa2, 0xdd, 0x06, 0xb6, 0xec, 0x8c, 0xdd, 0x19,
78 0xd9, 0x1f, 0xe2, 0xc6, 0x58, 0x0f, 0x4e, 0x26, 0xb8, 0xc4, 0x84, 0x6e, 0x13, 0xfa, 0x33, 0x34,
79 0x3c, 0xe2, 0x09, 0x8d, 0x23, 0x5f, 0x64, 0x07, 0x36, 0x3b, 0xab, 0x02, 0xc7, 0xaf, 0x7b, 0xa3,
80 0x2c, 0xee, 0x30, 0x37, 0xbb, 0xab, 0xdd, 0xec, 0xf7, 0xaa, 0xd5, 0xbf, 0x43, 0xc3, 0x13, 0x51,
81 0x2a, 0x39, 0x61, 0x47, 0xf2, 0x24, 0xaa, 0x67, 0x53, 0x11, 0xaf, 0xb3, 0xb1, 0xdb, 0x7a, 0x1c,
82 0x63, 0xc2, 0xb3, 0xfb, 0x39, 0xe3, 0xe5, 0x89, 0xa4, 0x71, 0x9c, 0xa0, 0x31, 0x83, 0xec, 0xd6,
83 0x67, 0xcc, 0xcd, 0x6f, 0x7f, 0x37, 0xff, 0x7a, 0x21, 0x24, 0x61, 0xb2, 0xf5, 0xb8, 0xf8, 0x05,
84 0x5a, 0x53, 0xb5, 0xbf, 0xfd, 0x25, 0x1c, 0x0e, 0x91, 0x06, 0xef, 0xe8, 0x0d, 0x97, 0x29, 0xb2,
85 0xfb, 0xd5, 0x55, 0xac, 0x49, 0xe5, 0x1a, 0xee, 0xba, 0xab, 0x07, 0x91, 0x3b, 0x41, 0x4a, 0x13,
86 0x95, 0xcb, 0x86, 0x0d, 0xe1, 0xd0, 0xdb, 0x4e, 0xf2, 0x3e, 0x24, 0x6d, 0x4b, 0x69, 0x0a, 0xcd,
87 0x21, 0x92, 0x27, 0x54, 0x28, 0xb1, 0x64, 0x5d, 0xcf, 0x59, 0xc4, 0x87, 0x58, 0xb0, 0xca, 0xbf,
88 0xe5, 0x77, 0x1f, 0x19, 0x61, 0x3b, 0x36, 0xcd, 0xae, 0xe6, 0x4f, 0x60, 0xbd, 0x4f, 0x62, 0xbd,
89 0x1a, 0xb6, 0x4b, 0xf0, 0x50, 0x27, 0xa1, 0xab, 0x63, 0x54, 0xbe, 0x4e, 0x02, 0xd7, 0x3e, 0xf9,
90 0x6a, 0x6f, 0xd9, 0xee, 0xe9, 0x9b, 0x3c, 0x5e, 0x7d, 0xc4, 0xfd, 0xfd, 0x3c, 0x14, 0xb4, 0x48,
91 0x67, 0xd9, 0xb6, 0x68, 0x97, 0x04, 0xfb, 0x68, 0x7c, 0x54, 0x3e, 0x21, 0x9f, 0xb6, 0x43, 0x5d,
92 0x7f, 0x31, 0xcf, 0xbe, 0xca, 0xd5, 0x27, 0xff, 0x07, 0x00, 0x00, 0xff, 0xff, 0xbd, 0x54, 0xa5,
93 0xf6, 0x59, 0x0b, 0x00, 0x00,
khenaidoo4c6543e2021-10-19 17:25:58 -040094}
95
96// Reference imports to suppress errors if they are not otherwise used.
97var _ context.Context
98var _ grpc.ClientConn
99
100// This is a compile-time assertion to ensure that this generated file
101// is compatible with the grpc package it is being compiled against.
102const _ = grpc.SupportPackageIsVersion4
103
104// AdapterServiceClient is the client API for AdapterService service.
105//
106// For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
107type AdapterServiceClient interface {
108 // GetHealthStatus is used by an AdapterService client to verify connectivity
109 // to the gRPC server hosting the AdapterService service
khenaidoo257f3192021-12-15 16:46:37 -0500110 GetHealthStatus(ctx context.Context, opts ...grpc.CallOption) (AdapterService_GetHealthStatusClient, error)
khenaidoo4c6543e2021-10-19 17:25:58 -0400111 // Device
112 AdoptDevice(ctx context.Context, in *voltha.Device, opts ...grpc.CallOption) (*empty.Empty, error)
113 ReconcileDevice(ctx context.Context, in *voltha.Device, opts ...grpc.CallOption) (*empty.Empty, error)
114 DeleteDevice(ctx context.Context, in *voltha.Device, opts ...grpc.CallOption) (*empty.Empty, error)
115 DisableDevice(ctx context.Context, in *voltha.Device, opts ...grpc.CallOption) (*empty.Empty, error)
116 ReEnableDevice(ctx context.Context, in *voltha.Device, opts ...grpc.CallOption) (*empty.Empty, error)
117 RebootDevice(ctx context.Context, in *voltha.Device, opts ...grpc.CallOption) (*empty.Empty, error)
118 SelfTestDevice(ctx context.Context, in *voltha.Device, opts ...grpc.CallOption) (*empty.Empty, error)
119 GetOfpDeviceInfo(ctx context.Context, in *voltha.Device, opts ...grpc.CallOption) (*core_adapter.SwitchCapability, error)
120 ChildDeviceLost(ctx context.Context, in *voltha.Device, opts ...grpc.CallOption) (*empty.Empty, error)
121 // Ports
122 EnablePort(ctx context.Context, in *voltha.Port, opts ...grpc.CallOption) (*empty.Empty, error)
123 DisablePort(ctx context.Context, in *voltha.Port, opts ...grpc.CallOption) (*empty.Empty, error)
124 // Flows
125 UpdateFlowsBulk(ctx context.Context, in *core_adapter.BulkFlows, opts ...grpc.CallOption) (*empty.Empty, error)
126 UpdateFlowsIncrementally(ctx context.Context, in *core_adapter.IncrementalFlows, opts ...grpc.CallOption) (*empty.Empty, error)
127 //Packets
128 SendPacketOut(ctx context.Context, in *core_adapter.PacketOut, opts ...grpc.CallOption) (*empty.Empty, error)
129 // PM
130 UpdatePmConfig(ctx context.Context, in *core_adapter.PmConfigsInfo, opts ...grpc.CallOption) (*empty.Empty, error)
131 // Image
132 DownloadOnuImage(ctx context.Context, in *voltha.DeviceImageDownloadRequest, opts ...grpc.CallOption) (*voltha.DeviceImageResponse, error)
133 GetOnuImageStatus(ctx context.Context, in *voltha.DeviceImageRequest, opts ...grpc.CallOption) (*voltha.DeviceImageResponse, error)
134 AbortOnuImageUpgrade(ctx context.Context, in *voltha.DeviceImageRequest, opts ...grpc.CallOption) (*voltha.DeviceImageResponse, error)
135 GetOnuImages(ctx context.Context, in *common.ID, opts ...grpc.CallOption) (*voltha.OnuImages, error)
136 ActivateOnuImage(ctx context.Context, in *voltha.DeviceImageRequest, opts ...grpc.CallOption) (*voltha.DeviceImageResponse, error)
137 CommitOnuImage(ctx context.Context, in *voltha.DeviceImageRequest, opts ...grpc.CallOption) (*voltha.DeviceImageResponse, error)
138 // Deprecated Image APIs
139 DownloadImage(ctx context.Context, in *core_adapter.ImageDownloadMessage, opts ...grpc.CallOption) (*voltha.ImageDownload, error)
140 GetImageDownloadStatus(ctx context.Context, in *core_adapter.ImageDownloadMessage, opts ...grpc.CallOption) (*voltha.ImageDownload, error)
141 CancelImageDownload(ctx context.Context, in *core_adapter.ImageDownloadMessage, opts ...grpc.CallOption) (*voltha.ImageDownload, error)
142 ActivateImageUpdate(ctx context.Context, in *core_adapter.ImageDownloadMessage, opts ...grpc.CallOption) (*voltha.ImageDownload, error)
143 RevertImageUpdate(ctx context.Context, in *core_adapter.ImageDownloadMessage, opts ...grpc.CallOption) (*voltha.ImageDownload, error)
144 // Tests
145 StartOmciTest(ctx context.Context, in *core_adapter.OMCITest, opts ...grpc.CallOption) (*omci.TestResponse, error)
146 SimulateAlarm(ctx context.Context, in *core_adapter.SimulateAlarmMessage, opts ...grpc.CallOption) (*common.OperationResp, error)
147 // Events
148 SuppressEvent(ctx context.Context, in *voltha.EventFilter, opts ...grpc.CallOption) (*empty.Empty, error)
149 UnSuppressEvent(ctx context.Context, in *voltha.EventFilter, opts ...grpc.CallOption) (*empty.Empty, error)
150 // Get/Set
151 GetExtValue(ctx context.Context, in *core_adapter.GetExtValueMessage, opts ...grpc.CallOption) (*extension.ReturnValues, error)
152 SetExtValue(ctx context.Context, in *core_adapter.SetExtValueMessage, opts ...grpc.CallOption) (*empty.Empty, error)
153 GetSingleValue(ctx context.Context, in *extension.SingleGetValueRequest, opts ...grpc.CallOption) (*extension.SingleGetValueResponse, error)
154 SetSingleValue(ctx context.Context, in *extension.SingleSetValueRequest, opts ...grpc.CallOption) (*extension.SingleSetValueResponse, error)
155}
156
157type adapterServiceClient struct {
158 cc *grpc.ClientConn
159}
160
161func NewAdapterServiceClient(cc *grpc.ClientConn) AdapterServiceClient {
162 return &adapterServiceClient{cc}
163}
164
khenaidoo257f3192021-12-15 16:46:37 -0500165func (c *adapterServiceClient) GetHealthStatus(ctx context.Context, opts ...grpc.CallOption) (AdapterService_GetHealthStatusClient, error) {
166 stream, err := c.cc.NewStream(ctx, &_AdapterService_serviceDesc.Streams[0], "/adapter_service.AdapterService/GetHealthStatus", opts...)
khenaidoo4c6543e2021-10-19 17:25:58 -0400167 if err != nil {
168 return nil, err
169 }
khenaidoo257f3192021-12-15 16:46:37 -0500170 x := &adapterServiceGetHealthStatusClient{stream}
171 return x, nil
172}
173
174type AdapterService_GetHealthStatusClient interface {
175 Send(*common.Connection) error
176 Recv() (*health.HealthStatus, error)
177 grpc.ClientStream
178}
179
180type adapterServiceGetHealthStatusClient struct {
181 grpc.ClientStream
182}
183
184func (x *adapterServiceGetHealthStatusClient) Send(m *common.Connection) error {
185 return x.ClientStream.SendMsg(m)
186}
187
188func (x *adapterServiceGetHealthStatusClient) Recv() (*health.HealthStatus, error) {
189 m := new(health.HealthStatus)
190 if err := x.ClientStream.RecvMsg(m); err != nil {
191 return nil, err
192 }
193 return m, nil
khenaidoo4c6543e2021-10-19 17:25:58 -0400194}
195
196func (c *adapterServiceClient) AdoptDevice(ctx context.Context, in *voltha.Device, opts ...grpc.CallOption) (*empty.Empty, error) {
197 out := new(empty.Empty)
198 err := c.cc.Invoke(ctx, "/adapter_service.AdapterService/AdoptDevice", in, out, opts...)
199 if err != nil {
200 return nil, err
201 }
202 return out, nil
203}
204
205func (c *adapterServiceClient) ReconcileDevice(ctx context.Context, in *voltha.Device, opts ...grpc.CallOption) (*empty.Empty, error) {
206 out := new(empty.Empty)
207 err := c.cc.Invoke(ctx, "/adapter_service.AdapterService/ReconcileDevice", in, out, opts...)
208 if err != nil {
209 return nil, err
210 }
211 return out, nil
212}
213
214func (c *adapterServiceClient) DeleteDevice(ctx context.Context, in *voltha.Device, opts ...grpc.CallOption) (*empty.Empty, error) {
215 out := new(empty.Empty)
216 err := c.cc.Invoke(ctx, "/adapter_service.AdapterService/DeleteDevice", in, out, opts...)
217 if err != nil {
218 return nil, err
219 }
220 return out, nil
221}
222
223func (c *adapterServiceClient) DisableDevice(ctx context.Context, in *voltha.Device, opts ...grpc.CallOption) (*empty.Empty, error) {
224 out := new(empty.Empty)
225 err := c.cc.Invoke(ctx, "/adapter_service.AdapterService/DisableDevice", in, out, opts...)
226 if err != nil {
227 return nil, err
228 }
229 return out, nil
230}
231
232func (c *adapterServiceClient) ReEnableDevice(ctx context.Context, in *voltha.Device, opts ...grpc.CallOption) (*empty.Empty, error) {
233 out := new(empty.Empty)
234 err := c.cc.Invoke(ctx, "/adapter_service.AdapterService/ReEnableDevice", in, out, opts...)
235 if err != nil {
236 return nil, err
237 }
238 return out, nil
239}
240
241func (c *adapterServiceClient) RebootDevice(ctx context.Context, in *voltha.Device, opts ...grpc.CallOption) (*empty.Empty, error) {
242 out := new(empty.Empty)
243 err := c.cc.Invoke(ctx, "/adapter_service.AdapterService/RebootDevice", in, out, opts...)
244 if err != nil {
245 return nil, err
246 }
247 return out, nil
248}
249
250func (c *adapterServiceClient) SelfTestDevice(ctx context.Context, in *voltha.Device, opts ...grpc.CallOption) (*empty.Empty, error) {
251 out := new(empty.Empty)
252 err := c.cc.Invoke(ctx, "/adapter_service.AdapterService/SelfTestDevice", in, out, opts...)
253 if err != nil {
254 return nil, err
255 }
256 return out, nil
257}
258
259func (c *adapterServiceClient) GetOfpDeviceInfo(ctx context.Context, in *voltha.Device, opts ...grpc.CallOption) (*core_adapter.SwitchCapability, error) {
260 out := new(core_adapter.SwitchCapability)
261 err := c.cc.Invoke(ctx, "/adapter_service.AdapterService/GetOfpDeviceInfo", in, out, opts...)
262 if err != nil {
263 return nil, err
264 }
265 return out, nil
266}
267
268func (c *adapterServiceClient) ChildDeviceLost(ctx context.Context, in *voltha.Device, opts ...grpc.CallOption) (*empty.Empty, error) {
269 out := new(empty.Empty)
270 err := c.cc.Invoke(ctx, "/adapter_service.AdapterService/ChildDeviceLost", in, out, opts...)
271 if err != nil {
272 return nil, err
273 }
274 return out, nil
275}
276
277func (c *adapterServiceClient) EnablePort(ctx context.Context, in *voltha.Port, opts ...grpc.CallOption) (*empty.Empty, error) {
278 out := new(empty.Empty)
279 err := c.cc.Invoke(ctx, "/adapter_service.AdapterService/EnablePort", in, out, opts...)
280 if err != nil {
281 return nil, err
282 }
283 return out, nil
284}
285
286func (c *adapterServiceClient) DisablePort(ctx context.Context, in *voltha.Port, opts ...grpc.CallOption) (*empty.Empty, error) {
287 out := new(empty.Empty)
288 err := c.cc.Invoke(ctx, "/adapter_service.AdapterService/DisablePort", in, out, opts...)
289 if err != nil {
290 return nil, err
291 }
292 return out, nil
293}
294
295func (c *adapterServiceClient) UpdateFlowsBulk(ctx context.Context, in *core_adapter.BulkFlows, opts ...grpc.CallOption) (*empty.Empty, error) {
296 out := new(empty.Empty)
297 err := c.cc.Invoke(ctx, "/adapter_service.AdapterService/UpdateFlowsBulk", in, out, opts...)
298 if err != nil {
299 return nil, err
300 }
301 return out, nil
302}
303
304func (c *adapterServiceClient) UpdateFlowsIncrementally(ctx context.Context, in *core_adapter.IncrementalFlows, opts ...grpc.CallOption) (*empty.Empty, error) {
305 out := new(empty.Empty)
306 err := c.cc.Invoke(ctx, "/adapter_service.AdapterService/UpdateFlowsIncrementally", in, out, opts...)
307 if err != nil {
308 return nil, err
309 }
310 return out, nil
311}
312
313func (c *adapterServiceClient) SendPacketOut(ctx context.Context, in *core_adapter.PacketOut, opts ...grpc.CallOption) (*empty.Empty, error) {
314 out := new(empty.Empty)
315 err := c.cc.Invoke(ctx, "/adapter_service.AdapterService/SendPacketOut", in, out, opts...)
316 if err != nil {
317 return nil, err
318 }
319 return out, nil
320}
321
322func (c *adapterServiceClient) UpdatePmConfig(ctx context.Context, in *core_adapter.PmConfigsInfo, opts ...grpc.CallOption) (*empty.Empty, error) {
323 out := new(empty.Empty)
324 err := c.cc.Invoke(ctx, "/adapter_service.AdapterService/UpdatePmConfig", in, out, opts...)
325 if err != nil {
326 return nil, err
327 }
328 return out, nil
329}
330
331func (c *adapterServiceClient) DownloadOnuImage(ctx context.Context, in *voltha.DeviceImageDownloadRequest, opts ...grpc.CallOption) (*voltha.DeviceImageResponse, error) {
332 out := new(voltha.DeviceImageResponse)
333 err := c.cc.Invoke(ctx, "/adapter_service.AdapterService/DownloadOnuImage", in, out, opts...)
334 if err != nil {
335 return nil, err
336 }
337 return out, nil
338}
339
340func (c *adapterServiceClient) GetOnuImageStatus(ctx context.Context, in *voltha.DeviceImageRequest, opts ...grpc.CallOption) (*voltha.DeviceImageResponse, error) {
341 out := new(voltha.DeviceImageResponse)
342 err := c.cc.Invoke(ctx, "/adapter_service.AdapterService/GetOnuImageStatus", in, out, opts...)
343 if err != nil {
344 return nil, err
345 }
346 return out, nil
347}
348
349func (c *adapterServiceClient) AbortOnuImageUpgrade(ctx context.Context, in *voltha.DeviceImageRequest, opts ...grpc.CallOption) (*voltha.DeviceImageResponse, error) {
350 out := new(voltha.DeviceImageResponse)
351 err := c.cc.Invoke(ctx, "/adapter_service.AdapterService/AbortOnuImageUpgrade", in, out, opts...)
352 if err != nil {
353 return nil, err
354 }
355 return out, nil
356}
357
358func (c *adapterServiceClient) GetOnuImages(ctx context.Context, in *common.ID, opts ...grpc.CallOption) (*voltha.OnuImages, error) {
359 out := new(voltha.OnuImages)
360 err := c.cc.Invoke(ctx, "/adapter_service.AdapterService/GetOnuImages", in, out, opts...)
361 if err != nil {
362 return nil, err
363 }
364 return out, nil
365}
366
367func (c *adapterServiceClient) ActivateOnuImage(ctx context.Context, in *voltha.DeviceImageRequest, opts ...grpc.CallOption) (*voltha.DeviceImageResponse, error) {
368 out := new(voltha.DeviceImageResponse)
369 err := c.cc.Invoke(ctx, "/adapter_service.AdapterService/ActivateOnuImage", in, out, opts...)
370 if err != nil {
371 return nil, err
372 }
373 return out, nil
374}
375
376func (c *adapterServiceClient) CommitOnuImage(ctx context.Context, in *voltha.DeviceImageRequest, opts ...grpc.CallOption) (*voltha.DeviceImageResponse, error) {
377 out := new(voltha.DeviceImageResponse)
378 err := c.cc.Invoke(ctx, "/adapter_service.AdapterService/CommitOnuImage", in, out, opts...)
379 if err != nil {
380 return nil, err
381 }
382 return out, nil
383}
384
385// Deprecated: Do not use.
386func (c *adapterServiceClient) DownloadImage(ctx context.Context, in *core_adapter.ImageDownloadMessage, opts ...grpc.CallOption) (*voltha.ImageDownload, error) {
387 out := new(voltha.ImageDownload)
388 err := c.cc.Invoke(ctx, "/adapter_service.AdapterService/DownloadImage", in, out, opts...)
389 if err != nil {
390 return nil, err
391 }
392 return out, nil
393}
394
395// Deprecated: Do not use.
396func (c *adapterServiceClient) GetImageDownloadStatus(ctx context.Context, in *core_adapter.ImageDownloadMessage, opts ...grpc.CallOption) (*voltha.ImageDownload, error) {
397 out := new(voltha.ImageDownload)
398 err := c.cc.Invoke(ctx, "/adapter_service.AdapterService/GetImageDownloadStatus", in, out, opts...)
399 if err != nil {
400 return nil, err
401 }
402 return out, nil
403}
404
405// Deprecated: Do not use.
406func (c *adapterServiceClient) CancelImageDownload(ctx context.Context, in *core_adapter.ImageDownloadMessage, opts ...grpc.CallOption) (*voltha.ImageDownload, error) {
407 out := new(voltha.ImageDownload)
408 err := c.cc.Invoke(ctx, "/adapter_service.AdapterService/CancelImageDownload", in, out, opts...)
409 if err != nil {
410 return nil, err
411 }
412 return out, nil
413}
414
415// Deprecated: Do not use.
416func (c *adapterServiceClient) ActivateImageUpdate(ctx context.Context, in *core_adapter.ImageDownloadMessage, opts ...grpc.CallOption) (*voltha.ImageDownload, error) {
417 out := new(voltha.ImageDownload)
418 err := c.cc.Invoke(ctx, "/adapter_service.AdapterService/ActivateImageUpdate", in, out, opts...)
419 if err != nil {
420 return nil, err
421 }
422 return out, nil
423}
424
425// Deprecated: Do not use.
426func (c *adapterServiceClient) RevertImageUpdate(ctx context.Context, in *core_adapter.ImageDownloadMessage, opts ...grpc.CallOption) (*voltha.ImageDownload, error) {
427 out := new(voltha.ImageDownload)
428 err := c.cc.Invoke(ctx, "/adapter_service.AdapterService/RevertImageUpdate", in, out, opts...)
429 if err != nil {
430 return nil, err
431 }
432 return out, nil
433}
434
435func (c *adapterServiceClient) StartOmciTest(ctx context.Context, in *core_adapter.OMCITest, opts ...grpc.CallOption) (*omci.TestResponse, error) {
436 out := new(omci.TestResponse)
437 err := c.cc.Invoke(ctx, "/adapter_service.AdapterService/StartOmciTest", in, out, opts...)
438 if err != nil {
439 return nil, err
440 }
441 return out, nil
442}
443
444func (c *adapterServiceClient) SimulateAlarm(ctx context.Context, in *core_adapter.SimulateAlarmMessage, opts ...grpc.CallOption) (*common.OperationResp, error) {
445 out := new(common.OperationResp)
446 err := c.cc.Invoke(ctx, "/adapter_service.AdapterService/SimulateAlarm", in, out, opts...)
447 if err != nil {
448 return nil, err
449 }
450 return out, nil
451}
452
453func (c *adapterServiceClient) SuppressEvent(ctx context.Context, in *voltha.EventFilter, opts ...grpc.CallOption) (*empty.Empty, error) {
454 out := new(empty.Empty)
455 err := c.cc.Invoke(ctx, "/adapter_service.AdapterService/SuppressEvent", in, out, opts...)
456 if err != nil {
457 return nil, err
458 }
459 return out, nil
460}
461
462func (c *adapterServiceClient) UnSuppressEvent(ctx context.Context, in *voltha.EventFilter, opts ...grpc.CallOption) (*empty.Empty, error) {
463 out := new(empty.Empty)
464 err := c.cc.Invoke(ctx, "/adapter_service.AdapterService/UnSuppressEvent", in, out, opts...)
465 if err != nil {
466 return nil, err
467 }
468 return out, nil
469}
470
471func (c *adapterServiceClient) GetExtValue(ctx context.Context, in *core_adapter.GetExtValueMessage, opts ...grpc.CallOption) (*extension.ReturnValues, error) {
472 out := new(extension.ReturnValues)
473 err := c.cc.Invoke(ctx, "/adapter_service.AdapterService/GetExtValue", in, out, opts...)
474 if err != nil {
475 return nil, err
476 }
477 return out, nil
478}
479
480func (c *adapterServiceClient) SetExtValue(ctx context.Context, in *core_adapter.SetExtValueMessage, opts ...grpc.CallOption) (*empty.Empty, error) {
481 out := new(empty.Empty)
482 err := c.cc.Invoke(ctx, "/adapter_service.AdapterService/SetExtValue", in, out, opts...)
483 if err != nil {
484 return nil, err
485 }
486 return out, nil
487}
488
489func (c *adapterServiceClient) GetSingleValue(ctx context.Context, in *extension.SingleGetValueRequest, opts ...grpc.CallOption) (*extension.SingleGetValueResponse, error) {
490 out := new(extension.SingleGetValueResponse)
491 err := c.cc.Invoke(ctx, "/adapter_service.AdapterService/GetSingleValue", in, out, opts...)
492 if err != nil {
493 return nil, err
494 }
495 return out, nil
496}
497
498func (c *adapterServiceClient) SetSingleValue(ctx context.Context, in *extension.SingleSetValueRequest, opts ...grpc.CallOption) (*extension.SingleSetValueResponse, error) {
499 out := new(extension.SingleSetValueResponse)
500 err := c.cc.Invoke(ctx, "/adapter_service.AdapterService/SetSingleValue", in, out, opts...)
501 if err != nil {
502 return nil, err
503 }
504 return out, nil
505}
506
507// AdapterServiceServer is the server API for AdapterService service.
508type AdapterServiceServer interface {
509 // GetHealthStatus is used by an AdapterService client to verify connectivity
510 // to the gRPC server hosting the AdapterService service
khenaidoo257f3192021-12-15 16:46:37 -0500511 GetHealthStatus(AdapterService_GetHealthStatusServer) error
khenaidoo4c6543e2021-10-19 17:25:58 -0400512 // Device
513 AdoptDevice(context.Context, *voltha.Device) (*empty.Empty, error)
514 ReconcileDevice(context.Context, *voltha.Device) (*empty.Empty, error)
515 DeleteDevice(context.Context, *voltha.Device) (*empty.Empty, error)
516 DisableDevice(context.Context, *voltha.Device) (*empty.Empty, error)
517 ReEnableDevice(context.Context, *voltha.Device) (*empty.Empty, error)
518 RebootDevice(context.Context, *voltha.Device) (*empty.Empty, error)
519 SelfTestDevice(context.Context, *voltha.Device) (*empty.Empty, error)
520 GetOfpDeviceInfo(context.Context, *voltha.Device) (*core_adapter.SwitchCapability, error)
521 ChildDeviceLost(context.Context, *voltha.Device) (*empty.Empty, error)
522 // Ports
523 EnablePort(context.Context, *voltha.Port) (*empty.Empty, error)
524 DisablePort(context.Context, *voltha.Port) (*empty.Empty, error)
525 // Flows
526 UpdateFlowsBulk(context.Context, *core_adapter.BulkFlows) (*empty.Empty, error)
527 UpdateFlowsIncrementally(context.Context, *core_adapter.IncrementalFlows) (*empty.Empty, error)
528 //Packets
529 SendPacketOut(context.Context, *core_adapter.PacketOut) (*empty.Empty, error)
530 // PM
531 UpdatePmConfig(context.Context, *core_adapter.PmConfigsInfo) (*empty.Empty, error)
532 // Image
533 DownloadOnuImage(context.Context, *voltha.DeviceImageDownloadRequest) (*voltha.DeviceImageResponse, error)
534 GetOnuImageStatus(context.Context, *voltha.DeviceImageRequest) (*voltha.DeviceImageResponse, error)
535 AbortOnuImageUpgrade(context.Context, *voltha.DeviceImageRequest) (*voltha.DeviceImageResponse, error)
536 GetOnuImages(context.Context, *common.ID) (*voltha.OnuImages, error)
537 ActivateOnuImage(context.Context, *voltha.DeviceImageRequest) (*voltha.DeviceImageResponse, error)
538 CommitOnuImage(context.Context, *voltha.DeviceImageRequest) (*voltha.DeviceImageResponse, error)
539 // Deprecated Image APIs
540 DownloadImage(context.Context, *core_adapter.ImageDownloadMessage) (*voltha.ImageDownload, error)
541 GetImageDownloadStatus(context.Context, *core_adapter.ImageDownloadMessage) (*voltha.ImageDownload, error)
542 CancelImageDownload(context.Context, *core_adapter.ImageDownloadMessage) (*voltha.ImageDownload, error)
543 ActivateImageUpdate(context.Context, *core_adapter.ImageDownloadMessage) (*voltha.ImageDownload, error)
544 RevertImageUpdate(context.Context, *core_adapter.ImageDownloadMessage) (*voltha.ImageDownload, error)
545 // Tests
546 StartOmciTest(context.Context, *core_adapter.OMCITest) (*omci.TestResponse, error)
547 SimulateAlarm(context.Context, *core_adapter.SimulateAlarmMessage) (*common.OperationResp, error)
548 // Events
549 SuppressEvent(context.Context, *voltha.EventFilter) (*empty.Empty, error)
550 UnSuppressEvent(context.Context, *voltha.EventFilter) (*empty.Empty, error)
551 // Get/Set
552 GetExtValue(context.Context, *core_adapter.GetExtValueMessage) (*extension.ReturnValues, error)
553 SetExtValue(context.Context, *core_adapter.SetExtValueMessage) (*empty.Empty, error)
554 GetSingleValue(context.Context, *extension.SingleGetValueRequest) (*extension.SingleGetValueResponse, error)
555 SetSingleValue(context.Context, *extension.SingleSetValueRequest) (*extension.SingleSetValueResponse, error)
556}
557
558// UnimplementedAdapterServiceServer can be embedded to have forward compatible implementations.
559type UnimplementedAdapterServiceServer struct {
560}
561
khenaidoo257f3192021-12-15 16:46:37 -0500562func (*UnimplementedAdapterServiceServer) GetHealthStatus(srv AdapterService_GetHealthStatusServer) error {
563 return status.Errorf(codes.Unimplemented, "method GetHealthStatus not implemented")
khenaidoo4c6543e2021-10-19 17:25:58 -0400564}
565func (*UnimplementedAdapterServiceServer) AdoptDevice(ctx context.Context, req *voltha.Device) (*empty.Empty, error) {
566 return nil, status.Errorf(codes.Unimplemented, "method AdoptDevice not implemented")
567}
568func (*UnimplementedAdapterServiceServer) ReconcileDevice(ctx context.Context, req *voltha.Device) (*empty.Empty, error) {
569 return nil, status.Errorf(codes.Unimplemented, "method ReconcileDevice not implemented")
570}
571func (*UnimplementedAdapterServiceServer) DeleteDevice(ctx context.Context, req *voltha.Device) (*empty.Empty, error) {
572 return nil, status.Errorf(codes.Unimplemented, "method DeleteDevice not implemented")
573}
574func (*UnimplementedAdapterServiceServer) DisableDevice(ctx context.Context, req *voltha.Device) (*empty.Empty, error) {
575 return nil, status.Errorf(codes.Unimplemented, "method DisableDevice not implemented")
576}
577func (*UnimplementedAdapterServiceServer) ReEnableDevice(ctx context.Context, req *voltha.Device) (*empty.Empty, error) {
578 return nil, status.Errorf(codes.Unimplemented, "method ReEnableDevice not implemented")
579}
580func (*UnimplementedAdapterServiceServer) RebootDevice(ctx context.Context, req *voltha.Device) (*empty.Empty, error) {
581 return nil, status.Errorf(codes.Unimplemented, "method RebootDevice not implemented")
582}
583func (*UnimplementedAdapterServiceServer) SelfTestDevice(ctx context.Context, req *voltha.Device) (*empty.Empty, error) {
584 return nil, status.Errorf(codes.Unimplemented, "method SelfTestDevice not implemented")
585}
586func (*UnimplementedAdapterServiceServer) GetOfpDeviceInfo(ctx context.Context, req *voltha.Device) (*core_adapter.SwitchCapability, error) {
587 return nil, status.Errorf(codes.Unimplemented, "method GetOfpDeviceInfo not implemented")
588}
589func (*UnimplementedAdapterServiceServer) ChildDeviceLost(ctx context.Context, req *voltha.Device) (*empty.Empty, error) {
590 return nil, status.Errorf(codes.Unimplemented, "method ChildDeviceLost not implemented")
591}
592func (*UnimplementedAdapterServiceServer) EnablePort(ctx context.Context, req *voltha.Port) (*empty.Empty, error) {
593 return nil, status.Errorf(codes.Unimplemented, "method EnablePort not implemented")
594}
595func (*UnimplementedAdapterServiceServer) DisablePort(ctx context.Context, req *voltha.Port) (*empty.Empty, error) {
596 return nil, status.Errorf(codes.Unimplemented, "method DisablePort not implemented")
597}
598func (*UnimplementedAdapterServiceServer) UpdateFlowsBulk(ctx context.Context, req *core_adapter.BulkFlows) (*empty.Empty, error) {
599 return nil, status.Errorf(codes.Unimplemented, "method UpdateFlowsBulk not implemented")
600}
601func (*UnimplementedAdapterServiceServer) UpdateFlowsIncrementally(ctx context.Context, req *core_adapter.IncrementalFlows) (*empty.Empty, error) {
602 return nil, status.Errorf(codes.Unimplemented, "method UpdateFlowsIncrementally not implemented")
603}
604func (*UnimplementedAdapterServiceServer) SendPacketOut(ctx context.Context, req *core_adapter.PacketOut) (*empty.Empty, error) {
605 return nil, status.Errorf(codes.Unimplemented, "method SendPacketOut not implemented")
606}
607func (*UnimplementedAdapterServiceServer) UpdatePmConfig(ctx context.Context, req *core_adapter.PmConfigsInfo) (*empty.Empty, error) {
608 return nil, status.Errorf(codes.Unimplemented, "method UpdatePmConfig not implemented")
609}
610func (*UnimplementedAdapterServiceServer) DownloadOnuImage(ctx context.Context, req *voltha.DeviceImageDownloadRequest) (*voltha.DeviceImageResponse, error) {
611 return nil, status.Errorf(codes.Unimplemented, "method DownloadOnuImage not implemented")
612}
613func (*UnimplementedAdapterServiceServer) GetOnuImageStatus(ctx context.Context, req *voltha.DeviceImageRequest) (*voltha.DeviceImageResponse, error) {
614 return nil, status.Errorf(codes.Unimplemented, "method GetOnuImageStatus not implemented")
615}
616func (*UnimplementedAdapterServiceServer) AbortOnuImageUpgrade(ctx context.Context, req *voltha.DeviceImageRequest) (*voltha.DeviceImageResponse, error) {
617 return nil, status.Errorf(codes.Unimplemented, "method AbortOnuImageUpgrade not implemented")
618}
619func (*UnimplementedAdapterServiceServer) GetOnuImages(ctx context.Context, req *common.ID) (*voltha.OnuImages, error) {
620 return nil, status.Errorf(codes.Unimplemented, "method GetOnuImages not implemented")
621}
622func (*UnimplementedAdapterServiceServer) ActivateOnuImage(ctx context.Context, req *voltha.DeviceImageRequest) (*voltha.DeviceImageResponse, error) {
623 return nil, status.Errorf(codes.Unimplemented, "method ActivateOnuImage not implemented")
624}
625func (*UnimplementedAdapterServiceServer) CommitOnuImage(ctx context.Context, req *voltha.DeviceImageRequest) (*voltha.DeviceImageResponse, error) {
626 return nil, status.Errorf(codes.Unimplemented, "method CommitOnuImage not implemented")
627}
628func (*UnimplementedAdapterServiceServer) DownloadImage(ctx context.Context, req *core_adapter.ImageDownloadMessage) (*voltha.ImageDownload, error) {
629 return nil, status.Errorf(codes.Unimplemented, "method DownloadImage not implemented")
630}
631func (*UnimplementedAdapterServiceServer) GetImageDownloadStatus(ctx context.Context, req *core_adapter.ImageDownloadMessage) (*voltha.ImageDownload, error) {
632 return nil, status.Errorf(codes.Unimplemented, "method GetImageDownloadStatus not implemented")
633}
634func (*UnimplementedAdapterServiceServer) CancelImageDownload(ctx context.Context, req *core_adapter.ImageDownloadMessage) (*voltha.ImageDownload, error) {
635 return nil, status.Errorf(codes.Unimplemented, "method CancelImageDownload not implemented")
636}
637func (*UnimplementedAdapterServiceServer) ActivateImageUpdate(ctx context.Context, req *core_adapter.ImageDownloadMessage) (*voltha.ImageDownload, error) {
638 return nil, status.Errorf(codes.Unimplemented, "method ActivateImageUpdate not implemented")
639}
640func (*UnimplementedAdapterServiceServer) RevertImageUpdate(ctx context.Context, req *core_adapter.ImageDownloadMessage) (*voltha.ImageDownload, error) {
641 return nil, status.Errorf(codes.Unimplemented, "method RevertImageUpdate not implemented")
642}
643func (*UnimplementedAdapterServiceServer) StartOmciTest(ctx context.Context, req *core_adapter.OMCITest) (*omci.TestResponse, error) {
644 return nil, status.Errorf(codes.Unimplemented, "method StartOmciTest not implemented")
645}
646func (*UnimplementedAdapterServiceServer) SimulateAlarm(ctx context.Context, req *core_adapter.SimulateAlarmMessage) (*common.OperationResp, error) {
647 return nil, status.Errorf(codes.Unimplemented, "method SimulateAlarm not implemented")
648}
649func (*UnimplementedAdapterServiceServer) SuppressEvent(ctx context.Context, req *voltha.EventFilter) (*empty.Empty, error) {
650 return nil, status.Errorf(codes.Unimplemented, "method SuppressEvent not implemented")
651}
652func (*UnimplementedAdapterServiceServer) UnSuppressEvent(ctx context.Context, req *voltha.EventFilter) (*empty.Empty, error) {
653 return nil, status.Errorf(codes.Unimplemented, "method UnSuppressEvent not implemented")
654}
655func (*UnimplementedAdapterServiceServer) GetExtValue(ctx context.Context, req *core_adapter.GetExtValueMessage) (*extension.ReturnValues, error) {
656 return nil, status.Errorf(codes.Unimplemented, "method GetExtValue not implemented")
657}
658func (*UnimplementedAdapterServiceServer) SetExtValue(ctx context.Context, req *core_adapter.SetExtValueMessage) (*empty.Empty, error) {
659 return nil, status.Errorf(codes.Unimplemented, "method SetExtValue not implemented")
660}
661func (*UnimplementedAdapterServiceServer) GetSingleValue(ctx context.Context, req *extension.SingleGetValueRequest) (*extension.SingleGetValueResponse, error) {
662 return nil, status.Errorf(codes.Unimplemented, "method GetSingleValue not implemented")
663}
664func (*UnimplementedAdapterServiceServer) SetSingleValue(ctx context.Context, req *extension.SingleSetValueRequest) (*extension.SingleSetValueResponse, error) {
665 return nil, status.Errorf(codes.Unimplemented, "method SetSingleValue not implemented")
666}
667
668func RegisterAdapterServiceServer(s *grpc.Server, srv AdapterServiceServer) {
669 s.RegisterService(&_AdapterService_serviceDesc, srv)
670}
671
khenaidoo257f3192021-12-15 16:46:37 -0500672func _AdapterService_GetHealthStatus_Handler(srv interface{}, stream grpc.ServerStream) error {
673 return srv.(AdapterServiceServer).GetHealthStatus(&adapterServiceGetHealthStatusServer{stream})
674}
675
676type AdapterService_GetHealthStatusServer interface {
677 Send(*health.HealthStatus) error
678 Recv() (*common.Connection, error)
679 grpc.ServerStream
680}
681
682type adapterServiceGetHealthStatusServer struct {
683 grpc.ServerStream
684}
685
686func (x *adapterServiceGetHealthStatusServer) Send(m *health.HealthStatus) error {
687 return x.ServerStream.SendMsg(m)
688}
689
690func (x *adapterServiceGetHealthStatusServer) Recv() (*common.Connection, error) {
691 m := new(common.Connection)
692 if err := x.ServerStream.RecvMsg(m); err != nil {
khenaidoo4c6543e2021-10-19 17:25:58 -0400693 return nil, err
694 }
khenaidoo257f3192021-12-15 16:46:37 -0500695 return m, nil
khenaidoo4c6543e2021-10-19 17:25:58 -0400696}
697
698func _AdapterService_AdoptDevice_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
699 in := new(voltha.Device)
700 if err := dec(in); err != nil {
701 return nil, err
702 }
703 if interceptor == nil {
704 return srv.(AdapterServiceServer).AdoptDevice(ctx, in)
705 }
706 info := &grpc.UnaryServerInfo{
707 Server: srv,
708 FullMethod: "/adapter_service.AdapterService/AdoptDevice",
709 }
710 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
711 return srv.(AdapterServiceServer).AdoptDevice(ctx, req.(*voltha.Device))
712 }
713 return interceptor(ctx, in, info, handler)
714}
715
716func _AdapterService_ReconcileDevice_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
717 in := new(voltha.Device)
718 if err := dec(in); err != nil {
719 return nil, err
720 }
721 if interceptor == nil {
722 return srv.(AdapterServiceServer).ReconcileDevice(ctx, in)
723 }
724 info := &grpc.UnaryServerInfo{
725 Server: srv,
726 FullMethod: "/adapter_service.AdapterService/ReconcileDevice",
727 }
728 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
729 return srv.(AdapterServiceServer).ReconcileDevice(ctx, req.(*voltha.Device))
730 }
731 return interceptor(ctx, in, info, handler)
732}
733
734func _AdapterService_DeleteDevice_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
735 in := new(voltha.Device)
736 if err := dec(in); err != nil {
737 return nil, err
738 }
739 if interceptor == nil {
740 return srv.(AdapterServiceServer).DeleteDevice(ctx, in)
741 }
742 info := &grpc.UnaryServerInfo{
743 Server: srv,
744 FullMethod: "/adapter_service.AdapterService/DeleteDevice",
745 }
746 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
747 return srv.(AdapterServiceServer).DeleteDevice(ctx, req.(*voltha.Device))
748 }
749 return interceptor(ctx, in, info, handler)
750}
751
752func _AdapterService_DisableDevice_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
753 in := new(voltha.Device)
754 if err := dec(in); err != nil {
755 return nil, err
756 }
757 if interceptor == nil {
758 return srv.(AdapterServiceServer).DisableDevice(ctx, in)
759 }
760 info := &grpc.UnaryServerInfo{
761 Server: srv,
762 FullMethod: "/adapter_service.AdapterService/DisableDevice",
763 }
764 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
765 return srv.(AdapterServiceServer).DisableDevice(ctx, req.(*voltha.Device))
766 }
767 return interceptor(ctx, in, info, handler)
768}
769
770func _AdapterService_ReEnableDevice_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
771 in := new(voltha.Device)
772 if err := dec(in); err != nil {
773 return nil, err
774 }
775 if interceptor == nil {
776 return srv.(AdapterServiceServer).ReEnableDevice(ctx, in)
777 }
778 info := &grpc.UnaryServerInfo{
779 Server: srv,
780 FullMethod: "/adapter_service.AdapterService/ReEnableDevice",
781 }
782 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
783 return srv.(AdapterServiceServer).ReEnableDevice(ctx, req.(*voltha.Device))
784 }
785 return interceptor(ctx, in, info, handler)
786}
787
788func _AdapterService_RebootDevice_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
789 in := new(voltha.Device)
790 if err := dec(in); err != nil {
791 return nil, err
792 }
793 if interceptor == nil {
794 return srv.(AdapterServiceServer).RebootDevice(ctx, in)
795 }
796 info := &grpc.UnaryServerInfo{
797 Server: srv,
798 FullMethod: "/adapter_service.AdapterService/RebootDevice",
799 }
800 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
801 return srv.(AdapterServiceServer).RebootDevice(ctx, req.(*voltha.Device))
802 }
803 return interceptor(ctx, in, info, handler)
804}
805
806func _AdapterService_SelfTestDevice_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
807 in := new(voltha.Device)
808 if err := dec(in); err != nil {
809 return nil, err
810 }
811 if interceptor == nil {
812 return srv.(AdapterServiceServer).SelfTestDevice(ctx, in)
813 }
814 info := &grpc.UnaryServerInfo{
815 Server: srv,
816 FullMethod: "/adapter_service.AdapterService/SelfTestDevice",
817 }
818 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
819 return srv.(AdapterServiceServer).SelfTestDevice(ctx, req.(*voltha.Device))
820 }
821 return interceptor(ctx, in, info, handler)
822}
823
824func _AdapterService_GetOfpDeviceInfo_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
825 in := new(voltha.Device)
826 if err := dec(in); err != nil {
827 return nil, err
828 }
829 if interceptor == nil {
830 return srv.(AdapterServiceServer).GetOfpDeviceInfo(ctx, in)
831 }
832 info := &grpc.UnaryServerInfo{
833 Server: srv,
834 FullMethod: "/adapter_service.AdapterService/GetOfpDeviceInfo",
835 }
836 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
837 return srv.(AdapterServiceServer).GetOfpDeviceInfo(ctx, req.(*voltha.Device))
838 }
839 return interceptor(ctx, in, info, handler)
840}
841
842func _AdapterService_ChildDeviceLost_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
843 in := new(voltha.Device)
844 if err := dec(in); err != nil {
845 return nil, err
846 }
847 if interceptor == nil {
848 return srv.(AdapterServiceServer).ChildDeviceLost(ctx, in)
849 }
850 info := &grpc.UnaryServerInfo{
851 Server: srv,
852 FullMethod: "/adapter_service.AdapterService/ChildDeviceLost",
853 }
854 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
855 return srv.(AdapterServiceServer).ChildDeviceLost(ctx, req.(*voltha.Device))
856 }
857 return interceptor(ctx, in, info, handler)
858}
859
860func _AdapterService_EnablePort_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
861 in := new(voltha.Port)
862 if err := dec(in); err != nil {
863 return nil, err
864 }
865 if interceptor == nil {
866 return srv.(AdapterServiceServer).EnablePort(ctx, in)
867 }
868 info := &grpc.UnaryServerInfo{
869 Server: srv,
870 FullMethod: "/adapter_service.AdapterService/EnablePort",
871 }
872 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
873 return srv.(AdapterServiceServer).EnablePort(ctx, req.(*voltha.Port))
874 }
875 return interceptor(ctx, in, info, handler)
876}
877
878func _AdapterService_DisablePort_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
879 in := new(voltha.Port)
880 if err := dec(in); err != nil {
881 return nil, err
882 }
883 if interceptor == nil {
884 return srv.(AdapterServiceServer).DisablePort(ctx, in)
885 }
886 info := &grpc.UnaryServerInfo{
887 Server: srv,
888 FullMethod: "/adapter_service.AdapterService/DisablePort",
889 }
890 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
891 return srv.(AdapterServiceServer).DisablePort(ctx, req.(*voltha.Port))
892 }
893 return interceptor(ctx, in, info, handler)
894}
895
896func _AdapterService_UpdateFlowsBulk_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
897 in := new(core_adapter.BulkFlows)
898 if err := dec(in); err != nil {
899 return nil, err
900 }
901 if interceptor == nil {
902 return srv.(AdapterServiceServer).UpdateFlowsBulk(ctx, in)
903 }
904 info := &grpc.UnaryServerInfo{
905 Server: srv,
906 FullMethod: "/adapter_service.AdapterService/UpdateFlowsBulk",
907 }
908 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
909 return srv.(AdapterServiceServer).UpdateFlowsBulk(ctx, req.(*core_adapter.BulkFlows))
910 }
911 return interceptor(ctx, in, info, handler)
912}
913
914func _AdapterService_UpdateFlowsIncrementally_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
915 in := new(core_adapter.IncrementalFlows)
916 if err := dec(in); err != nil {
917 return nil, err
918 }
919 if interceptor == nil {
920 return srv.(AdapterServiceServer).UpdateFlowsIncrementally(ctx, in)
921 }
922 info := &grpc.UnaryServerInfo{
923 Server: srv,
924 FullMethod: "/adapter_service.AdapterService/UpdateFlowsIncrementally",
925 }
926 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
927 return srv.(AdapterServiceServer).UpdateFlowsIncrementally(ctx, req.(*core_adapter.IncrementalFlows))
928 }
929 return interceptor(ctx, in, info, handler)
930}
931
932func _AdapterService_SendPacketOut_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
933 in := new(core_adapter.PacketOut)
934 if err := dec(in); err != nil {
935 return nil, err
936 }
937 if interceptor == nil {
938 return srv.(AdapterServiceServer).SendPacketOut(ctx, in)
939 }
940 info := &grpc.UnaryServerInfo{
941 Server: srv,
942 FullMethod: "/adapter_service.AdapterService/SendPacketOut",
943 }
944 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
945 return srv.(AdapterServiceServer).SendPacketOut(ctx, req.(*core_adapter.PacketOut))
946 }
947 return interceptor(ctx, in, info, handler)
948}
949
950func _AdapterService_UpdatePmConfig_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
951 in := new(core_adapter.PmConfigsInfo)
952 if err := dec(in); err != nil {
953 return nil, err
954 }
955 if interceptor == nil {
956 return srv.(AdapterServiceServer).UpdatePmConfig(ctx, in)
957 }
958 info := &grpc.UnaryServerInfo{
959 Server: srv,
960 FullMethod: "/adapter_service.AdapterService/UpdatePmConfig",
961 }
962 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
963 return srv.(AdapterServiceServer).UpdatePmConfig(ctx, req.(*core_adapter.PmConfigsInfo))
964 }
965 return interceptor(ctx, in, info, handler)
966}
967
968func _AdapterService_DownloadOnuImage_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
969 in := new(voltha.DeviceImageDownloadRequest)
970 if err := dec(in); err != nil {
971 return nil, err
972 }
973 if interceptor == nil {
974 return srv.(AdapterServiceServer).DownloadOnuImage(ctx, in)
975 }
976 info := &grpc.UnaryServerInfo{
977 Server: srv,
978 FullMethod: "/adapter_service.AdapterService/DownloadOnuImage",
979 }
980 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
981 return srv.(AdapterServiceServer).DownloadOnuImage(ctx, req.(*voltha.DeviceImageDownloadRequest))
982 }
983 return interceptor(ctx, in, info, handler)
984}
985
986func _AdapterService_GetOnuImageStatus_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
987 in := new(voltha.DeviceImageRequest)
988 if err := dec(in); err != nil {
989 return nil, err
990 }
991 if interceptor == nil {
992 return srv.(AdapterServiceServer).GetOnuImageStatus(ctx, in)
993 }
994 info := &grpc.UnaryServerInfo{
995 Server: srv,
996 FullMethod: "/adapter_service.AdapterService/GetOnuImageStatus",
997 }
998 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
999 return srv.(AdapterServiceServer).GetOnuImageStatus(ctx, req.(*voltha.DeviceImageRequest))
1000 }
1001 return interceptor(ctx, in, info, handler)
1002}
1003
1004func _AdapterService_AbortOnuImageUpgrade_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
1005 in := new(voltha.DeviceImageRequest)
1006 if err := dec(in); err != nil {
1007 return nil, err
1008 }
1009 if interceptor == nil {
1010 return srv.(AdapterServiceServer).AbortOnuImageUpgrade(ctx, in)
1011 }
1012 info := &grpc.UnaryServerInfo{
1013 Server: srv,
1014 FullMethod: "/adapter_service.AdapterService/AbortOnuImageUpgrade",
1015 }
1016 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
1017 return srv.(AdapterServiceServer).AbortOnuImageUpgrade(ctx, req.(*voltha.DeviceImageRequest))
1018 }
1019 return interceptor(ctx, in, info, handler)
1020}
1021
1022func _AdapterService_GetOnuImages_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
1023 in := new(common.ID)
1024 if err := dec(in); err != nil {
1025 return nil, err
1026 }
1027 if interceptor == nil {
1028 return srv.(AdapterServiceServer).GetOnuImages(ctx, in)
1029 }
1030 info := &grpc.UnaryServerInfo{
1031 Server: srv,
1032 FullMethod: "/adapter_service.AdapterService/GetOnuImages",
1033 }
1034 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
1035 return srv.(AdapterServiceServer).GetOnuImages(ctx, req.(*common.ID))
1036 }
1037 return interceptor(ctx, in, info, handler)
1038}
1039
1040func _AdapterService_ActivateOnuImage_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
1041 in := new(voltha.DeviceImageRequest)
1042 if err := dec(in); err != nil {
1043 return nil, err
1044 }
1045 if interceptor == nil {
1046 return srv.(AdapterServiceServer).ActivateOnuImage(ctx, in)
1047 }
1048 info := &grpc.UnaryServerInfo{
1049 Server: srv,
1050 FullMethod: "/adapter_service.AdapterService/ActivateOnuImage",
1051 }
1052 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
1053 return srv.(AdapterServiceServer).ActivateOnuImage(ctx, req.(*voltha.DeviceImageRequest))
1054 }
1055 return interceptor(ctx, in, info, handler)
1056}
1057
1058func _AdapterService_CommitOnuImage_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
1059 in := new(voltha.DeviceImageRequest)
1060 if err := dec(in); err != nil {
1061 return nil, err
1062 }
1063 if interceptor == nil {
1064 return srv.(AdapterServiceServer).CommitOnuImage(ctx, in)
1065 }
1066 info := &grpc.UnaryServerInfo{
1067 Server: srv,
1068 FullMethod: "/adapter_service.AdapterService/CommitOnuImage",
1069 }
1070 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
1071 return srv.(AdapterServiceServer).CommitOnuImage(ctx, req.(*voltha.DeviceImageRequest))
1072 }
1073 return interceptor(ctx, in, info, handler)
1074}
1075
1076func _AdapterService_DownloadImage_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
1077 in := new(core_adapter.ImageDownloadMessage)
1078 if err := dec(in); err != nil {
1079 return nil, err
1080 }
1081 if interceptor == nil {
1082 return srv.(AdapterServiceServer).DownloadImage(ctx, in)
1083 }
1084 info := &grpc.UnaryServerInfo{
1085 Server: srv,
1086 FullMethod: "/adapter_service.AdapterService/DownloadImage",
1087 }
1088 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
1089 return srv.(AdapterServiceServer).DownloadImage(ctx, req.(*core_adapter.ImageDownloadMessage))
1090 }
1091 return interceptor(ctx, in, info, handler)
1092}
1093
1094func _AdapterService_GetImageDownloadStatus_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
1095 in := new(core_adapter.ImageDownloadMessage)
1096 if err := dec(in); err != nil {
1097 return nil, err
1098 }
1099 if interceptor == nil {
1100 return srv.(AdapterServiceServer).GetImageDownloadStatus(ctx, in)
1101 }
1102 info := &grpc.UnaryServerInfo{
1103 Server: srv,
1104 FullMethod: "/adapter_service.AdapterService/GetImageDownloadStatus",
1105 }
1106 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
1107 return srv.(AdapterServiceServer).GetImageDownloadStatus(ctx, req.(*core_adapter.ImageDownloadMessage))
1108 }
1109 return interceptor(ctx, in, info, handler)
1110}
1111
1112func _AdapterService_CancelImageDownload_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
1113 in := new(core_adapter.ImageDownloadMessage)
1114 if err := dec(in); err != nil {
1115 return nil, err
1116 }
1117 if interceptor == nil {
1118 return srv.(AdapterServiceServer).CancelImageDownload(ctx, in)
1119 }
1120 info := &grpc.UnaryServerInfo{
1121 Server: srv,
1122 FullMethod: "/adapter_service.AdapterService/CancelImageDownload",
1123 }
1124 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
1125 return srv.(AdapterServiceServer).CancelImageDownload(ctx, req.(*core_adapter.ImageDownloadMessage))
1126 }
1127 return interceptor(ctx, in, info, handler)
1128}
1129
1130func _AdapterService_ActivateImageUpdate_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
1131 in := new(core_adapter.ImageDownloadMessage)
1132 if err := dec(in); err != nil {
1133 return nil, err
1134 }
1135 if interceptor == nil {
1136 return srv.(AdapterServiceServer).ActivateImageUpdate(ctx, in)
1137 }
1138 info := &grpc.UnaryServerInfo{
1139 Server: srv,
1140 FullMethod: "/adapter_service.AdapterService/ActivateImageUpdate",
1141 }
1142 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
1143 return srv.(AdapterServiceServer).ActivateImageUpdate(ctx, req.(*core_adapter.ImageDownloadMessage))
1144 }
1145 return interceptor(ctx, in, info, handler)
1146}
1147
1148func _AdapterService_RevertImageUpdate_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
1149 in := new(core_adapter.ImageDownloadMessage)
1150 if err := dec(in); err != nil {
1151 return nil, err
1152 }
1153 if interceptor == nil {
1154 return srv.(AdapterServiceServer).RevertImageUpdate(ctx, in)
1155 }
1156 info := &grpc.UnaryServerInfo{
1157 Server: srv,
1158 FullMethod: "/adapter_service.AdapterService/RevertImageUpdate",
1159 }
1160 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
1161 return srv.(AdapterServiceServer).RevertImageUpdate(ctx, req.(*core_adapter.ImageDownloadMessage))
1162 }
1163 return interceptor(ctx, in, info, handler)
1164}
1165
1166func _AdapterService_StartOmciTest_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
1167 in := new(core_adapter.OMCITest)
1168 if err := dec(in); err != nil {
1169 return nil, err
1170 }
1171 if interceptor == nil {
1172 return srv.(AdapterServiceServer).StartOmciTest(ctx, in)
1173 }
1174 info := &grpc.UnaryServerInfo{
1175 Server: srv,
1176 FullMethod: "/adapter_service.AdapterService/StartOmciTest",
1177 }
1178 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
1179 return srv.(AdapterServiceServer).StartOmciTest(ctx, req.(*core_adapter.OMCITest))
1180 }
1181 return interceptor(ctx, in, info, handler)
1182}
1183
1184func _AdapterService_SimulateAlarm_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
1185 in := new(core_adapter.SimulateAlarmMessage)
1186 if err := dec(in); err != nil {
1187 return nil, err
1188 }
1189 if interceptor == nil {
1190 return srv.(AdapterServiceServer).SimulateAlarm(ctx, in)
1191 }
1192 info := &grpc.UnaryServerInfo{
1193 Server: srv,
1194 FullMethod: "/adapter_service.AdapterService/SimulateAlarm",
1195 }
1196 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
1197 return srv.(AdapterServiceServer).SimulateAlarm(ctx, req.(*core_adapter.SimulateAlarmMessage))
1198 }
1199 return interceptor(ctx, in, info, handler)
1200}
1201
1202func _AdapterService_SuppressEvent_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
1203 in := new(voltha.EventFilter)
1204 if err := dec(in); err != nil {
1205 return nil, err
1206 }
1207 if interceptor == nil {
1208 return srv.(AdapterServiceServer).SuppressEvent(ctx, in)
1209 }
1210 info := &grpc.UnaryServerInfo{
1211 Server: srv,
1212 FullMethod: "/adapter_service.AdapterService/SuppressEvent",
1213 }
1214 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
1215 return srv.(AdapterServiceServer).SuppressEvent(ctx, req.(*voltha.EventFilter))
1216 }
1217 return interceptor(ctx, in, info, handler)
1218}
1219
1220func _AdapterService_UnSuppressEvent_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
1221 in := new(voltha.EventFilter)
1222 if err := dec(in); err != nil {
1223 return nil, err
1224 }
1225 if interceptor == nil {
1226 return srv.(AdapterServiceServer).UnSuppressEvent(ctx, in)
1227 }
1228 info := &grpc.UnaryServerInfo{
1229 Server: srv,
1230 FullMethod: "/adapter_service.AdapterService/UnSuppressEvent",
1231 }
1232 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
1233 return srv.(AdapterServiceServer).UnSuppressEvent(ctx, req.(*voltha.EventFilter))
1234 }
1235 return interceptor(ctx, in, info, handler)
1236}
1237
1238func _AdapterService_GetExtValue_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
1239 in := new(core_adapter.GetExtValueMessage)
1240 if err := dec(in); err != nil {
1241 return nil, err
1242 }
1243 if interceptor == nil {
1244 return srv.(AdapterServiceServer).GetExtValue(ctx, in)
1245 }
1246 info := &grpc.UnaryServerInfo{
1247 Server: srv,
1248 FullMethod: "/adapter_service.AdapterService/GetExtValue",
1249 }
1250 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
1251 return srv.(AdapterServiceServer).GetExtValue(ctx, req.(*core_adapter.GetExtValueMessage))
1252 }
1253 return interceptor(ctx, in, info, handler)
1254}
1255
1256func _AdapterService_SetExtValue_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
1257 in := new(core_adapter.SetExtValueMessage)
1258 if err := dec(in); err != nil {
1259 return nil, err
1260 }
1261 if interceptor == nil {
1262 return srv.(AdapterServiceServer).SetExtValue(ctx, in)
1263 }
1264 info := &grpc.UnaryServerInfo{
1265 Server: srv,
1266 FullMethod: "/adapter_service.AdapterService/SetExtValue",
1267 }
1268 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
1269 return srv.(AdapterServiceServer).SetExtValue(ctx, req.(*core_adapter.SetExtValueMessage))
1270 }
1271 return interceptor(ctx, in, info, handler)
1272}
1273
1274func _AdapterService_GetSingleValue_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
1275 in := new(extension.SingleGetValueRequest)
1276 if err := dec(in); err != nil {
1277 return nil, err
1278 }
1279 if interceptor == nil {
1280 return srv.(AdapterServiceServer).GetSingleValue(ctx, in)
1281 }
1282 info := &grpc.UnaryServerInfo{
1283 Server: srv,
1284 FullMethod: "/adapter_service.AdapterService/GetSingleValue",
1285 }
1286 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
1287 return srv.(AdapterServiceServer).GetSingleValue(ctx, req.(*extension.SingleGetValueRequest))
1288 }
1289 return interceptor(ctx, in, info, handler)
1290}
1291
1292func _AdapterService_SetSingleValue_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
1293 in := new(extension.SingleSetValueRequest)
1294 if err := dec(in); err != nil {
1295 return nil, err
1296 }
1297 if interceptor == nil {
1298 return srv.(AdapterServiceServer).SetSingleValue(ctx, in)
1299 }
1300 info := &grpc.UnaryServerInfo{
1301 Server: srv,
1302 FullMethod: "/adapter_service.AdapterService/SetSingleValue",
1303 }
1304 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
1305 return srv.(AdapterServiceServer).SetSingleValue(ctx, req.(*extension.SingleSetValueRequest))
1306 }
1307 return interceptor(ctx, in, info, handler)
1308}
1309
1310var _AdapterService_serviceDesc = grpc.ServiceDesc{
1311 ServiceName: "adapter_service.AdapterService",
1312 HandlerType: (*AdapterServiceServer)(nil),
1313 Methods: []grpc.MethodDesc{
1314 {
khenaidoo4c6543e2021-10-19 17:25:58 -04001315 MethodName: "AdoptDevice",
1316 Handler: _AdapterService_AdoptDevice_Handler,
1317 },
1318 {
1319 MethodName: "ReconcileDevice",
1320 Handler: _AdapterService_ReconcileDevice_Handler,
1321 },
1322 {
1323 MethodName: "DeleteDevice",
1324 Handler: _AdapterService_DeleteDevice_Handler,
1325 },
1326 {
1327 MethodName: "DisableDevice",
1328 Handler: _AdapterService_DisableDevice_Handler,
1329 },
1330 {
1331 MethodName: "ReEnableDevice",
1332 Handler: _AdapterService_ReEnableDevice_Handler,
1333 },
1334 {
1335 MethodName: "RebootDevice",
1336 Handler: _AdapterService_RebootDevice_Handler,
1337 },
1338 {
1339 MethodName: "SelfTestDevice",
1340 Handler: _AdapterService_SelfTestDevice_Handler,
1341 },
1342 {
1343 MethodName: "GetOfpDeviceInfo",
1344 Handler: _AdapterService_GetOfpDeviceInfo_Handler,
1345 },
1346 {
1347 MethodName: "ChildDeviceLost",
1348 Handler: _AdapterService_ChildDeviceLost_Handler,
1349 },
1350 {
1351 MethodName: "EnablePort",
1352 Handler: _AdapterService_EnablePort_Handler,
1353 },
1354 {
1355 MethodName: "DisablePort",
1356 Handler: _AdapterService_DisablePort_Handler,
1357 },
1358 {
1359 MethodName: "UpdateFlowsBulk",
1360 Handler: _AdapterService_UpdateFlowsBulk_Handler,
1361 },
1362 {
1363 MethodName: "UpdateFlowsIncrementally",
1364 Handler: _AdapterService_UpdateFlowsIncrementally_Handler,
1365 },
1366 {
1367 MethodName: "SendPacketOut",
1368 Handler: _AdapterService_SendPacketOut_Handler,
1369 },
1370 {
1371 MethodName: "UpdatePmConfig",
1372 Handler: _AdapterService_UpdatePmConfig_Handler,
1373 },
1374 {
1375 MethodName: "DownloadOnuImage",
1376 Handler: _AdapterService_DownloadOnuImage_Handler,
1377 },
1378 {
1379 MethodName: "GetOnuImageStatus",
1380 Handler: _AdapterService_GetOnuImageStatus_Handler,
1381 },
1382 {
1383 MethodName: "AbortOnuImageUpgrade",
1384 Handler: _AdapterService_AbortOnuImageUpgrade_Handler,
1385 },
1386 {
1387 MethodName: "GetOnuImages",
1388 Handler: _AdapterService_GetOnuImages_Handler,
1389 },
1390 {
1391 MethodName: "ActivateOnuImage",
1392 Handler: _AdapterService_ActivateOnuImage_Handler,
1393 },
1394 {
1395 MethodName: "CommitOnuImage",
1396 Handler: _AdapterService_CommitOnuImage_Handler,
1397 },
1398 {
1399 MethodName: "DownloadImage",
1400 Handler: _AdapterService_DownloadImage_Handler,
1401 },
1402 {
1403 MethodName: "GetImageDownloadStatus",
1404 Handler: _AdapterService_GetImageDownloadStatus_Handler,
1405 },
1406 {
1407 MethodName: "CancelImageDownload",
1408 Handler: _AdapterService_CancelImageDownload_Handler,
1409 },
1410 {
1411 MethodName: "ActivateImageUpdate",
1412 Handler: _AdapterService_ActivateImageUpdate_Handler,
1413 },
1414 {
1415 MethodName: "RevertImageUpdate",
1416 Handler: _AdapterService_RevertImageUpdate_Handler,
1417 },
1418 {
1419 MethodName: "StartOmciTest",
1420 Handler: _AdapterService_StartOmciTest_Handler,
1421 },
1422 {
1423 MethodName: "SimulateAlarm",
1424 Handler: _AdapterService_SimulateAlarm_Handler,
1425 },
1426 {
1427 MethodName: "SuppressEvent",
1428 Handler: _AdapterService_SuppressEvent_Handler,
1429 },
1430 {
1431 MethodName: "UnSuppressEvent",
1432 Handler: _AdapterService_UnSuppressEvent_Handler,
1433 },
1434 {
1435 MethodName: "GetExtValue",
1436 Handler: _AdapterService_GetExtValue_Handler,
1437 },
1438 {
1439 MethodName: "SetExtValue",
1440 Handler: _AdapterService_SetExtValue_Handler,
1441 },
1442 {
1443 MethodName: "GetSingleValue",
1444 Handler: _AdapterService_GetSingleValue_Handler,
1445 },
1446 {
1447 MethodName: "SetSingleValue",
1448 Handler: _AdapterService_SetSingleValue_Handler,
1449 },
1450 },
khenaidoo257f3192021-12-15 16:46:37 -05001451 Streams: []grpc.StreamDesc{
1452 {
1453 StreamName: "GetHealthStatus",
1454 Handler: _AdapterService_GetHealthStatus_Handler,
1455 ServerStreams: true,
1456 ClientStreams: true,
1457 },
1458 },
khenaidoo4c6543e2021-10-19 17:25:58 -04001459 Metadata: "voltha_protos/adapter_service.proto",
1460}