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