blob: 41ab07736c37b7f518518b8a783902b5b08bebf6 [file] [log] [blame]
khenaidoo9beaaf12021-10-19 17:32:01 -04001// Code generated by protoc-gen-go. DO NOT EDIT.
2// source: voltha_protos/core_services.proto
3
4package core_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 health "github.com/opencord/voltha-protos/v5/go/health"
14 voltha "github.com/opencord/voltha-protos/v5/go/voltha"
15 grpc "google.golang.org/grpc"
16 codes "google.golang.org/grpc/codes"
17 status "google.golang.org/grpc/status"
18 math "math"
19)
20
21// Reference imports to suppress errors if they are not otherwise used.
22var _ = proto.Marshal
23var _ = fmt.Errorf
24var _ = math.Inf
25
26// This is a compile-time assertion to ensure that this generated file
27// is compatible with the proto package it is being compiled against.
28// A compilation error at this line likely means your copy of the
29// proto package needs to be updated.
30const _ = proto.ProtoPackageIsVersion3 // please upgrade the proto package
31
32func init() { proto.RegisterFile("voltha_protos/core_services.proto", fileDescriptor_979c43850713f141) }
33
34var fileDescriptor_979c43850713f141 = []byte{
35 // 612 bytes of a gzipped FileDescriptorProto
36 0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0xac, 0x55, 0xcd, 0x6f, 0xd3, 0x30,
37 0x14, 0xbf, 0x21, 0x78, 0xeb, 0xd6, 0xcd, 0xfb, 0x00, 0x65, 0x1a, 0x6c, 0x27, 0x2e, 0xe0, 0x48,
38 0x6c, 0x0c, 0x09, 0x24, 0x50, 0xd7, 0x40, 0x57, 0x69, 0x43, 0x55, 0x2b, 0x40, 0xe2, 0x32, 0xb9,
39 0xc9, 0x5b, 0x12, 0x2d, 0x8d, 0x2b, 0xdb, 0x2d, 0xf4, 0x8f, 0x47, 0x42, 0x89, 0xdd, 0xca, 0xce,
40 0x6a, 0xb1, 0x03, 0xd7, 0xf7, 0x7e, 0x1f, 0xef, 0xc3, 0x4f, 0x86, 0x93, 0x39, 0x2f, 0x54, 0xc6,
41 0x6e, 0xa6, 0x82, 0x2b, 0x2e, 0xc3, 0x98, 0x0b, 0xbc, 0x91, 0x28, 0xe6, 0x79, 0x8c, 0x92, 0xd6,
42 0x41, 0xd2, 0xb2, 0x83, 0xc1, 0x61, 0xca, 0x79, 0x5a, 0x60, 0x58, 0xe7, 0xc6, 0xb3, 0xdb, 0x10,
43 0x27, 0x53, 0xb5, 0xd0, 0xd0, 0xe0, 0x78, 0x8d, 0x1a, 0x4b, 0xd8, 0x54, 0xa1, 0x30, 0x88, 0xa0,
44 0x89, 0x98, 0x4c, 0x78, 0xb9, 0x3e, 0x97, 0x60, 0x65, 0xb8, 0x3e, 0x97, 0x21, 0x2b, 0x54, 0xa6,
45 0x73, 0x6f, 0xfe, 0x6c, 0xc0, 0x46, 0x97, 0x0b, 0x1c, 0xe9, 0x12, 0xc9, 0x27, 0x68, 0xf7, 0x50,
46 0x5d, 0xd6, 0x90, 0x91, 0x62, 0x6a, 0x26, 0xc9, 0x01, 0xd5, 0x65, 0xd3, 0x65, 0xd9, 0xf4, 0x73,
47 0x55, 0x76, 0xb0, 0x47, 0x8d, 0x92, 0x83, 0xbe, 0x82, 0xf6, 0x10, 0xd3, 0x5c, 0x2a, 0x14, 0x1d,
48 0x5d, 0x3d, 0x39, 0xa1, 0x4e, 0x33, 0x26, 0xac, 0x51, 0x82, 0xa9, 0x9c, 0x97, 0x81, 0xc7, 0x83,
49 0x9c, 0x43, 0x2b, 0xaa, 0x5b, 0xf9, 0x36, 0x4d, 0x98, 0x42, 0xb2, 0x45, 0x4d, 0x67, 0x3a, 0xea,
50 0xe5, 0x9d, 0xc2, 0xc6, 0x80, 0x0b, 0xd5, 0x15, 0xc8, 0x14, 0x26, 0xa4, 0xb5, 0xa4, 0x55, 0x41,
51 0x2f, 0xa9, 0x0f, 0xdb, 0x55, 0x5e, 0x56, 0x9d, 0x2c, 0x0d, 0x8f, 0xdc, 0xda, 0xab, 0x7c, 0x9d,
52 0xfe, 0x92, 0x17, 0x0a, 0x85, 0x57, 0xea, 0x0c, 0xb6, 0x22, 0x2c, 0x50, 0x61, 0xa7, 0x28, 0x6a,
53 0x4d, 0x02, 0xd4, 0xec, 0xab, 0x1f, 0x79, 0x59, 0xef, 0x60, 0xb3, 0x87, 0x4a, 0xb7, 0x56, 0xb1,
54 0xc8, 0xb3, 0xfb, 0xee, 0xc6, 0xd8, 0xe9, 0x88, 0xbc, 0x82, 0xf6, 0x55, 0x2e, 0x2d, 0xa6, 0xeb,
55 0xb7, 0x69, 0x83, 0xab, 0x15, 0xed, 0x68, 0xa4, 0xdd, 0xe8, 0x0b, 0xd7, 0xca, 0x02, 0xfc, 0xa3,
56 0xd5, 0x0e, 0xec, 0x19, 0xdf, 0xeb, 0x2e, 0x2f, 0x6f, 0xf3, 0xd4, 0x08, 0xee, 0xac, 0x4c, 0x27,
57 0x3a, 0x2e, 0xbd, 0x12, 0x11, 0xec, 0x76, 0xb3, 0xbc, 0x48, 0xb4, 0x4e, 0x84, 0x0a, 0xe3, 0x6a,
58 0x6b, 0x47, 0xeb, 0x4a, 0x8a, 0x72, 0x19, 0xf3, 0x39, 0x8a, 0x45, 0xd0, 0x78, 0x0b, 0xe4, 0x1c,
59 0xb6, 0x2d, 0x15, 0x79, 0xc5, 0xa5, 0x7a, 0xd0, 0xd4, 0xdf, 0xc3, 0x9e, 0xcd, 0x5b, 0xd9, 0x3f,
60 0x84, 0xfb, 0x12, 0x9e, 0xac, 0x36, 0xe6, 0x10, 0x9a, 0xc5, 0x75, 0x60, 0xab, 0x87, 0xca, 0xf2,
61 0x69, 0x0e, 0xdc, 0x4a, 0x99, 0x81, 0x37, 0x25, 0x68, 0x7d, 0x9a, 0x76, 0xa9, 0x8e, 0x63, 0xdb,
62 0x85, 0x4b, 0xf2, 0x11, 0x5a, 0x23, 0x2c, 0x93, 0x01, 0x8b, 0xef, 0x50, 0xf5, 0x4b, 0x72, 0xd0,
63 0x78, 0x4c, 0x26, 0xee, 0xed, 0xed, 0x12, 0x88, 0x96, 0x1a, 0x22, 0x93, 0xbc, 0x34, 0x6b, 0x0d,
64 0xd6, 0x2d, 0x45, 0x23, 0xbc, 0x4a, 0x17, 0xd0, 0x5e, 0x1d, 0x8e, 0x91, 0x79, 0xea, 0xb9, 0x2b,
65 0xaf, 0xc6, 0x07, 0xd8, 0x1f, 0x62, 0xcc, 0xcb, 0x38, 0x2f, 0xd0, 0x3b, 0x03, 0x1f, 0xf9, 0x1a,
66 0x9e, 0xbb, 0xa3, 0xfb, 0x91, 0xab, 0x6c, 0x20, 0xf8, 0xef, 0x45, 0x27, 0x49, 0x04, 0x4a, 0x49,
67 0x0e, 0xdd, 0xe9, 0x51, 0x3b, 0x79, 0x6f, 0x13, 0xa7, 0xf0, 0xb8, 0x87, 0x4a, 0x1f, 0x93, 0xff,
68 0x44, 0x1b, 0x57, 0xf7, 0xd5, 0x3c, 0x72, 0x81, 0xe5, 0x7f, 0xb9, 0xbb, 0x08, 0x76, 0xb5, 0x44,
69 0x7f, 0xc2, 0x52, 0x8c, 0xf8, 0xaf, 0xb2, 0xe0, 0x2c, 0x21, 0xfb, 0x4b, 0x57, 0x27, 0xec, 0x53,
70 0xb9, 0xb8, 0x83, 0x63, 0x2e, 0x52, 0xca, 0xa7, 0x58, 0xc6, 0x5c, 0x24, 0x54, 0x7f, 0x15, 0xd4,
71 0xfe, 0xb6, 0x2e, 0x76, 0xbe, 0xd7, 0x41, 0xeb, 0x9b, 0xf8, 0x79, 0x96, 0xe6, 0x2a, 0x9b, 0x8d,
72 0xab, 0xd1, 0x87, 0x4b, 0x6e, 0xa8, 0xb9, 0xaf, 0xcd, 0x37, 0x33, 0x7f, 0x1b, 0xa6, 0xdc, 0xf9,
73 0x14, 0xc7, 0x8f, 0xea, 0xd4, 0xe9, 0xdf, 0x00, 0x00, 0x00, 0xff, 0xff, 0x1b, 0x1f, 0x15, 0x0e,
74 0x39, 0x07, 0x00, 0x00,
75}
76
77// Reference imports to suppress errors if they are not otherwise used.
78var _ context.Context
79var _ grpc.ClientConn
80
81// This is a compile-time assertion to ensure that this generated file
82// is compatible with the grpc package it is being compiled against.
83const _ = grpc.SupportPackageIsVersion4
84
85// CoreServiceClient is the client API for CoreService service.
86//
87// For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
88type CoreServiceClient interface {
89 // in coreProxy interface
90 GetHealthStatus(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*health.HealthStatus, error)
91 RegisterAdapter(ctx context.Context, in *core_adapter.AdapterRegistration, opts ...grpc.CallOption) (*empty.Empty, error)
92 DeviceUpdate(ctx context.Context, in *voltha.Device, opts ...grpc.CallOption) (*empty.Empty, error)
93 PortCreated(ctx context.Context, in *voltha.Port, opts ...grpc.CallOption) (*empty.Empty, error)
94 PortsStateUpdate(ctx context.Context, in *core_adapter.PortStateFilter, opts ...grpc.CallOption) (*empty.Empty, error)
95 DeleteAllPorts(ctx context.Context, in *common.ID, opts ...grpc.CallOption) (*empty.Empty, error)
96 GetDevicePort(ctx context.Context, in *core_adapter.PortFilter, opts ...grpc.CallOption) (*voltha.Port, error)
97 ListDevicePorts(ctx context.Context, in *common.ID, opts ...grpc.CallOption) (*voltha.Ports, error)
98 DeviceStateUpdate(ctx context.Context, in *core_adapter.DeviceStateFilter, opts ...grpc.CallOption) (*empty.Empty, error)
99 DevicePMConfigUpdate(ctx context.Context, in *voltha.PmConfigs, opts ...grpc.CallOption) (*empty.Empty, error)
100 ChildDeviceDetected(ctx context.Context, in *core_adapter.DeviceDiscovery, opts ...grpc.CallOption) (*voltha.Device, error)
101 ChildDevicesLost(ctx context.Context, in *common.ID, opts ...grpc.CallOption) (*empty.Empty, error)
102 ChildDevicesDetected(ctx context.Context, in *common.ID, opts ...grpc.CallOption) (*empty.Empty, error)
103 GetDevice(ctx context.Context, in *common.ID, opts ...grpc.CallOption) (*voltha.Device, error)
104 GetChildDevice(ctx context.Context, in *core_adapter.ChildDeviceFilter, opts ...grpc.CallOption) (*voltha.Device, error)
105 GetChildDevices(ctx context.Context, in *common.ID, opts ...grpc.CallOption) (*voltha.Devices, error)
106 SendPacketIn(ctx context.Context, in *core_adapter.PacketIn, opts ...grpc.CallOption) (*empty.Empty, error)
107 DeviceReasonUpdate(ctx context.Context, in *core_adapter.DeviceReason, opts ...grpc.CallOption) (*empty.Empty, error)
108 PortStateUpdate(ctx context.Context, in *core_adapter.PortState, opts ...grpc.CallOption) (*empty.Empty, error)
109 // Additional API found in the Core - unused?
110 ReconcileChildDevices(ctx context.Context, in *common.ID, opts ...grpc.CallOption) (*empty.Empty, error)
111 GetChildDeviceWithProxyAddress(ctx context.Context, in *voltha.Device_ProxyAddress, opts ...grpc.CallOption) (*voltha.Device, error)
112 GetPorts(ctx context.Context, in *core_adapter.PortFilter, opts ...grpc.CallOption) (*voltha.Ports, error)
113 ChildrenStateUpdate(ctx context.Context, in *core_adapter.DeviceStateFilter, opts ...grpc.CallOption) (*empty.Empty, error)
114 UpdateImageDownload(ctx context.Context, in *voltha.ImageDownload, opts ...grpc.CallOption) (*empty.Empty, error)
115}
116
117type coreServiceClient struct {
118 cc *grpc.ClientConn
119}
120
121func NewCoreServiceClient(cc *grpc.ClientConn) CoreServiceClient {
122 return &coreServiceClient{cc}
123}
124
125func (c *coreServiceClient) GetHealthStatus(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*health.HealthStatus, error) {
126 out := new(health.HealthStatus)
127 err := c.cc.Invoke(ctx, "/core_service.CoreService/GetHealthStatus", in, out, opts...)
128 if err != nil {
129 return nil, err
130 }
131 return out, nil
132}
133
134func (c *coreServiceClient) RegisterAdapter(ctx context.Context, in *core_adapter.AdapterRegistration, opts ...grpc.CallOption) (*empty.Empty, error) {
135 out := new(empty.Empty)
136 err := c.cc.Invoke(ctx, "/core_service.CoreService/RegisterAdapter", in, out, opts...)
137 if err != nil {
138 return nil, err
139 }
140 return out, nil
141}
142
143func (c *coreServiceClient) DeviceUpdate(ctx context.Context, in *voltha.Device, opts ...grpc.CallOption) (*empty.Empty, error) {
144 out := new(empty.Empty)
145 err := c.cc.Invoke(ctx, "/core_service.CoreService/DeviceUpdate", in, out, opts...)
146 if err != nil {
147 return nil, err
148 }
149 return out, nil
150}
151
152func (c *coreServiceClient) PortCreated(ctx context.Context, in *voltha.Port, opts ...grpc.CallOption) (*empty.Empty, error) {
153 out := new(empty.Empty)
154 err := c.cc.Invoke(ctx, "/core_service.CoreService/PortCreated", in, out, opts...)
155 if err != nil {
156 return nil, err
157 }
158 return out, nil
159}
160
161func (c *coreServiceClient) PortsStateUpdate(ctx context.Context, in *core_adapter.PortStateFilter, opts ...grpc.CallOption) (*empty.Empty, error) {
162 out := new(empty.Empty)
163 err := c.cc.Invoke(ctx, "/core_service.CoreService/PortsStateUpdate", in, out, opts...)
164 if err != nil {
165 return nil, err
166 }
167 return out, nil
168}
169
170func (c *coreServiceClient) DeleteAllPorts(ctx context.Context, in *common.ID, opts ...grpc.CallOption) (*empty.Empty, error) {
171 out := new(empty.Empty)
172 err := c.cc.Invoke(ctx, "/core_service.CoreService/DeleteAllPorts", in, out, opts...)
173 if err != nil {
174 return nil, err
175 }
176 return out, nil
177}
178
179func (c *coreServiceClient) GetDevicePort(ctx context.Context, in *core_adapter.PortFilter, opts ...grpc.CallOption) (*voltha.Port, error) {
180 out := new(voltha.Port)
181 err := c.cc.Invoke(ctx, "/core_service.CoreService/GetDevicePort", in, out, opts...)
182 if err != nil {
183 return nil, err
184 }
185 return out, nil
186}
187
188func (c *coreServiceClient) ListDevicePorts(ctx context.Context, in *common.ID, opts ...grpc.CallOption) (*voltha.Ports, error) {
189 out := new(voltha.Ports)
190 err := c.cc.Invoke(ctx, "/core_service.CoreService/ListDevicePorts", in, out, opts...)
191 if err != nil {
192 return nil, err
193 }
194 return out, nil
195}
196
197func (c *coreServiceClient) DeviceStateUpdate(ctx context.Context, in *core_adapter.DeviceStateFilter, opts ...grpc.CallOption) (*empty.Empty, error) {
198 out := new(empty.Empty)
199 err := c.cc.Invoke(ctx, "/core_service.CoreService/DeviceStateUpdate", in, out, opts...)
200 if err != nil {
201 return nil, err
202 }
203 return out, nil
204}
205
206func (c *coreServiceClient) DevicePMConfigUpdate(ctx context.Context, in *voltha.PmConfigs, opts ...grpc.CallOption) (*empty.Empty, error) {
207 out := new(empty.Empty)
208 err := c.cc.Invoke(ctx, "/core_service.CoreService/DevicePMConfigUpdate", in, out, opts...)
209 if err != nil {
210 return nil, err
211 }
212 return out, nil
213}
214
215func (c *coreServiceClient) ChildDeviceDetected(ctx context.Context, in *core_adapter.DeviceDiscovery, opts ...grpc.CallOption) (*voltha.Device, error) {
216 out := new(voltha.Device)
217 err := c.cc.Invoke(ctx, "/core_service.CoreService/ChildDeviceDetected", in, out, opts...)
218 if err != nil {
219 return nil, err
220 }
221 return out, nil
222}
223
224func (c *coreServiceClient) ChildDevicesLost(ctx context.Context, in *common.ID, opts ...grpc.CallOption) (*empty.Empty, error) {
225 out := new(empty.Empty)
226 err := c.cc.Invoke(ctx, "/core_service.CoreService/ChildDevicesLost", in, out, opts...)
227 if err != nil {
228 return nil, err
229 }
230 return out, nil
231}
232
233func (c *coreServiceClient) ChildDevicesDetected(ctx context.Context, in *common.ID, opts ...grpc.CallOption) (*empty.Empty, error) {
234 out := new(empty.Empty)
235 err := c.cc.Invoke(ctx, "/core_service.CoreService/ChildDevicesDetected", in, out, opts...)
236 if err != nil {
237 return nil, err
238 }
239 return out, nil
240}
241
242func (c *coreServiceClient) GetDevice(ctx context.Context, in *common.ID, opts ...grpc.CallOption) (*voltha.Device, error) {
243 out := new(voltha.Device)
244 err := c.cc.Invoke(ctx, "/core_service.CoreService/GetDevice", in, out, opts...)
245 if err != nil {
246 return nil, err
247 }
248 return out, nil
249}
250
251func (c *coreServiceClient) GetChildDevice(ctx context.Context, in *core_adapter.ChildDeviceFilter, opts ...grpc.CallOption) (*voltha.Device, error) {
252 out := new(voltha.Device)
253 err := c.cc.Invoke(ctx, "/core_service.CoreService/GetChildDevice", in, out, opts...)
254 if err != nil {
255 return nil, err
256 }
257 return out, nil
258}
259
260func (c *coreServiceClient) GetChildDevices(ctx context.Context, in *common.ID, opts ...grpc.CallOption) (*voltha.Devices, error) {
261 out := new(voltha.Devices)
262 err := c.cc.Invoke(ctx, "/core_service.CoreService/GetChildDevices", in, out, opts...)
263 if err != nil {
264 return nil, err
265 }
266 return out, nil
267}
268
269func (c *coreServiceClient) SendPacketIn(ctx context.Context, in *core_adapter.PacketIn, opts ...grpc.CallOption) (*empty.Empty, error) {
270 out := new(empty.Empty)
271 err := c.cc.Invoke(ctx, "/core_service.CoreService/SendPacketIn", in, out, opts...)
272 if err != nil {
273 return nil, err
274 }
275 return out, nil
276}
277
278func (c *coreServiceClient) DeviceReasonUpdate(ctx context.Context, in *core_adapter.DeviceReason, opts ...grpc.CallOption) (*empty.Empty, error) {
279 out := new(empty.Empty)
280 err := c.cc.Invoke(ctx, "/core_service.CoreService/DeviceReasonUpdate", in, out, opts...)
281 if err != nil {
282 return nil, err
283 }
284 return out, nil
285}
286
287func (c *coreServiceClient) PortStateUpdate(ctx context.Context, in *core_adapter.PortState, opts ...grpc.CallOption) (*empty.Empty, error) {
288 out := new(empty.Empty)
289 err := c.cc.Invoke(ctx, "/core_service.CoreService/PortStateUpdate", in, out, opts...)
290 if err != nil {
291 return nil, err
292 }
293 return out, nil
294}
295
296func (c *coreServiceClient) ReconcileChildDevices(ctx context.Context, in *common.ID, opts ...grpc.CallOption) (*empty.Empty, error) {
297 out := new(empty.Empty)
298 err := c.cc.Invoke(ctx, "/core_service.CoreService/ReconcileChildDevices", in, out, opts...)
299 if err != nil {
300 return nil, err
301 }
302 return out, nil
303}
304
305func (c *coreServiceClient) GetChildDeviceWithProxyAddress(ctx context.Context, in *voltha.Device_ProxyAddress, opts ...grpc.CallOption) (*voltha.Device, error) {
306 out := new(voltha.Device)
307 err := c.cc.Invoke(ctx, "/core_service.CoreService/GetChildDeviceWithProxyAddress", in, out, opts...)
308 if err != nil {
309 return nil, err
310 }
311 return out, nil
312}
313
314func (c *coreServiceClient) GetPorts(ctx context.Context, in *core_adapter.PortFilter, opts ...grpc.CallOption) (*voltha.Ports, error) {
315 out := new(voltha.Ports)
316 err := c.cc.Invoke(ctx, "/core_service.CoreService/GetPorts", in, out, opts...)
317 if err != nil {
318 return nil, err
319 }
320 return out, nil
321}
322
323func (c *coreServiceClient) ChildrenStateUpdate(ctx context.Context, in *core_adapter.DeviceStateFilter, opts ...grpc.CallOption) (*empty.Empty, error) {
324 out := new(empty.Empty)
325 err := c.cc.Invoke(ctx, "/core_service.CoreService/ChildrenStateUpdate", in, out, opts...)
326 if err != nil {
327 return nil, err
328 }
329 return out, nil
330}
331
332func (c *coreServiceClient) UpdateImageDownload(ctx context.Context, in *voltha.ImageDownload, opts ...grpc.CallOption) (*empty.Empty, error) {
333 out := new(empty.Empty)
334 err := c.cc.Invoke(ctx, "/core_service.CoreService/UpdateImageDownload", in, out, opts...)
335 if err != nil {
336 return nil, err
337 }
338 return out, nil
339}
340
341// CoreServiceServer is the server API for CoreService service.
342type CoreServiceServer interface {
343 // in coreProxy interface
344 GetHealthStatus(context.Context, *empty.Empty) (*health.HealthStatus, error)
345 RegisterAdapter(context.Context, *core_adapter.AdapterRegistration) (*empty.Empty, error)
346 DeviceUpdate(context.Context, *voltha.Device) (*empty.Empty, error)
347 PortCreated(context.Context, *voltha.Port) (*empty.Empty, error)
348 PortsStateUpdate(context.Context, *core_adapter.PortStateFilter) (*empty.Empty, error)
349 DeleteAllPorts(context.Context, *common.ID) (*empty.Empty, error)
350 GetDevicePort(context.Context, *core_adapter.PortFilter) (*voltha.Port, error)
351 ListDevicePorts(context.Context, *common.ID) (*voltha.Ports, error)
352 DeviceStateUpdate(context.Context, *core_adapter.DeviceStateFilter) (*empty.Empty, error)
353 DevicePMConfigUpdate(context.Context, *voltha.PmConfigs) (*empty.Empty, error)
354 ChildDeviceDetected(context.Context, *core_adapter.DeviceDiscovery) (*voltha.Device, error)
355 ChildDevicesLost(context.Context, *common.ID) (*empty.Empty, error)
356 ChildDevicesDetected(context.Context, *common.ID) (*empty.Empty, error)
357 GetDevice(context.Context, *common.ID) (*voltha.Device, error)
358 GetChildDevice(context.Context, *core_adapter.ChildDeviceFilter) (*voltha.Device, error)
359 GetChildDevices(context.Context, *common.ID) (*voltha.Devices, error)
360 SendPacketIn(context.Context, *core_adapter.PacketIn) (*empty.Empty, error)
361 DeviceReasonUpdate(context.Context, *core_adapter.DeviceReason) (*empty.Empty, error)
362 PortStateUpdate(context.Context, *core_adapter.PortState) (*empty.Empty, error)
363 // Additional API found in the Core - unused?
364 ReconcileChildDevices(context.Context, *common.ID) (*empty.Empty, error)
365 GetChildDeviceWithProxyAddress(context.Context, *voltha.Device_ProxyAddress) (*voltha.Device, error)
366 GetPorts(context.Context, *core_adapter.PortFilter) (*voltha.Ports, error)
367 ChildrenStateUpdate(context.Context, *core_adapter.DeviceStateFilter) (*empty.Empty, error)
368 UpdateImageDownload(context.Context, *voltha.ImageDownload) (*empty.Empty, error)
369}
370
371// UnimplementedCoreServiceServer can be embedded to have forward compatible implementations.
372type UnimplementedCoreServiceServer struct {
373}
374
375func (*UnimplementedCoreServiceServer) GetHealthStatus(ctx context.Context, req *empty.Empty) (*health.HealthStatus, error) {
376 return nil, status.Errorf(codes.Unimplemented, "method GetHealthStatus not implemented")
377}
378func (*UnimplementedCoreServiceServer) RegisterAdapter(ctx context.Context, req *core_adapter.AdapterRegistration) (*empty.Empty, error) {
379 return nil, status.Errorf(codes.Unimplemented, "method RegisterAdapter not implemented")
380}
381func (*UnimplementedCoreServiceServer) DeviceUpdate(ctx context.Context, req *voltha.Device) (*empty.Empty, error) {
382 return nil, status.Errorf(codes.Unimplemented, "method DeviceUpdate not implemented")
383}
384func (*UnimplementedCoreServiceServer) PortCreated(ctx context.Context, req *voltha.Port) (*empty.Empty, error) {
385 return nil, status.Errorf(codes.Unimplemented, "method PortCreated not implemented")
386}
387func (*UnimplementedCoreServiceServer) PortsStateUpdate(ctx context.Context, req *core_adapter.PortStateFilter) (*empty.Empty, error) {
388 return nil, status.Errorf(codes.Unimplemented, "method PortsStateUpdate not implemented")
389}
390func (*UnimplementedCoreServiceServer) DeleteAllPorts(ctx context.Context, req *common.ID) (*empty.Empty, error) {
391 return nil, status.Errorf(codes.Unimplemented, "method DeleteAllPorts not implemented")
392}
393func (*UnimplementedCoreServiceServer) GetDevicePort(ctx context.Context, req *core_adapter.PortFilter) (*voltha.Port, error) {
394 return nil, status.Errorf(codes.Unimplemented, "method GetDevicePort not implemented")
395}
396func (*UnimplementedCoreServiceServer) ListDevicePorts(ctx context.Context, req *common.ID) (*voltha.Ports, error) {
397 return nil, status.Errorf(codes.Unimplemented, "method ListDevicePorts not implemented")
398}
399func (*UnimplementedCoreServiceServer) DeviceStateUpdate(ctx context.Context, req *core_adapter.DeviceStateFilter) (*empty.Empty, error) {
400 return nil, status.Errorf(codes.Unimplemented, "method DeviceStateUpdate not implemented")
401}
402func (*UnimplementedCoreServiceServer) DevicePMConfigUpdate(ctx context.Context, req *voltha.PmConfigs) (*empty.Empty, error) {
403 return nil, status.Errorf(codes.Unimplemented, "method DevicePMConfigUpdate not implemented")
404}
405func (*UnimplementedCoreServiceServer) ChildDeviceDetected(ctx context.Context, req *core_adapter.DeviceDiscovery) (*voltha.Device, error) {
406 return nil, status.Errorf(codes.Unimplemented, "method ChildDeviceDetected not implemented")
407}
408func (*UnimplementedCoreServiceServer) ChildDevicesLost(ctx context.Context, req *common.ID) (*empty.Empty, error) {
409 return nil, status.Errorf(codes.Unimplemented, "method ChildDevicesLost not implemented")
410}
411func (*UnimplementedCoreServiceServer) ChildDevicesDetected(ctx context.Context, req *common.ID) (*empty.Empty, error) {
412 return nil, status.Errorf(codes.Unimplemented, "method ChildDevicesDetected not implemented")
413}
414func (*UnimplementedCoreServiceServer) GetDevice(ctx context.Context, req *common.ID) (*voltha.Device, error) {
415 return nil, status.Errorf(codes.Unimplemented, "method GetDevice not implemented")
416}
417func (*UnimplementedCoreServiceServer) GetChildDevice(ctx context.Context, req *core_adapter.ChildDeviceFilter) (*voltha.Device, error) {
418 return nil, status.Errorf(codes.Unimplemented, "method GetChildDevice not implemented")
419}
420func (*UnimplementedCoreServiceServer) GetChildDevices(ctx context.Context, req *common.ID) (*voltha.Devices, error) {
421 return nil, status.Errorf(codes.Unimplemented, "method GetChildDevices not implemented")
422}
423func (*UnimplementedCoreServiceServer) SendPacketIn(ctx context.Context, req *core_adapter.PacketIn) (*empty.Empty, error) {
424 return nil, status.Errorf(codes.Unimplemented, "method SendPacketIn not implemented")
425}
426func (*UnimplementedCoreServiceServer) DeviceReasonUpdate(ctx context.Context, req *core_adapter.DeviceReason) (*empty.Empty, error) {
427 return nil, status.Errorf(codes.Unimplemented, "method DeviceReasonUpdate not implemented")
428}
429func (*UnimplementedCoreServiceServer) PortStateUpdate(ctx context.Context, req *core_adapter.PortState) (*empty.Empty, error) {
430 return nil, status.Errorf(codes.Unimplemented, "method PortStateUpdate not implemented")
431}
432func (*UnimplementedCoreServiceServer) ReconcileChildDevices(ctx context.Context, req *common.ID) (*empty.Empty, error) {
433 return nil, status.Errorf(codes.Unimplemented, "method ReconcileChildDevices not implemented")
434}
435func (*UnimplementedCoreServiceServer) GetChildDeviceWithProxyAddress(ctx context.Context, req *voltha.Device_ProxyAddress) (*voltha.Device, error) {
436 return nil, status.Errorf(codes.Unimplemented, "method GetChildDeviceWithProxyAddress not implemented")
437}
438func (*UnimplementedCoreServiceServer) GetPorts(ctx context.Context, req *core_adapter.PortFilter) (*voltha.Ports, error) {
439 return nil, status.Errorf(codes.Unimplemented, "method GetPorts not implemented")
440}
441func (*UnimplementedCoreServiceServer) ChildrenStateUpdate(ctx context.Context, req *core_adapter.DeviceStateFilter) (*empty.Empty, error) {
442 return nil, status.Errorf(codes.Unimplemented, "method ChildrenStateUpdate not implemented")
443}
444func (*UnimplementedCoreServiceServer) UpdateImageDownload(ctx context.Context, req *voltha.ImageDownload) (*empty.Empty, error) {
445 return nil, status.Errorf(codes.Unimplemented, "method UpdateImageDownload not implemented")
446}
447
448func RegisterCoreServiceServer(s *grpc.Server, srv CoreServiceServer) {
449 s.RegisterService(&_CoreService_serviceDesc, srv)
450}
451
452func _CoreService_GetHealthStatus_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
453 in := new(empty.Empty)
454 if err := dec(in); err != nil {
455 return nil, err
456 }
457 if interceptor == nil {
458 return srv.(CoreServiceServer).GetHealthStatus(ctx, in)
459 }
460 info := &grpc.UnaryServerInfo{
461 Server: srv,
462 FullMethod: "/core_service.CoreService/GetHealthStatus",
463 }
464 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
465 return srv.(CoreServiceServer).GetHealthStatus(ctx, req.(*empty.Empty))
466 }
467 return interceptor(ctx, in, info, handler)
468}
469
470func _CoreService_RegisterAdapter_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
471 in := new(core_adapter.AdapterRegistration)
472 if err := dec(in); err != nil {
473 return nil, err
474 }
475 if interceptor == nil {
476 return srv.(CoreServiceServer).RegisterAdapter(ctx, in)
477 }
478 info := &grpc.UnaryServerInfo{
479 Server: srv,
480 FullMethod: "/core_service.CoreService/RegisterAdapter",
481 }
482 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
483 return srv.(CoreServiceServer).RegisterAdapter(ctx, req.(*core_adapter.AdapterRegistration))
484 }
485 return interceptor(ctx, in, info, handler)
486}
487
488func _CoreService_DeviceUpdate_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
489 in := new(voltha.Device)
490 if err := dec(in); err != nil {
491 return nil, err
492 }
493 if interceptor == nil {
494 return srv.(CoreServiceServer).DeviceUpdate(ctx, in)
495 }
496 info := &grpc.UnaryServerInfo{
497 Server: srv,
498 FullMethod: "/core_service.CoreService/DeviceUpdate",
499 }
500 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
501 return srv.(CoreServiceServer).DeviceUpdate(ctx, req.(*voltha.Device))
502 }
503 return interceptor(ctx, in, info, handler)
504}
505
506func _CoreService_PortCreated_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
507 in := new(voltha.Port)
508 if err := dec(in); err != nil {
509 return nil, err
510 }
511 if interceptor == nil {
512 return srv.(CoreServiceServer).PortCreated(ctx, in)
513 }
514 info := &grpc.UnaryServerInfo{
515 Server: srv,
516 FullMethod: "/core_service.CoreService/PortCreated",
517 }
518 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
519 return srv.(CoreServiceServer).PortCreated(ctx, req.(*voltha.Port))
520 }
521 return interceptor(ctx, in, info, handler)
522}
523
524func _CoreService_PortsStateUpdate_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
525 in := new(core_adapter.PortStateFilter)
526 if err := dec(in); err != nil {
527 return nil, err
528 }
529 if interceptor == nil {
530 return srv.(CoreServiceServer).PortsStateUpdate(ctx, in)
531 }
532 info := &grpc.UnaryServerInfo{
533 Server: srv,
534 FullMethod: "/core_service.CoreService/PortsStateUpdate",
535 }
536 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
537 return srv.(CoreServiceServer).PortsStateUpdate(ctx, req.(*core_adapter.PortStateFilter))
538 }
539 return interceptor(ctx, in, info, handler)
540}
541
542func _CoreService_DeleteAllPorts_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
543 in := new(common.ID)
544 if err := dec(in); err != nil {
545 return nil, err
546 }
547 if interceptor == nil {
548 return srv.(CoreServiceServer).DeleteAllPorts(ctx, in)
549 }
550 info := &grpc.UnaryServerInfo{
551 Server: srv,
552 FullMethod: "/core_service.CoreService/DeleteAllPorts",
553 }
554 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
555 return srv.(CoreServiceServer).DeleteAllPorts(ctx, req.(*common.ID))
556 }
557 return interceptor(ctx, in, info, handler)
558}
559
560func _CoreService_GetDevicePort_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
561 in := new(core_adapter.PortFilter)
562 if err := dec(in); err != nil {
563 return nil, err
564 }
565 if interceptor == nil {
566 return srv.(CoreServiceServer).GetDevicePort(ctx, in)
567 }
568 info := &grpc.UnaryServerInfo{
569 Server: srv,
570 FullMethod: "/core_service.CoreService/GetDevicePort",
571 }
572 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
573 return srv.(CoreServiceServer).GetDevicePort(ctx, req.(*core_adapter.PortFilter))
574 }
575 return interceptor(ctx, in, info, handler)
576}
577
578func _CoreService_ListDevicePorts_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
579 in := new(common.ID)
580 if err := dec(in); err != nil {
581 return nil, err
582 }
583 if interceptor == nil {
584 return srv.(CoreServiceServer).ListDevicePorts(ctx, in)
585 }
586 info := &grpc.UnaryServerInfo{
587 Server: srv,
588 FullMethod: "/core_service.CoreService/ListDevicePorts",
589 }
590 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
591 return srv.(CoreServiceServer).ListDevicePorts(ctx, req.(*common.ID))
592 }
593 return interceptor(ctx, in, info, handler)
594}
595
596func _CoreService_DeviceStateUpdate_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
597 in := new(core_adapter.DeviceStateFilter)
598 if err := dec(in); err != nil {
599 return nil, err
600 }
601 if interceptor == nil {
602 return srv.(CoreServiceServer).DeviceStateUpdate(ctx, in)
603 }
604 info := &grpc.UnaryServerInfo{
605 Server: srv,
606 FullMethod: "/core_service.CoreService/DeviceStateUpdate",
607 }
608 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
609 return srv.(CoreServiceServer).DeviceStateUpdate(ctx, req.(*core_adapter.DeviceStateFilter))
610 }
611 return interceptor(ctx, in, info, handler)
612}
613
614func _CoreService_DevicePMConfigUpdate_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
615 in := new(voltha.PmConfigs)
616 if err := dec(in); err != nil {
617 return nil, err
618 }
619 if interceptor == nil {
620 return srv.(CoreServiceServer).DevicePMConfigUpdate(ctx, in)
621 }
622 info := &grpc.UnaryServerInfo{
623 Server: srv,
624 FullMethod: "/core_service.CoreService/DevicePMConfigUpdate",
625 }
626 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
627 return srv.(CoreServiceServer).DevicePMConfigUpdate(ctx, req.(*voltha.PmConfigs))
628 }
629 return interceptor(ctx, in, info, handler)
630}
631
632func _CoreService_ChildDeviceDetected_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
633 in := new(core_adapter.DeviceDiscovery)
634 if err := dec(in); err != nil {
635 return nil, err
636 }
637 if interceptor == nil {
638 return srv.(CoreServiceServer).ChildDeviceDetected(ctx, in)
639 }
640 info := &grpc.UnaryServerInfo{
641 Server: srv,
642 FullMethod: "/core_service.CoreService/ChildDeviceDetected",
643 }
644 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
645 return srv.(CoreServiceServer).ChildDeviceDetected(ctx, req.(*core_adapter.DeviceDiscovery))
646 }
647 return interceptor(ctx, in, info, handler)
648}
649
650func _CoreService_ChildDevicesLost_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
651 in := new(common.ID)
652 if err := dec(in); err != nil {
653 return nil, err
654 }
655 if interceptor == nil {
656 return srv.(CoreServiceServer).ChildDevicesLost(ctx, in)
657 }
658 info := &grpc.UnaryServerInfo{
659 Server: srv,
660 FullMethod: "/core_service.CoreService/ChildDevicesLost",
661 }
662 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
663 return srv.(CoreServiceServer).ChildDevicesLost(ctx, req.(*common.ID))
664 }
665 return interceptor(ctx, in, info, handler)
666}
667
668func _CoreService_ChildDevicesDetected_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
669 in := new(common.ID)
670 if err := dec(in); err != nil {
671 return nil, err
672 }
673 if interceptor == nil {
674 return srv.(CoreServiceServer).ChildDevicesDetected(ctx, in)
675 }
676 info := &grpc.UnaryServerInfo{
677 Server: srv,
678 FullMethod: "/core_service.CoreService/ChildDevicesDetected",
679 }
680 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
681 return srv.(CoreServiceServer).ChildDevicesDetected(ctx, req.(*common.ID))
682 }
683 return interceptor(ctx, in, info, handler)
684}
685
686func _CoreService_GetDevice_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
687 in := new(common.ID)
688 if err := dec(in); err != nil {
689 return nil, err
690 }
691 if interceptor == nil {
692 return srv.(CoreServiceServer).GetDevice(ctx, in)
693 }
694 info := &grpc.UnaryServerInfo{
695 Server: srv,
696 FullMethod: "/core_service.CoreService/GetDevice",
697 }
698 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
699 return srv.(CoreServiceServer).GetDevice(ctx, req.(*common.ID))
700 }
701 return interceptor(ctx, in, info, handler)
702}
703
704func _CoreService_GetChildDevice_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
705 in := new(core_adapter.ChildDeviceFilter)
706 if err := dec(in); err != nil {
707 return nil, err
708 }
709 if interceptor == nil {
710 return srv.(CoreServiceServer).GetChildDevice(ctx, in)
711 }
712 info := &grpc.UnaryServerInfo{
713 Server: srv,
714 FullMethod: "/core_service.CoreService/GetChildDevice",
715 }
716 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
717 return srv.(CoreServiceServer).GetChildDevice(ctx, req.(*core_adapter.ChildDeviceFilter))
718 }
719 return interceptor(ctx, in, info, handler)
720}
721
722func _CoreService_GetChildDevices_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
723 in := new(common.ID)
724 if err := dec(in); err != nil {
725 return nil, err
726 }
727 if interceptor == nil {
728 return srv.(CoreServiceServer).GetChildDevices(ctx, in)
729 }
730 info := &grpc.UnaryServerInfo{
731 Server: srv,
732 FullMethod: "/core_service.CoreService/GetChildDevices",
733 }
734 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
735 return srv.(CoreServiceServer).GetChildDevices(ctx, req.(*common.ID))
736 }
737 return interceptor(ctx, in, info, handler)
738}
739
740func _CoreService_SendPacketIn_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
741 in := new(core_adapter.PacketIn)
742 if err := dec(in); err != nil {
743 return nil, err
744 }
745 if interceptor == nil {
746 return srv.(CoreServiceServer).SendPacketIn(ctx, in)
747 }
748 info := &grpc.UnaryServerInfo{
749 Server: srv,
750 FullMethod: "/core_service.CoreService/SendPacketIn",
751 }
752 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
753 return srv.(CoreServiceServer).SendPacketIn(ctx, req.(*core_adapter.PacketIn))
754 }
755 return interceptor(ctx, in, info, handler)
756}
757
758func _CoreService_DeviceReasonUpdate_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
759 in := new(core_adapter.DeviceReason)
760 if err := dec(in); err != nil {
761 return nil, err
762 }
763 if interceptor == nil {
764 return srv.(CoreServiceServer).DeviceReasonUpdate(ctx, in)
765 }
766 info := &grpc.UnaryServerInfo{
767 Server: srv,
768 FullMethod: "/core_service.CoreService/DeviceReasonUpdate",
769 }
770 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
771 return srv.(CoreServiceServer).DeviceReasonUpdate(ctx, req.(*core_adapter.DeviceReason))
772 }
773 return interceptor(ctx, in, info, handler)
774}
775
776func _CoreService_PortStateUpdate_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
777 in := new(core_adapter.PortState)
778 if err := dec(in); err != nil {
779 return nil, err
780 }
781 if interceptor == nil {
782 return srv.(CoreServiceServer).PortStateUpdate(ctx, in)
783 }
784 info := &grpc.UnaryServerInfo{
785 Server: srv,
786 FullMethod: "/core_service.CoreService/PortStateUpdate",
787 }
788 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
789 return srv.(CoreServiceServer).PortStateUpdate(ctx, req.(*core_adapter.PortState))
790 }
791 return interceptor(ctx, in, info, handler)
792}
793
794func _CoreService_ReconcileChildDevices_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
795 in := new(common.ID)
796 if err := dec(in); err != nil {
797 return nil, err
798 }
799 if interceptor == nil {
800 return srv.(CoreServiceServer).ReconcileChildDevices(ctx, in)
801 }
802 info := &grpc.UnaryServerInfo{
803 Server: srv,
804 FullMethod: "/core_service.CoreService/ReconcileChildDevices",
805 }
806 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
807 return srv.(CoreServiceServer).ReconcileChildDevices(ctx, req.(*common.ID))
808 }
809 return interceptor(ctx, in, info, handler)
810}
811
812func _CoreService_GetChildDeviceWithProxyAddress_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
813 in := new(voltha.Device_ProxyAddress)
814 if err := dec(in); err != nil {
815 return nil, err
816 }
817 if interceptor == nil {
818 return srv.(CoreServiceServer).GetChildDeviceWithProxyAddress(ctx, in)
819 }
820 info := &grpc.UnaryServerInfo{
821 Server: srv,
822 FullMethod: "/core_service.CoreService/GetChildDeviceWithProxyAddress",
823 }
824 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
825 return srv.(CoreServiceServer).GetChildDeviceWithProxyAddress(ctx, req.(*voltha.Device_ProxyAddress))
826 }
827 return interceptor(ctx, in, info, handler)
828}
829
830func _CoreService_GetPorts_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
831 in := new(core_adapter.PortFilter)
832 if err := dec(in); err != nil {
833 return nil, err
834 }
835 if interceptor == nil {
836 return srv.(CoreServiceServer).GetPorts(ctx, in)
837 }
838 info := &grpc.UnaryServerInfo{
839 Server: srv,
840 FullMethod: "/core_service.CoreService/GetPorts",
841 }
842 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
843 return srv.(CoreServiceServer).GetPorts(ctx, req.(*core_adapter.PortFilter))
844 }
845 return interceptor(ctx, in, info, handler)
846}
847
848func _CoreService_ChildrenStateUpdate_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
849 in := new(core_adapter.DeviceStateFilter)
850 if err := dec(in); err != nil {
851 return nil, err
852 }
853 if interceptor == nil {
854 return srv.(CoreServiceServer).ChildrenStateUpdate(ctx, in)
855 }
856 info := &grpc.UnaryServerInfo{
857 Server: srv,
858 FullMethod: "/core_service.CoreService/ChildrenStateUpdate",
859 }
860 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
861 return srv.(CoreServiceServer).ChildrenStateUpdate(ctx, req.(*core_adapter.DeviceStateFilter))
862 }
863 return interceptor(ctx, in, info, handler)
864}
865
866func _CoreService_UpdateImageDownload_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
867 in := new(voltha.ImageDownload)
868 if err := dec(in); err != nil {
869 return nil, err
870 }
871 if interceptor == nil {
872 return srv.(CoreServiceServer).UpdateImageDownload(ctx, in)
873 }
874 info := &grpc.UnaryServerInfo{
875 Server: srv,
876 FullMethod: "/core_service.CoreService/UpdateImageDownload",
877 }
878 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
879 return srv.(CoreServiceServer).UpdateImageDownload(ctx, req.(*voltha.ImageDownload))
880 }
881 return interceptor(ctx, in, info, handler)
882}
883
884var _CoreService_serviceDesc = grpc.ServiceDesc{
885 ServiceName: "core_service.CoreService",
886 HandlerType: (*CoreServiceServer)(nil),
887 Methods: []grpc.MethodDesc{
888 {
889 MethodName: "GetHealthStatus",
890 Handler: _CoreService_GetHealthStatus_Handler,
891 },
892 {
893 MethodName: "RegisterAdapter",
894 Handler: _CoreService_RegisterAdapter_Handler,
895 },
896 {
897 MethodName: "DeviceUpdate",
898 Handler: _CoreService_DeviceUpdate_Handler,
899 },
900 {
901 MethodName: "PortCreated",
902 Handler: _CoreService_PortCreated_Handler,
903 },
904 {
905 MethodName: "PortsStateUpdate",
906 Handler: _CoreService_PortsStateUpdate_Handler,
907 },
908 {
909 MethodName: "DeleteAllPorts",
910 Handler: _CoreService_DeleteAllPorts_Handler,
911 },
912 {
913 MethodName: "GetDevicePort",
914 Handler: _CoreService_GetDevicePort_Handler,
915 },
916 {
917 MethodName: "ListDevicePorts",
918 Handler: _CoreService_ListDevicePorts_Handler,
919 },
920 {
921 MethodName: "DeviceStateUpdate",
922 Handler: _CoreService_DeviceStateUpdate_Handler,
923 },
924 {
925 MethodName: "DevicePMConfigUpdate",
926 Handler: _CoreService_DevicePMConfigUpdate_Handler,
927 },
928 {
929 MethodName: "ChildDeviceDetected",
930 Handler: _CoreService_ChildDeviceDetected_Handler,
931 },
932 {
933 MethodName: "ChildDevicesLost",
934 Handler: _CoreService_ChildDevicesLost_Handler,
935 },
936 {
937 MethodName: "ChildDevicesDetected",
938 Handler: _CoreService_ChildDevicesDetected_Handler,
939 },
940 {
941 MethodName: "GetDevice",
942 Handler: _CoreService_GetDevice_Handler,
943 },
944 {
945 MethodName: "GetChildDevice",
946 Handler: _CoreService_GetChildDevice_Handler,
947 },
948 {
949 MethodName: "GetChildDevices",
950 Handler: _CoreService_GetChildDevices_Handler,
951 },
952 {
953 MethodName: "SendPacketIn",
954 Handler: _CoreService_SendPacketIn_Handler,
955 },
956 {
957 MethodName: "DeviceReasonUpdate",
958 Handler: _CoreService_DeviceReasonUpdate_Handler,
959 },
960 {
961 MethodName: "PortStateUpdate",
962 Handler: _CoreService_PortStateUpdate_Handler,
963 },
964 {
965 MethodName: "ReconcileChildDevices",
966 Handler: _CoreService_ReconcileChildDevices_Handler,
967 },
968 {
969 MethodName: "GetChildDeviceWithProxyAddress",
970 Handler: _CoreService_GetChildDeviceWithProxyAddress_Handler,
971 },
972 {
973 MethodName: "GetPorts",
974 Handler: _CoreService_GetPorts_Handler,
975 },
976 {
977 MethodName: "ChildrenStateUpdate",
978 Handler: _CoreService_ChildrenStateUpdate_Handler,
979 },
980 {
981 MethodName: "UpdateImageDownload",
982 Handler: _CoreService_UpdateImageDownload_Handler,
983 },
984 },
985 Streams: []grpc.StreamDesc{},
986 Metadata: "voltha_protos/core_services.proto",
987}