blob: d157d2305e8904742ecea6c74651224228da74d5 [file] [log] [blame]
William Kurkian1b363f42019-03-12 15:28:12 -04001// Code generated by protoc-gen-go. DO NOT EDIT.
2// source: voltha_protos/voltha.proto
3
William Kurkianad745652019-03-20 08:45:51 -04004package voltha
William Kurkian1b363f42019-03-12 15:28:12 -04005
6import (
William Kurkianad745652019-03-20 08:45:51 -04007 context "context"
8 fmt "fmt"
9 proto "github.com/golang/protobuf/proto"
10 empty "github.com/golang/protobuf/ptypes/empty"
khenaidoo5fc5cea2021-08-11 17:39:16 -040011 common "github.com/opencord/voltha-protos/v5/go/common"
khenaidoo4c6543e2021-10-19 17:25:58 -040012 extension "github.com/opencord/voltha-protos/v5/go/extension"
13 health "github.com/opencord/voltha-protos/v5/go/health"
khenaidoo5fc5cea2021-08-11 17:39:16 -040014 omci "github.com/opencord/voltha-protos/v5/go/omci"
15 openflow_13 "github.com/opencord/voltha-protos/v5/go/openflow_13"
William Kurkianad745652019-03-20 08:45:51 -040016 _ "google.golang.org/genproto/googleapis/api/annotations"
William Kurkian1b363f42019-03-12 15:28:12 -040017 grpc "google.golang.org/grpc"
David K. Bainbridgec4bf5382021-04-08 16:06:54 +000018 codes "google.golang.org/grpc/codes"
19 status "google.golang.org/grpc/status"
William Kurkianad745652019-03-20 08:45:51 -040020 math "math"
William Kurkian1b363f42019-03-12 15:28:12 -040021)
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.
William Kurkianad745652019-03-20 08:45:51 -040032const _ = proto.ProtoPackageIsVersion3 // please upgrade the proto package
William Kurkian1b363f42019-03-12 15:28:12 -040033
William Kurkian1b363f42019-03-12 15:28:12 -040034// ID from public import voltha_protos/common.proto
35type ID = common.ID
36
37// IDs from public import voltha_protos/common.proto
38type IDs = common.IDs
39
khenaidoo5cb0d402021-12-08 14:09:16 -050040// Connection from public import voltha_protos/common.proto
41type Connection = common.Connection
42
William Kurkian1b363f42019-03-12 15:28:12 -040043// AdminState from public import voltha_protos/common.proto
44type AdminState = common.AdminState
45
46// OperStatus from public import voltha_protos/common.proto
47type OperStatus = common.OperStatus
48
49// ConnectStatus from public import voltha_protos/common.proto
50type ConnectStatus = common.ConnectStatus
51
52// OperationResp from public import voltha_protos/common.proto
53type OperationResp = common.OperationResp
54
55// TestModeKeys from public import voltha_protos/common.proto
56type TestModeKeys = common.TestModeKeys
57
58var TestModeKeys_name = common.TestModeKeys_name
59var TestModeKeys_value = common.TestModeKeys_value
60
61const TestModeKeys_api_test = TestModeKeys(common.TestModeKeys_api_test)
62
Serkant Uluderyacbcfaa42019-10-18 13:25:08 +030063// AdminState_Types from public import voltha_protos/common.proto
64type AdminState_Types = common.AdminState_Types
William Kurkian1b363f42019-03-12 15:28:12 -040065
Serkant Uluderyacbcfaa42019-10-18 13:25:08 +030066var AdminState_Types_name = common.AdminState_Types_name
67var AdminState_Types_value = common.AdminState_Types_value
William Kurkian1b363f42019-03-12 15:28:12 -040068
Serkant Uluderyacbcfaa42019-10-18 13:25:08 +030069const AdminState_UNKNOWN = AdminState_Types(common.AdminState_UNKNOWN)
70const AdminState_PREPROVISIONED = AdminState_Types(common.AdminState_PREPROVISIONED)
71const AdminState_ENABLED = AdminState_Types(common.AdminState_ENABLED)
72const AdminState_DISABLED = AdminState_Types(common.AdminState_DISABLED)
73const AdminState_DOWNLOADING_IMAGE = AdminState_Types(common.AdminState_DOWNLOADING_IMAGE)
William Kurkian1b363f42019-03-12 15:28:12 -040074
Serkant Uluderyacbcfaa42019-10-18 13:25:08 +030075// OperStatus_Types from public import voltha_protos/common.proto
76type OperStatus_Types = common.OperStatus_Types
William Kurkian1b363f42019-03-12 15:28:12 -040077
Serkant Uluderyacbcfaa42019-10-18 13:25:08 +030078var OperStatus_Types_name = common.OperStatus_Types_name
79var OperStatus_Types_value = common.OperStatus_Types_value
William Kurkian1b363f42019-03-12 15:28:12 -040080
Serkant Uluderyacbcfaa42019-10-18 13:25:08 +030081const OperStatus_UNKNOWN = OperStatus_Types(common.OperStatus_UNKNOWN)
82const OperStatus_DISCOVERED = OperStatus_Types(common.OperStatus_DISCOVERED)
83const OperStatus_ACTIVATING = OperStatus_Types(common.OperStatus_ACTIVATING)
84const OperStatus_TESTING = OperStatus_Types(common.OperStatus_TESTING)
85const OperStatus_ACTIVE = OperStatus_Types(common.OperStatus_ACTIVE)
86const OperStatus_FAILED = OperStatus_Types(common.OperStatus_FAILED)
Maninder4ed97f52021-03-15 10:14:55 +053087const OperStatus_RECONCILING = OperStatus_Types(common.OperStatus_RECONCILING)
Manindera4b9e552021-06-16 17:33:04 +053088const OperStatus_RECONCILING_FAILED = OperStatus_Types(common.OperStatus_RECONCILING_FAILED)
Abhilash Laxmeshwar540a0b92022-06-13 11:24:06 +053089const OperStatus_REBOOTED = OperStatus_Types(common.OperStatus_REBOOTED)
William Kurkian1b363f42019-03-12 15:28:12 -040090
Serkant Uluderyacbcfaa42019-10-18 13:25:08 +030091// ConnectStatus_Types from public import voltha_protos/common.proto
92type ConnectStatus_Types = common.ConnectStatus_Types
William Kurkian1b363f42019-03-12 15:28:12 -040093
Serkant Uluderyacbcfaa42019-10-18 13:25:08 +030094var ConnectStatus_Types_name = common.ConnectStatus_Types_name
95var ConnectStatus_Types_value = common.ConnectStatus_Types_value
William Kurkian1b363f42019-03-12 15:28:12 -040096
Serkant Uluderyacbcfaa42019-10-18 13:25:08 +030097const ConnectStatus_UNKNOWN = ConnectStatus_Types(common.ConnectStatus_UNKNOWN)
98const ConnectStatus_UNREACHABLE = ConnectStatus_Types(common.ConnectStatus_UNREACHABLE)
99const ConnectStatus_REACHABLE = ConnectStatus_Types(common.ConnectStatus_REACHABLE)
William Kurkian1b363f42019-03-12 15:28:12 -0400100
William Kurkianad745652019-03-20 08:45:51 -0400101// OperationResp_OperationReturnCode from public import voltha_protos/common.proto
William Kurkian1b363f42019-03-12 15:28:12 -0400102type OperationResp_OperationReturnCode = common.OperationResp_OperationReturnCode
103
104var OperationResp_OperationReturnCode_name = common.OperationResp_OperationReturnCode_name
105var OperationResp_OperationReturnCode_value = common.OperationResp_OperationReturnCode_value
106
107const OperationResp_OPERATION_SUCCESS = OperationResp_OperationReturnCode(common.OperationResp_OPERATION_SUCCESS)
108const OperationResp_OPERATION_FAILURE = OperationResp_OperationReturnCode(common.OperationResp_OPERATION_FAILURE)
109const OperationResp_OPERATION_UNSUPPORTED = OperationResp_OperationReturnCode(common.OperationResp_OPERATION_UNSUPPORTED)
Maninder2f9d63e2021-02-08 11:42:19 +0530110const OperationResp_OPERATION_IN_PROGRESS = OperationResp_OperationReturnCode(common.OperationResp_OPERATION_IN_PROGRESS)
William Kurkian1b363f42019-03-12 15:28:12 -0400111
William Kurkian1b363f42019-03-12 15:28:12 -0400112// CoreInstance represents a core instance. It is data held in memory when a core
113// is running. This data is not persistent.
114type CoreInstance struct {
khenaidoo4c6543e2021-10-19 17:25:58 -0400115 InstanceId string `protobuf:"bytes,1,opt,name=instance_id,json=instanceId,proto3" json:"instance_id,omitempty"`
116 Health *health.HealthStatus `protobuf:"bytes,2,opt,name=health,proto3" json:"health,omitempty"`
117 XXX_NoUnkeyedLiteral struct{} `json:"-"`
118 XXX_unrecognized []byte `json:"-"`
119 XXX_sizecache int32 `json:"-"`
William Kurkian1b363f42019-03-12 15:28:12 -0400120}
121
122func (m *CoreInstance) Reset() { *m = CoreInstance{} }
123func (m *CoreInstance) String() string { return proto.CompactTextString(m) }
124func (*CoreInstance) ProtoMessage() {}
125func (*CoreInstance) Descriptor() ([]byte, []int) {
khenaidoo4c6543e2021-10-19 17:25:58 -0400126 return fileDescriptor_e084f1a60ce7016c, []int{0}
William Kurkian1b363f42019-03-12 15:28:12 -0400127}
William Kurkianad745652019-03-20 08:45:51 -0400128
William Kurkian1b363f42019-03-12 15:28:12 -0400129func (m *CoreInstance) XXX_Unmarshal(b []byte) error {
130 return xxx_messageInfo_CoreInstance.Unmarshal(m, b)
131}
132func (m *CoreInstance) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
133 return xxx_messageInfo_CoreInstance.Marshal(b, m, deterministic)
134}
William Kurkianad745652019-03-20 08:45:51 -0400135func (m *CoreInstance) XXX_Merge(src proto.Message) {
136 xxx_messageInfo_CoreInstance.Merge(m, src)
William Kurkian1b363f42019-03-12 15:28:12 -0400137}
138func (m *CoreInstance) XXX_Size() int {
139 return xxx_messageInfo_CoreInstance.Size(m)
140}
141func (m *CoreInstance) XXX_DiscardUnknown() {
142 xxx_messageInfo_CoreInstance.DiscardUnknown(m)
143}
144
145var xxx_messageInfo_CoreInstance proto.InternalMessageInfo
146
147func (m *CoreInstance) GetInstanceId() string {
148 if m != nil {
149 return m.InstanceId
150 }
151 return ""
152}
153
khenaidoo4c6543e2021-10-19 17:25:58 -0400154func (m *CoreInstance) GetHealth() *health.HealthStatus {
William Kurkian1b363f42019-03-12 15:28:12 -0400155 if m != nil {
156 return m.Health
157 }
158 return nil
159}
160
161type CoreInstances struct {
162 Items []*CoreInstance `protobuf:"bytes,1,rep,name=items,proto3" json:"items,omitempty"`
163 XXX_NoUnkeyedLiteral struct{} `json:"-"`
164 XXX_unrecognized []byte `json:"-"`
165 XXX_sizecache int32 `json:"-"`
166}
167
168func (m *CoreInstances) Reset() { *m = CoreInstances{} }
169func (m *CoreInstances) String() string { return proto.CompactTextString(m) }
170func (*CoreInstances) ProtoMessage() {}
171func (*CoreInstances) Descriptor() ([]byte, []int) {
khenaidoo4c6543e2021-10-19 17:25:58 -0400172 return fileDescriptor_e084f1a60ce7016c, []int{1}
William Kurkian1b363f42019-03-12 15:28:12 -0400173}
William Kurkianad745652019-03-20 08:45:51 -0400174
William Kurkian1b363f42019-03-12 15:28:12 -0400175func (m *CoreInstances) XXX_Unmarshal(b []byte) error {
176 return xxx_messageInfo_CoreInstances.Unmarshal(m, b)
177}
178func (m *CoreInstances) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
179 return xxx_messageInfo_CoreInstances.Marshal(b, m, deterministic)
180}
William Kurkianad745652019-03-20 08:45:51 -0400181func (m *CoreInstances) XXX_Merge(src proto.Message) {
182 xxx_messageInfo_CoreInstances.Merge(m, src)
William Kurkian1b363f42019-03-12 15:28:12 -0400183}
184func (m *CoreInstances) XXX_Size() int {
185 return xxx_messageInfo_CoreInstances.Size(m)
186}
187func (m *CoreInstances) XXX_DiscardUnknown() {
188 xxx_messageInfo_CoreInstances.DiscardUnknown(m)
189}
190
191var xxx_messageInfo_CoreInstances proto.InternalMessageInfo
192
193func (m *CoreInstances) GetItems() []*CoreInstance {
194 if m != nil {
195 return m.Items
196 }
197 return nil
198}
199
200// Voltha represents the Voltha cluster data. Each Core instance will hold a subset of
201// the entire cluster. However, some items (e.g. adapters) will be held by all cores
202// for better performance
203type Voltha struct {
204 Version string `protobuf:"bytes,1,opt,name=version,proto3" json:"version,omitempty"`
205 Adapters []*Adapter `protobuf:"bytes,2,rep,name=adapters,proto3" json:"adapters,omitempty"`
206 LogicalDevices []*LogicalDevice `protobuf:"bytes,3,rep,name=logical_devices,json=logicalDevices,proto3" json:"logical_devices,omitempty"`
207 Devices []*Device `protobuf:"bytes,4,rep,name=devices,proto3" json:"devices,omitempty"`
208 DeviceTypes []*DeviceType `protobuf:"bytes,5,rep,name=device_types,json=deviceTypes,proto3" json:"device_types,omitempty"`
Devmalya Paul96a2c9e2019-11-06 07:17:44 +0000209 EventFilters []*EventFilter `protobuf:"bytes,7,rep,name=event_filters,json=eventFilters,proto3" json:"event_filters,omitempty"`
William Kurkian1b363f42019-03-12 15:28:12 -0400210 OmciMibDatabase []*omci.MibDeviceData `protobuf:"bytes,28,rep,name=omci_mib_database,json=omciMibDatabase,proto3" json:"omci_mib_database,omitempty"`
211 OmciAlarmDatabase []*omci.AlarmDeviceData `protobuf:"bytes,29,rep,name=omci_alarm_database,json=omciAlarmDatabase,proto3" json:"omci_alarm_database,omitempty"`
212 XXX_NoUnkeyedLiteral struct{} `json:"-"`
213 XXX_unrecognized []byte `json:"-"`
214 XXX_sizecache int32 `json:"-"`
215}
216
217func (m *Voltha) Reset() { *m = Voltha{} }
218func (m *Voltha) String() string { return proto.CompactTextString(m) }
219func (*Voltha) ProtoMessage() {}
220func (*Voltha) Descriptor() ([]byte, []int) {
khenaidoo4c6543e2021-10-19 17:25:58 -0400221 return fileDescriptor_e084f1a60ce7016c, []int{2}
William Kurkian1b363f42019-03-12 15:28:12 -0400222}
William Kurkianad745652019-03-20 08:45:51 -0400223
William Kurkian1b363f42019-03-12 15:28:12 -0400224func (m *Voltha) XXX_Unmarshal(b []byte) error {
225 return xxx_messageInfo_Voltha.Unmarshal(m, b)
226}
227func (m *Voltha) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
228 return xxx_messageInfo_Voltha.Marshal(b, m, deterministic)
229}
William Kurkianad745652019-03-20 08:45:51 -0400230func (m *Voltha) XXX_Merge(src proto.Message) {
231 xxx_messageInfo_Voltha.Merge(m, src)
William Kurkian1b363f42019-03-12 15:28:12 -0400232}
233func (m *Voltha) XXX_Size() int {
234 return xxx_messageInfo_Voltha.Size(m)
235}
236func (m *Voltha) XXX_DiscardUnknown() {
237 xxx_messageInfo_Voltha.DiscardUnknown(m)
238}
239
240var xxx_messageInfo_Voltha proto.InternalMessageInfo
241
242func (m *Voltha) GetVersion() string {
243 if m != nil {
244 return m.Version
245 }
246 return ""
247}
248
249func (m *Voltha) GetAdapters() []*Adapter {
250 if m != nil {
251 return m.Adapters
252 }
253 return nil
254}
255
256func (m *Voltha) GetLogicalDevices() []*LogicalDevice {
257 if m != nil {
258 return m.LogicalDevices
259 }
260 return nil
261}
262
263func (m *Voltha) GetDevices() []*Device {
264 if m != nil {
265 return m.Devices
266 }
267 return nil
268}
269
270func (m *Voltha) GetDeviceTypes() []*DeviceType {
271 if m != nil {
272 return m.DeviceTypes
273 }
274 return nil
275}
276
Devmalya Paul96a2c9e2019-11-06 07:17:44 +0000277func (m *Voltha) GetEventFilters() []*EventFilter {
William Kurkian1b363f42019-03-12 15:28:12 -0400278 if m != nil {
Devmalya Paul96a2c9e2019-11-06 07:17:44 +0000279 return m.EventFilters
William Kurkian1b363f42019-03-12 15:28:12 -0400280 }
281 return nil
282}
283
284func (m *Voltha) GetOmciMibDatabase() []*omci.MibDeviceData {
285 if m != nil {
286 return m.OmciMibDatabase
287 }
288 return nil
289}
290
291func (m *Voltha) GetOmciAlarmDatabase() []*omci.AlarmDeviceData {
292 if m != nil {
293 return m.OmciAlarmDatabase
294 }
295 return nil
296}
297
William Kurkian1b363f42019-03-12 15:28:12 -0400298func init() {
William Kurkian1b363f42019-03-12 15:28:12 -0400299 proto.RegisterType((*CoreInstance)(nil), "voltha.CoreInstance")
300 proto.RegisterType((*CoreInstances)(nil), "voltha.CoreInstances")
301 proto.RegisterType((*Voltha)(nil), "voltha.Voltha")
William Kurkianad745652019-03-20 08:45:51 -0400302}
303
304func init() { proto.RegisterFile("voltha_protos/voltha.proto", fileDescriptor_e084f1a60ce7016c) }
305
306var fileDescriptor_e084f1a60ce7016c = []byte{
khenaidoo4c6543e2021-10-19 17:25:58 -0400307 // 2130 bytes of a gzipped FileDescriptorProto
308 0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0xc4, 0x59, 0xeb, 0x6e, 0x1b, 0xb9,
309 0x15, 0xde, 0x71, 0x76, 0x73, 0xa1, 0x25, 0xdb, 0xa2, 0x7c, 0x91, 0x25, 0xf9, 0xc6, 0x64, 0xb3,
310 0x5e, 0x25, 0x91, 0x92, 0x38, 0xd9, 0xb6, 0xd9, 0x2e, 0x0a, 0xaf, 0x6f, 0xf5, 0x36, 0x81, 0x0d,
311 0x29, 0x71, 0xda, 0x62, 0xb3, 0xc2, 0x48, 0x43, 0xcb, 0x83, 0x8e, 0x66, 0xd4, 0x21, 0x65, 0x27,
312 0x30, 0xf6, 0x4f, 0x2f, 0x40, 0x8a, 0xa2, 0xe8, 0x8f, 0x7d, 0x8b, 0x3e, 0x45, 0xff, 0xf5, 0x01,
313 0xfa, 0x0a, 0x7d, 0x90, 0x82, 0x87, 0xa4, 0x3c, 0xd4, 0xcc, 0xc8, 0x56, 0xba, 0x40, 0xff, 0x58,
314 0x26, 0x0f, 0xf9, 0x7d, 0x1f, 0xcf, 0x39, 0xbc, 0x0e, 0x2a, 0x9e, 0x06, 0x1e, 0x3f, 0xb1, 0x9b,
315 0xbd, 0x30, 0xe0, 0x01, 0xab, 0xc9, 0x52, 0x15, 0x4a, 0xf8, 0xba, 0x2c, 0x15, 0xcb, 0x9d, 0x20,
316 0xe8, 0x78, 0xb4, 0x66, 0xf7, 0xdc, 0x9a, 0xed, 0xfb, 0x01, 0xb7, 0xb9, 0x1b, 0xf8, 0x4c, 0xb6,
317 0x2a, 0x96, 0x94, 0x15, 0x4a, 0xad, 0xfe, 0x71, 0x8d, 0x76, 0x7b, 0xfc, 0x9d, 0x32, 0x0e, 0xc1,
318 0xb7, 0x83, 0x6e, 0x37, 0xf0, 0x93, 0x6d, 0x27, 0xd4, 0xf6, 0xf8, 0x89, 0xb2, 0x11, 0xd3, 0xe6,
319 0x05, 0x1d, 0xb7, 0x6d, 0x7b, 0x4d, 0x87, 0x9e, 0xba, 0x6d, 0x9a, 0xdc, 0xdf, 0xb0, 0x95, 0x4c,
320 0x9b, 0xed, 0xd8, 0x3d, 0x4e, 0x43, 0x65, 0x5c, 0x31, 0x8d, 0x41, 0x8f, 0xfa, 0xc7, 0x5e, 0x70,
321 0xd6, 0x7c, 0xb4, 0x91, 0x8c, 0x4c, 0x4f, 0xa9, 0xcf, 0xf5, 0x70, 0x97, 0x87, 0x6c, 0x6f, 0x39,
322 0xf5, 0x59, 0xc4, 0x1d, 0xc3, 0xe0, 0xdd, 0xb6, 0xdb, 0xec, 0xba, 0xad, 0xa6, 0xd3, 0x52, 0x0d,
323 0xd6, 0x12, 0x1a, 0xd8, 0x9e, 0x1d, 0x76, 0x2f, 0x9a, 0x2c, 0x25, 0x34, 0xe1, 0x94, 0x71, 0x69,
324 0x26, 0x6f, 0x50, 0x66, 0x2b, 0x08, 0xe9, 0xbe, 0xcf, 0xb8, 0xed, 0xb7, 0x29, 0x5e, 0x41, 0x93,
325 0xae, 0xfa, 0xbf, 0xe9, 0x3a, 0x05, 0x6b, 0xd5, 0x5a, 0xbf, 0x55, 0x47, 0xba, 0x6a, 0xdf, 0xc1,
326 0xf7, 0xd1, 0x75, 0xe9, 0xdd, 0xc2, 0xc4, 0xaa, 0xb5, 0x3e, 0xf9, 0x78, 0xb6, 0xaa, 0x9c, 0xfd,
327 0x4b, 0xf8, 0x69, 0x70, 0x9b, 0xf7, 0x59, 0x5d, 0xb5, 0x21, 0x5f, 0xa2, 0x6c, 0x14, 0x9e, 0xe1,
328 0x0a, 0xfa, 0xc4, 0xe5, 0xb4, 0xcb, 0x0a, 0xd6, 0xea, 0x35, 0xe8, 0xad, 0xb2, 0x24, 0xda, 0xaa,
329 0x2e, 0x9b, 0x90, 0x7f, 0x5e, 0x43, 0xd7, 0x8f, 0xc0, 0x8c, 0x0b, 0xe8, 0xc6, 0x29, 0x0d, 0x85,
330 0x6f, 0x94, 0x24, 0x5d, 0xc4, 0xf7, 0xd1, 0x4d, 0x15, 0x11, 0x56, 0x98, 0x00, 0xcc, 0x99, 0xaa,
331 0x0e, 0xd1, 0xa6, 0xfc, 0xad, 0x0f, 0x5a, 0xe0, 0x5d, 0x34, 0x6d, 0xc6, 0x9f, 0x15, 0xae, 0x41,
332 0xa7, 0xa5, 0xea, 0x50, 0x5e, 0x3c, 0x97, 0xc5, 0x6d, 0x28, 0xd5, 0xa7, 0xbc, 0x68, 0x91, 0xe1,
333 0x75, 0x74, 0x43, 0xf7, 0xff, 0x18, 0xfa, 0x4f, 0x55, 0x55, 0x3f, 0xd5, 0x41, 0x9b, 0xf1, 0x53,
334 0x94, 0x91, 0xff, 0x36, 0xf9, 0xbb, 0x1e, 0x65, 0x85, 0x4f, 0xa0, 0x39, 0x36, 0x9b, 0xbf, 0x7c,
335 0xd7, 0xa3, 0xf5, 0x49, 0x67, 0xf0, 0x3f, 0xc3, 0x3f, 0x41, 0x59, 0x48, 0x95, 0xe6, 0xb1, 0xeb,
336 0xc1, 0xd8, 0x6e, 0xa8, 0x7e, 0x50, 0x5b, 0xdd, 0x11, 0x7f, 0x77, 0xc1, 0x54, 0xcf, 0xd0, 0x8b,
337 0x02, 0xc3, 0xbf, 0x40, 0xb9, 0x8b, 0x3c, 0xb1, 0xb9, 0xdd, 0xb2, 0x19, 0x2d, 0x94, 0xa1, 0x73,
338 0xbe, 0x2a, 0x2c, 0xd5, 0x17, 0x6e, 0x4b, 0xb2, 0x6e, 0xdb, 0xdc, 0xae, 0x4f, 0x8b, 0x3a, 0x51,
339 0xa5, 0xda, 0xe2, 0x1d, 0x94, 0x8f, 0xe6, 0x91, 0x86, 0x58, 0x02, 0x88, 0x39, 0x09, 0xb1, 0x29,
340 0x6c, 0x11, 0x10, 0xa0, 0x94, 0x95, 0xaa, 0xfd, 0x37, 0x1f, 0xdf, 0xbc, 0x3e, 0x73, 0xe3, 0xf1,
341 0xbf, 0x36, 0x50, 0x56, 0x86, 0xb0, 0x41, 0x43, 0xd1, 0x1c, 0x6f, 0xa3, 0x5b, 0x7b, 0x94, 0xab,
342 0xb0, 0xce, 0x57, 0xe5, 0x84, 0xaf, 0xea, 0x09, 0x5f, 0xdd, 0x11, 0x13, 0xbe, 0x38, 0xa5, 0xd3,
343 0x42, 0xb6, 0x23, 0xd3, 0x7f, 0xf8, 0xf7, 0x7f, 0x7e, 0x98, 0xb8, 0x85, 0x6f, 0xc0, 0xba, 0x71,
344 0xfa, 0x08, 0xbf, 0x41, 0xb9, 0xe7, 0x2e, 0xe3, 0x66, 0x6e, 0xa5, 0xa1, 0xcd, 0x25, 0x25, 0x19,
345 0x23, 0x8b, 0x00, 0x9a, 0xc7, 0x39, 0x05, 0x5a, 0x73, 0x07, 0x48, 0x0d, 0x34, 0xbd, 0x47, 0x0d,
346 0x74, 0x8c, 0xaa, 0x6a, 0xc1, 0xd9, 0xdf, 0x2e, 0x26, 0x66, 0x2d, 0x59, 0x06, 0xbc, 0x02, 0x9e,
347 0x8f, 0xe1, 0xd5, 0xce, 0x5d, 0xe7, 0x7b, 0xdc, 0x40, 0x19, 0xa1, 0x79, 0x53, 0xe7, 0x62, 0x9a,
348 0xdc, 0xdc, 0x70, 0xfe, 0x32, 0x52, 0x00, 0x68, 0x8c, 0x67, 0x34, 0xf4, 0x20, 0xa1, 0xbb, 0x08,
349 0x0b, 0xd0, 0xe7, 0x66, 0x7a, 0xa6, 0x41, 0x2f, 0x8f, 0xcc, 0x72, 0x46, 0x56, 0x80, 0x67, 0x11,
350 0x2f, 0x68, 0x9e, 0xa1, 0xc9, 0x82, 0xdb, 0x68, 0x66, 0x8f, 0x9a, 0x6c, 0x86, 0x67, 0x46, 0x4f,
351 0x23, 0x72, 0x07, 0xf0, 0x97, 0x71, 0x39, 0x05, 0x5f, 0x3a, 0xca, 0x47, 0xf3, 0xb1, 0x31, 0x1d,
352 0x06, 0x21, 0x67, 0x06, 0x55, 0x39, 0x85, 0x0a, 0x5a, 0x92, 0x0a, 0x30, 0xdd, 0xc1, 0x64, 0x14,
353 0x53, 0xad, 0x07, 0xa8, 0xef, 0x2d, 0x34, 0x3b, 0x3c, 0x2a, 0x81, 0x82, 0x97, 0x46, 0x50, 0xec,
354 0x3b, 0xc5, 0xd2, 0x08, 0x33, 0x79, 0x02, 0x02, 0xaa, 0xf8, 0xfe, 0xe5, 0x02, 0x6a, 0xe7, 0xe2,
355 0xa7, 0x29, 0x86, 0xfe, 0x37, 0x0b, 0x2d, 0xec, 0xf8, 0x76, 0xcb, 0xa3, 0x63, 0xab, 0x49, 0x89,
356 0x39, 0xf9, 0x12, 0x84, 0x3c, 0x25, 0x1b, 0xe3, 0x08, 0xa9, 0x51, 0x10, 0x81, 0xff, 0x6e, 0xa1,
357 0xc2, 0xb6, 0xcb, 0x7e, 0x54, 0x41, 0x3f, 0x07, 0x41, 0x5f, 0x90, 0x27, 0x63, 0x09, 0x72, 0xa4,
358 0x0a, 0xec, 0x24, 0x24, 0xc7, 0xae, 0x17, 0x9c, 0x99, 0xc9, 0x81, 0xab, 0xd1, 0x9d, 0x18, 0xec,
359 0x57, 0x4c, 0x89, 0x63, 0xc0, 0xfa, 0xa3, 0x85, 0xca, 0xaf, 0x7a, 0x8e, 0xcd, 0x69, 0x8c, 0xe8,
360 0x25, 0xc8, 0x28, 0xc7, 0x08, 0xa0, 0x5e, 0xf6, 0x49, 0x1d, 0xfa, 0x03, 0x90, 0xf0, 0x19, 0xb9,
361 0x82, 0x84, 0x67, 0x56, 0x05, 0xff, 0xc9, 0x42, 0x4b, 0x09, 0x2a, 0x5e, 0x50, 0x4e, 0x43, 0x29,
362 0xa3, 0x64, 0xc8, 0x00, 0xc3, 0x8b, 0xc0, 0xb9, 0x44, 0x45, 0x15, 0x54, 0xac, 0x93, 0xdb, 0x23,
363 0x55, 0x74, 0x05, 0x18, 0xc8, 0xe8, 0xa0, 0x85, 0x98, 0xcb, 0x81, 0xca, 0xf4, 0x79, 0x3e, 0xae,
364 0x85, 0x91, 0x7b, 0xc0, 0xf5, 0x29, 0xbe, 0x0a, 0x17, 0xe6, 0xa8, 0x94, 0x18, 0xdb, 0xbd, 0x30,
365 0xe8, 0xf7, 0x4c, 0xb2, 0x85, 0x98, 0xff, 0x65, 0x23, 0xf2, 0x10, 0x08, 0x2b, 0x78, 0xfd, 0x52,
366 0x17, 0x37, 0x3b, 0x12, 0xf6, 0x07, 0x0b, 0xad, 0xa5, 0xc4, 0x1a, 0x30, 0xa5, 0xa7, 0xd7, 0x92,
367 0x09, 0xaf, 0x12, 0xf5, 0x0d, 0x90, 0xf4, 0x80, 0x5c, 0x59, 0x92, 0x70, 0xfa, 0x01, 0x9a, 0x14,
368 0xbe, 0xb8, 0x6c, 0x45, 0x9f, 0x36, 0x0f, 0x12, 0x8c, 0x2c, 0x00, 0x59, 0x0e, 0x4f, 0x6b, 0x32,
369 0xbd, 0x74, 0x1f, 0xa0, 0xec, 0x05, 0xe0, 0xbe, 0x93, 0x0e, 0x39, 0x79, 0xe1, 0xe6, 0x84, 0x4d,
370 0x52, 0xc2, 0xb9, 0x0e, 0xc3, 0xaf, 0xd0, 0x4c, 0x9d, 0xb6, 0x03, 0xbf, 0xed, 0x7a, 0x54, 0xcb,
371 0x8c, 0xf6, 0x4d, 0xf5, 0x47, 0x19, 0x30, 0xe7, 0x49, 0x1c, 0x53, 0x0c, 0x7c, 0x07, 0x0e, 0x08,
372 0x09, 0x7b, 0xcb, 0xd0, 0x11, 0x4b, 0xc3, 0xe0, 0xd9, 0xa1, 0x91, 0xca, 0x4d, 0xe4, 0x1b, 0x94,
373 0xd9, 0x0a, 0xa9, 0xcd, 0x95, 0x34, 0x3c, 0xd4, 0x3b, 0x86, 0x56, 0x04, 0xb4, 0x59, 0x32, 0xec,
374 0x37, 0x21, 0xe9, 0x35, 0xca, 0xc8, 0x45, 0x39, 0x41, 0x55, 0xda, 0x20, 0x6f, 0x03, 0xde, 0x12,
375 0x29, 0x25, 0xa9, 0xd3, 0xcb, 0xeb, 0x6f, 0x50, 0x56, 0xad, 0xae, 0x63, 0x20, 0xab, 0x4d, 0x94,
376 0x94, 0x13, 0x91, 0xf5, 0x3a, 0xf9, 0x1a, 0x65, 0xea, 0xb4, 0x15, 0x04, 0xfc, 0x47, 0xd3, 0x1c,
377 0x02, 0x9c, 0x00, 0xde, 0xa6, 0x1e, 0xe5, 0x1f, 0xe0, 0x8c, 0x4a, 0x32, 0xb0, 0x03, 0x70, 0xb8,
378 0x85, 0x72, 0xbb, 0x41, 0xd8, 0xa6, 0x63, 0xa3, 0x7f, 0x0e, 0xe8, 0xb7, 0x2b, 0x6b, 0x89, 0xe8,
379 0xc7, 0x02, 0xb3, 0xa9, 0x38, 0xde, 0xa2, 0xec, 0x76, 0x70, 0xe6, 0x7b, 0x81, 0xed, 0xec, 0x77,
380 0xed, 0x0e, 0xc5, 0x73, 0x3a, 0x0d, 0xa0, 0xa8, 0x6d, 0xc5, 0x39, 0x4d, 0x7b, 0xd0, 0xa3, 0x21,
381 0x5c, 0x51, 0xeb, 0x94, 0xf5, 0xc8, 0xcf, 0x80, 0xe9, 0x21, 0xb9, 0x97, 0xc8, 0xe4, 0x0a, 0x88,
382 0xa6, 0xa3, 0x30, 0x58, 0xed, 0xdc, 0xb7, 0xbb, 0xf4, 0xfb, 0x67, 0x56, 0xe5, 0xfd, 0x84, 0x85,
383 0xff, 0x6c, 0xa1, 0xf9, 0x3d, 0xca, 0x0d, 0x1a, 0x79, 0x59, 0x4a, 0xd7, 0x90, 0x54, 0x4d, 0xbe,
384 0x02, 0x0d, 0x4f, 0xf0, 0xe3, 0x31, 0x34, 0xd4, 0x18, 0x30, 0x09, 0x1d, 0x6f, 0xe1, 0x04, 0x67,
385 0x40, 0x8e, 0x29, 0xe0, 0x0b, 0xb9, 0x9c, 0xe1, 0x71, 0x9c, 0x20, 0x98, 0x5d, 0x79, 0x54, 0x35,
386 0xc0, 0xd8, 0x50, 0x80, 0x93, 0x08, 0x19, 0xa9, 0x01, 0xe3, 0x5d, 0x7c, 0xe7, 0x2a, 0x8c, 0x82,
387 0xea, 0x1c, 0xe5, 0xb7, 0xc4, 0xc9, 0xdb, 0xbb, 0xe2, 0x38, 0x13, 0x83, 0xad, 0xc6, 0x59, 0x19,
388 0x77, 0x9c, 0x7f, 0xb5, 0x50, 0x7e, 0xb3, 0xcd, 0xdd, 0x53, 0x9b, 0x53, 0x20, 0x92, 0xdb, 0xc3,
389 0x98, 0xec, 0xbb, 0xc0, 0xfe, 0x15, 0xf9, 0xe9, 0x38, 0x61, 0x96, 0xd5, 0x7d, 0xe0, 0x53, 0x79,
390 0xf7, 0x17, 0x0b, 0xe5, 0xea, 0xf4, 0x94, 0x86, 0xfc, 0xff, 0xa2, 0x25, 0x04, 0x6a, 0xa5, 0xe5,
391 0xbd, 0x85, 0xe6, 0x8c, 0xe9, 0xf7, 0x32, 0x50, 0xd3, 0x9c, 0x98, 0xab, 0xb1, 0xa1, 0xaa, 0x4e,
392 0x7f, 0xdf, 0xa7, 0x8c, 0x17, 0x4b, 0x09, 0x6d, 0x84, 0xbc, 0xc0, 0x67, 0x54, 0x9f, 0x69, 0xf0,
393 0xdd, 0x61, 0x89, 0x20, 0x83, 0xd5, 0xb4, 0xbc, 0xa6, 0x2c, 0xe3, 0x33, 0x34, 0xa5, 0xa7, 0x81,
394 0x9a, 0x85, 0xc5, 0x44, 0xf8, 0x2b, 0x50, 0xdf, 0x4f, 0xcb, 0x4e, 0x45, 0x2d, 0x7f, 0x9a, 0x72,
395 0x0a, 0x8a, 0x78, 0x2c, 0x6e, 0xb6, 0x82, 0x41, 0x38, 0x3a, 0xa1, 0xed, 0x5c, 0xf8, 0xe1, 0x83,
396 0x45, 0x6c, 0xa4, 0x4d, 0x4a, 0x25, 0xc2, 0x16, 0x94, 0xcd, 0xbe, 0xa4, 0xd3, 0x4e, 0x38, 0x42,
397 0x99, 0x3d, 0xca, 0x0f, 0xfc, 0xfe, 0xbe, 0x2c, 0x47, 0xe7, 0x62, 0x4e, 0xb3, 0x0d, 0xcc, 0xe4,
398 0x33, 0xe0, 0x58, 0xc3, 0x2b, 0x89, 0x69, 0x10, 0xf8, 0x7d, 0x8d, 0x7b, 0x8e, 0xb2, 0xc6, 0x04,
399 0xf8, 0xf0, 0x61, 0x3d, 0x02, 0xca, 0x7b, 0x24, 0x2d, 0xac, 0xb6, 0xa2, 0x51, 0xcc, 0x62, 0xb3,
400 0x3e, 0x43, 0x93, 0x5b, 0x41, 0xb7, 0xeb, 0xf2, 0xff, 0x91, 0x5a, 0x2e, 0x3a, 0x9f, 0x93, 0xb4,
401 0xb0, 0xb6, 0x81, 0x24, 0x42, 0x7c, 0x88, 0xa6, 0x2f, 0x0e, 0x58, 0xf1, 0xfb, 0x6a, 0x56, 0x93,
402 0xc9, 0x0b, 0x2a, 0x01, 0xf8, 0x32, 0x2e, 0x26, 0x3a, 0x53, 0x5e, 0x4c, 0xdf, 0xa0, 0x7c, 0x04,
403 0xb1, 0xbb, 0x15, 0xf8, 0xc7, 0x6e, 0x27, 0x25, 0x4c, 0x03, 0xf3, 0x25, 0x61, 0xea, 0x75, 0x9b,
404 0x6d, 0x85, 0xe3, 0xa3, 0x39, 0xb9, 0x1c, 0x0c, 0x13, 0xc4, 0x41, 0x53, 0xf7, 0x5e, 0x75, 0xa9,
405 0x22, 0x97, 0x91, 0x09, 0x07, 0xbd, 0x8a, 0x3a, 0xe8, 0x6a, 0x77, 0xb6, 0xd1, 0x5e, 0x92, 0x77,
406 0x35, 0x8a, 0x66, 0x4d, 0xd8, 0x71, 0xae, 0x0b, 0xeb, 0x40, 0x40, 0xf0, 0x6a, 0x2a, 0x81, 0xbe,
407 0x26, 0x7c, 0x1b, 0x55, 0x2f, 0x1f, 0xe9, 0xd2, 0x4e, 0xd0, 0xf9, 0xf8, 0xeb, 0x1e, 0x4b, 0x3b,
408 0xae, 0xca, 0x67, 0x41, 0x5c, 0x47, 0xd9, 0xc1, 0xa9, 0x57, 0xb4, 0x1f, 0xf2, 0x4c, 0x0c, 0x8f,
409 0xac, 0x01, 0x5c, 0x09, 0x2f, 0x26, 0xc1, 0xc9, 0x23, 0xf0, 0x2e, 0x9a, 0x69, 0xf0, 0x90, 0xda,
410 0xdd, 0x43, 0xbb, 0xfd, 0x3b, 0xca, 0xd9, 0x41, 0x9f, 0xe3, 0x79, 0xc3, 0x11, 0xd2, 0x70, 0xd0,
411 0xe7, 0xa9, 0xf1, 0xfd, 0x68, 0xdd, 0xc2, 0x3b, 0x70, 0xd0, 0xa7, 0xee, 0x29, 0x55, 0x40, 0xfb,
412 0xfe, 0x88, 0xb7, 0xb6, 0x38, 0xfe, 0xbe, 0x4f, 0x3e, 0x7a, 0x68, 0xe1, 0x5f, 0xa1, 0xbc, 0x82,
413 0xd9, 0x3a, 0xb1, 0xfd, 0x0e, 0x85, 0x37, 0xcc, 0x74, 0x27, 0x16, 0x0c, 0xa4, 0x48, 0x17, 0x00,
414 0x7b, 0x83, 0x72, 0xf2, 0x78, 0x1f, 0x79, 0x09, 0xc5, 0x09, 0xaf, 0xa3, 0xc5, 0x84, 0x3a, 0xb2,
415 0x0a, 0xbe, 0x2b, 0x92, 0x39, 0xed, 0x3b, 0xe3, 0xa9, 0x55, 0xa6, 0xaa, 0xd8, 0x1e, 0xa2, 0xd8,
416 0xe6, 0x4d, 0x37, 0x86, 0x99, 0x90, 0xaa, 0x06, 0xa8, 0x8c, 0x48, 0x0b, 0xe5, 0xe4, 0x8c, 0xfb,
417 0x10, 0xd5, 0x9f, 0x02, 0xc1, 0x4a, 0x71, 0x04, 0x81, 0x90, 0xde, 0x46, 0x39, 0x79, 0x82, 0xbe,
418 0x8c, 0x23, 0x2d, 0xe4, 0x6a, 0x20, 0x95, 0x51, 0x03, 0xf9, 0x0e, 0xcd, 0x88, 0xc9, 0x10, 0x75,
419 0xc0, 0x88, 0xd9, 0x90, 0xe0, 0xad, 0x25, 0x20, 0x59, 0xc0, 0xc9, 0x21, 0xc0, 0xcf, 0xe1, 0x12,
420 0x98, 0xb0, 0x2d, 0x4d, 0x19, 0x07, 0x17, 0xa6, 0x6f, 0x16, 0xb8, 0x94, 0x7e, 0x34, 0x61, 0xf8,
421 0xd7, 0xe8, 0x66, 0x83, 0x7a, 0xc7, 0x2f, 0x29, 0xe3, 0x06, 0x58, 0x41, 0x83, 0x69, 0xeb, 0x60,
422 0xf1, 0xbf, 0x0b, 0xb0, 0xab, 0x64, 0x39, 0x11, 0x96, 0x51, 0xef, 0x18, 0x3e, 0xa2, 0xe0, 0x23,
423 0x38, 0x4d, 0x1b, 0x2f, 0xea, 0xc3, 0x6f, 0x22, 0xb1, 0x27, 0xf7, 0xf8, 0xd4, 0x15, 0x89, 0x2e,
424 0xda, 0xa9, 0xc7, 0x10, 0xb7, 0x85, 0xbf, 0x45, 0x78, 0x8f, 0xf2, 0xa1, 0x67, 0x76, 0x03, 0x39,
425 0xf9, 0x25, 0x3e, 0xee, 0x0f, 0x13, 0x1b, 0x1e, 0xf5, 0x31, 0x43, 0xd9, 0x86, 0xdb, 0xed, 0x7b,
426 0x36, 0xa7, 0xd0, 0x1f, 0x97, 0x07, 0x8e, 0x88, 0x56, 0xeb, 0x6d, 0x32, 0xe5, 0x54, 0x18, 0x7b,
427 0xcc, 0x32, 0x7d, 0xa4, 0x90, 0x9a, 0x02, 0x49, 0xe4, 0xe5, 0x0b, 0x84, 0xe4, 0x25, 0x1a, 0xde,
428 0x0e, 0x33, 0xd1, 0xdd, 0x30, 0x35, 0x15, 0xd5, 0xeb, 0x03, 0x99, 0x12, 0xf0, 0x17, 0xbd, 0xd5,
429 0xfb, 0x88, 0xba, 0x3a, 0x8f, 0x81, 0x77, 0x71, 0xc9, 0x3f, 0x7d, 0x54, 0x8b, 0x74, 0x17, 0x80,
430 0xdf, 0xa1, 0x49, 0x31, 0xe5, 0xdf, 0xf2, 0x23, 0xdb, 0xeb, 0x53, 0xbc, 0x58, 0x1d, 0x7c, 0x8e,
431 0xab, 0x42, 0x4d, 0xa3, 0x47, 0xdb, 0xee, 0xb1, 0x4b, 0xc3, 0xe2, 0x42, 0xc4, 0x54, 0xa7, 0xbc,
432 0x1f, 0xfa, 0xd0, 0x80, 0x91, 0x12, 0xc0, 0xcf, 0xe1, 0xbc, 0xf6, 0x48, 0x14, 0xf0, 0x35, 0x9a,
433 0x6c, 0x44, 0x8a, 0xf9, 0x18, 0x3e, 0x4d, 0xd7, 0x1d, 0x03, 0x8e, 0x22, 0x39, 0x28, 0xdf, 0xe0,
434 0x76, 0xc8, 0x0f, 0xba, 0x6d, 0x57, 0x24, 0xb1, 0x38, 0x7a, 0x05, 0x3e, 0x56, 0x09, 0xa2, 0x6b,
435 0x75, 0x30, 0xb1, 0xac, 0x36, 0xb2, 0x5d, 0xcd, 0x78, 0x32, 0x78, 0xf6, 0x67, 0x02, 0xaf, 0x39,
436 0xf8, 0x56, 0xf8, 0xcc, 0xaa, 0x7c, 0xed, 0xa1, 0x7c, 0x10, 0x76, 0x60, 0x4d, 0x6e, 0x07, 0xa1,
437 0xa3, 0xbe, 0x80, 0x7c, 0x9d, 0x91, 0x5f, 0x68, 0x0e, 0xe1, 0xeb, 0xe2, 0x6f, 0xab, 0x1d, 0x97,
438 0x9f, 0xf4, 0x5b, 0x22, 0x5f, 0x6a, 0xba, 0xa5, 0xfa, 0x0e, 0xfc, 0x40, 0x7f, 0x15, 0x7e, 0x5a,
439 0xeb, 0x04, 0xaa, 0xee, 0x1f, 0x13, 0xf3, 0x07, 0x1a, 0xef, 0x28, 0xfa, 0xc1, 0xe7, 0x70, 0xa2,
440 0x75, 0x1d, 0xda, 0x6f, 0xfc, 0x37, 0x00, 0x00, 0xff, 0xff, 0x37, 0x95, 0xcc, 0x79, 0x55, 0x1e,
441 0x00, 0x00,
William Kurkian1b363f42019-03-12 15:28:12 -0400442}
443
444// Reference imports to suppress errors if they are not otherwise used.
445var _ context.Context
446var _ grpc.ClientConn
447
448// This is a compile-time assertion to ensure that this generated file
449// is compatible with the grpc package it is being compiled against.
450const _ = grpc.SupportPackageIsVersion4
451
452// VolthaServiceClient is the client API for VolthaService service.
453//
454// For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
455type VolthaServiceClient interface {
William Kurkian1b363f42019-03-12 15:28:12 -0400456 // Get high level information on the Voltha cluster
457 GetVoltha(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*Voltha, error)
458 // List all Voltha cluster core instances
459 ListCoreInstances(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*CoreInstances, error)
460 // Get details on a Voltha cluster instance
461 GetCoreInstance(ctx context.Context, in *common.ID, opts ...grpc.CallOption) (*CoreInstance, error)
462 // List all active adapters (plugins) in the Voltha cluster
463 ListAdapters(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*Adapters, error)
464 // List all logical devices managed by the Voltha cluster
465 ListLogicalDevices(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*LogicalDevices, error)
466 // Get additional information on a given logical device
467 GetLogicalDevice(ctx context.Context, in *common.ID, opts ...grpc.CallOption) (*LogicalDevice, error)
468 // List ports of a logical device
469 ListLogicalDevicePorts(ctx context.Context, in *common.ID, opts ...grpc.CallOption) (*LogicalPorts, error)
470 // Gets a logical device port
471 GetLogicalDevicePort(ctx context.Context, in *LogicalPortId, opts ...grpc.CallOption) (*LogicalPort, error)
472 // Enables a logical device port
473 EnableLogicalDevicePort(ctx context.Context, in *LogicalPortId, opts ...grpc.CallOption) (*empty.Empty, error)
474 // Disables a logical device port
475 DisableLogicalDevicePort(ctx context.Context, in *LogicalPortId, opts ...grpc.CallOption) (*empty.Empty, error)
476 // List all flows of a logical device
477 ListLogicalDeviceFlows(ctx context.Context, in *common.ID, opts ...grpc.CallOption) (*openflow_13.Flows, error)
478 // Update flow table for logical device
479 UpdateLogicalDeviceFlowTable(ctx context.Context, in *openflow_13.FlowTableUpdate, opts ...grpc.CallOption) (*empty.Empty, error)
480 // Update meter table for logical device
481 UpdateLogicalDeviceMeterTable(ctx context.Context, in *openflow_13.MeterModUpdate, opts ...grpc.CallOption) (*empty.Empty, error)
Abhilash Laxmeshwardfbb74d2019-07-23 08:03:08 -0400482 // List all meters of a logical device
483 ListLogicalDeviceMeters(ctx context.Context, in *common.ID, opts ...grpc.CallOption) (*openflow_13.Meters, error)
William Kurkian1b363f42019-03-12 15:28:12 -0400484 // List all flow groups of a logical device
485 ListLogicalDeviceFlowGroups(ctx context.Context, in *common.ID, opts ...grpc.CallOption) (*openflow_13.FlowGroups, error)
486 // Update group table for device
487 UpdateLogicalDeviceFlowGroupTable(ctx context.Context, in *openflow_13.FlowGroupTableUpdate, opts ...grpc.CallOption) (*empty.Empty, error)
488 // List all physical devices controlled by the Voltha cluster
489 ListDevices(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*Devices, error)
490 // List all physical devices IDs controlled by the Voltha cluster
491 ListDeviceIds(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*common.IDs, error)
492 // Request to a voltha Core to reconcile a set of devices based on their IDs
493 ReconcileDevices(ctx context.Context, in *common.IDs, opts ...grpc.CallOption) (*empty.Empty, error)
494 // Get more information on a given physical device
495 GetDevice(ctx context.Context, in *common.ID, opts ...grpc.CallOption) (*Device, error)
496 // Pre-provision a new physical device
497 CreateDevice(ctx context.Context, in *Device, opts ...grpc.CallOption) (*Device, error)
498 // Enable a device. If the device was in pre-provisioned state then it
499 // will transition to ENABLED state. If it was is DISABLED state then it
500 // will transition to ENABLED state as well.
501 EnableDevice(ctx context.Context, in *common.ID, opts ...grpc.CallOption) (*empty.Empty, error)
502 // Disable a device
503 DisableDevice(ctx context.Context, in *common.ID, opts ...grpc.CallOption) (*empty.Empty, error)
504 // Reboot a device
505 RebootDevice(ctx context.Context, in *common.ID, opts ...grpc.CallOption) (*empty.Empty, error)
506 // Delete a device
507 DeleteDevice(ctx context.Context, in *common.ID, opts ...grpc.CallOption) (*empty.Empty, error)
Himani Chawla503b7ce2020-10-07 13:20:03 +0530508 // Forcefully delete a device
509 ForceDeleteDevice(ctx context.Context, in *common.ID, opts ...grpc.CallOption) (*empty.Empty, error)
William Kurkian1b363f42019-03-12 15:28:12 -0400510 // Request an image download to the standby partition
511 // of a device.
512 // Note that the call is expected to be non-blocking.
513 DownloadImage(ctx context.Context, in *ImageDownload, opts ...grpc.CallOption) (*common.OperationResp, error)
514 // Get image download status on a device
515 // The request retrieves progress on device and updates db record
Andrea Campanella9e94e8a2021-01-19 15:21:25 +0100516 // Deprecated in voltha 2.8, will be removed
William Kurkian1b363f42019-03-12 15:28:12 -0400517 GetImageDownloadStatus(ctx context.Context, in *ImageDownload, opts ...grpc.CallOption) (*ImageDownload, error)
518 // Get image download db record
Andrea Campanella9e94e8a2021-01-19 15:21:25 +0100519 // Deprecated in voltha 2.8, will be removed
William Kurkian1b363f42019-03-12 15:28:12 -0400520 GetImageDownload(ctx context.Context, in *ImageDownload, opts ...grpc.CallOption) (*ImageDownload, error)
521 // List image download db records for a given device
Andrea Campanella9e94e8a2021-01-19 15:21:25 +0100522 // Deprecated in voltha 2.8, will be removed
William Kurkian1b363f42019-03-12 15:28:12 -0400523 ListImageDownloads(ctx context.Context, in *common.ID, opts ...grpc.CallOption) (*ImageDownloads, error)
524 // Cancel an existing image download process on a device
Andrea Campanella9e94e8a2021-01-19 15:21:25 +0100525 // Deprecated in voltha 2.8, will be removed
William Kurkian1b363f42019-03-12 15:28:12 -0400526 CancelImageDownload(ctx context.Context, in *ImageDownload, opts ...grpc.CallOption) (*common.OperationResp, error)
527 // Activate the specified image at a standby partition
528 // to active partition.
529 // Depending on the device implementation, this call
530 // may or may not cause device reboot.
531 // If no reboot, then a reboot is required to make the
532 // activated image running on device
533 // Note that the call is expected to be non-blocking.
Andrea Campanella9e94e8a2021-01-19 15:21:25 +0100534 // Deprecated in voltha 2.8, will be removed
William Kurkian1b363f42019-03-12 15:28:12 -0400535 ActivateImageUpdate(ctx context.Context, in *ImageDownload, opts ...grpc.CallOption) (*common.OperationResp, error)
536 // Revert the specified image at standby partition
537 // to active partition, and revert to previous image
538 // Depending on the device implementation, this call
539 // may or may not cause device reboot.
540 // If no reboot, then a reboot is required to make the
541 // previous image running on device
542 // Note that the call is expected to be non-blocking.
Andrea Campanella9e94e8a2021-01-19 15:21:25 +0100543 // Deprecated in voltha 2.8, will be removed
William Kurkian1b363f42019-03-12 15:28:12 -0400544 RevertImageUpdate(ctx context.Context, in *ImageDownload, opts ...grpc.CallOption) (*common.OperationResp, error)
Andrea Campanella9e94e8a2021-01-19 15:21:25 +0100545 // Downloads a certain image to the standby partition of the devices
546 // Note that the call is expected to be non-blocking.
547 DownloadImageToDevice(ctx context.Context, in *DeviceImageDownloadRequest, opts ...grpc.CallOption) (*DeviceImageResponse, error)
548 // Get image status on a number of devices devices
549 // Polled from northbound systems to get state of download/activate/commit
550 GetImageStatus(ctx context.Context, in *DeviceImageRequest, opts ...grpc.CallOption) (*DeviceImageResponse, error)
551 // Aborts the upgrade of an image on a device
552 // To be used carefully, stops any further operations for the Image on the given devices
553 // Might also stop if possible existing work, but no guarantees are given,
554 // depends on implementation and procedure status.
555 AbortImageUpgradeToDevice(ctx context.Context, in *DeviceImageRequest, opts ...grpc.CallOption) (*DeviceImageResponse, error)
556 // Get Both Active and Standby image for a given device
557 GetOnuImages(ctx context.Context, in *common.ID, opts ...grpc.CallOption) (*OnuImages, error)
558 // Activate the specified image from a standby partition
559 // to active partition.
560 // Depending on the device implementation, this call
561 // may or may not cause device reboot.
562 // If no reboot, then a reboot is required to make the
563 // activated image running on device
564 // Note that the call is expected to be non-blocking.
565 ActivateImage(ctx context.Context, in *DeviceImageRequest, opts ...grpc.CallOption) (*DeviceImageResponse, error)
566 // Commit the specified image to be default.
567 // Depending on the device implementation, this call
568 // may or may not cause device reboot.
569 // If no reboot, then a reboot is required to make the
570 // activated image running on device upon next reboot
571 // Note that the call is expected to be non-blocking.
572 CommitImage(ctx context.Context, in *DeviceImageRequest, opts ...grpc.CallOption) (*DeviceImageResponse, error)
William Kurkian1b363f42019-03-12 15:28:12 -0400573 // List ports of a device
574 ListDevicePorts(ctx context.Context, in *common.ID, opts ...grpc.CallOption) (*Ports, error)
575 // List pm config of a device
576 ListDevicePmConfigs(ctx context.Context, in *common.ID, opts ...grpc.CallOption) (*PmConfigs, error)
577 // Update the pm config of a device
578 UpdateDevicePmConfigs(ctx context.Context, in *PmConfigs, opts ...grpc.CallOption) (*empty.Empty, error)
579 // List all flows of a device
580 ListDeviceFlows(ctx context.Context, in *common.ID, opts ...grpc.CallOption) (*openflow_13.Flows, error)
581 // List all flow groups of a device
582 ListDeviceFlowGroups(ctx context.Context, in *common.ID, opts ...grpc.CallOption) (*openflow_13.FlowGroups, error)
583 // List device types known to Voltha
584 ListDeviceTypes(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*DeviceTypes, error)
585 // Get additional information on a device type
586 GetDeviceType(ctx context.Context, in *common.ID, opts ...grpc.CallOption) (*DeviceType, error)
William Kurkian1b363f42019-03-12 15:28:12 -0400587 // Stream control packets to the dataplane
588 StreamPacketsOut(ctx context.Context, opts ...grpc.CallOption) (VolthaService_StreamPacketsOutClient, error)
589 // Receive control packet stream
590 ReceivePacketsIn(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (VolthaService_ReceivePacketsInClient, error)
591 ReceiveChangeEvents(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (VolthaService_ReceiveChangeEventsClient, error)
Devmalya Paul96a2c9e2019-11-06 07:17:44 +0000592 CreateEventFilter(ctx context.Context, in *EventFilter, opts ...grpc.CallOption) (*EventFilter, error)
593 // Get all filters present for a device
594 GetEventFilter(ctx context.Context, in *common.ID, opts ...grpc.CallOption) (*EventFilters, error)
595 UpdateEventFilter(ctx context.Context, in *EventFilter, opts ...grpc.CallOption) (*EventFilter, error)
596 DeleteEventFilter(ctx context.Context, in *EventFilter, opts ...grpc.CallOption) (*empty.Empty, error)
597 // Get all the filters present
598 ListEventFilters(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*EventFilters, error)
William Kurkian1b363f42019-03-12 15:28:12 -0400599 GetImages(ctx context.Context, in *common.ID, opts ...grpc.CallOption) (*Images, error)
600 SelfTest(ctx context.Context, in *common.ID, opts ...grpc.CallOption) (*SelfTestResponse, error)
601 // OpenOMCI MIB information
602 GetMibDeviceData(ctx context.Context, in *common.ID, opts ...grpc.CallOption) (*omci.MibDeviceData, error)
603 // OpenOMCI ALARM information
604 GetAlarmDeviceData(ctx context.Context, in *common.ID, opts ...grpc.CallOption) (*omci.AlarmDeviceData, error)
605 // Simulate an Alarm
606 SimulateAlarm(ctx context.Context, in *SimulateAlarmRequest, opts ...grpc.CallOption) (*common.OperationResp, error)
kesavand4a002b02020-01-23 21:29:47 -0500607 EnablePort(ctx context.Context, in *Port, opts ...grpc.CallOption) (*empty.Empty, error)
608 DisablePort(ctx context.Context, in *Port, opts ...grpc.CallOption) (*empty.Empty, error)
khenaidoo4c6543e2021-10-19 17:25:58 -0400609 GetExtValue(ctx context.Context, in *extension.ValueSpecifier, opts ...grpc.CallOption) (*extension.ReturnValues, error)
610 SetExtValue(ctx context.Context, in *extension.ValueSet, opts ...grpc.CallOption) (*empty.Empty, error)
onkar.kundargi7b85fa12020-02-27 13:19:22 +0530611 // omci start and stop cli implementation
khenaidoo4c6543e2021-10-19 17:25:58 -0400612 StartOmciTestAction(ctx context.Context, in *omci.OmciTestRequest, opts ...grpc.CallOption) (*omci.TestResponse, error)
William Kurkian1b363f42019-03-12 15:28:12 -0400613}
614
615type volthaServiceClient struct {
616 cc *grpc.ClientConn
617}
618
619func NewVolthaServiceClient(cc *grpc.ClientConn) VolthaServiceClient {
620 return &volthaServiceClient{cc}
621}
622
William Kurkian1b363f42019-03-12 15:28:12 -0400623func (c *volthaServiceClient) GetVoltha(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*Voltha, error) {
624 out := new(Voltha)
625 err := c.cc.Invoke(ctx, "/voltha.VolthaService/GetVoltha", in, out, opts...)
626 if err != nil {
627 return nil, err
628 }
629 return out, nil
630}
631
632func (c *volthaServiceClient) ListCoreInstances(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*CoreInstances, error) {
633 out := new(CoreInstances)
634 err := c.cc.Invoke(ctx, "/voltha.VolthaService/ListCoreInstances", in, out, opts...)
635 if err != nil {
636 return nil, err
637 }
638 return out, nil
639}
640
641func (c *volthaServiceClient) GetCoreInstance(ctx context.Context, in *common.ID, opts ...grpc.CallOption) (*CoreInstance, error) {
642 out := new(CoreInstance)
643 err := c.cc.Invoke(ctx, "/voltha.VolthaService/GetCoreInstance", in, out, opts...)
644 if err != nil {
645 return nil, err
646 }
647 return out, nil
648}
649
650func (c *volthaServiceClient) ListAdapters(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*Adapters, error) {
651 out := new(Adapters)
652 err := c.cc.Invoke(ctx, "/voltha.VolthaService/ListAdapters", in, out, opts...)
653 if err != nil {
654 return nil, err
655 }
656 return out, nil
657}
658
659func (c *volthaServiceClient) ListLogicalDevices(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*LogicalDevices, error) {
660 out := new(LogicalDevices)
661 err := c.cc.Invoke(ctx, "/voltha.VolthaService/ListLogicalDevices", in, out, opts...)
662 if err != nil {
663 return nil, err
664 }
665 return out, nil
666}
667
668func (c *volthaServiceClient) GetLogicalDevice(ctx context.Context, in *common.ID, opts ...grpc.CallOption) (*LogicalDevice, error) {
669 out := new(LogicalDevice)
670 err := c.cc.Invoke(ctx, "/voltha.VolthaService/GetLogicalDevice", in, out, opts...)
671 if err != nil {
672 return nil, err
673 }
674 return out, nil
675}
676
677func (c *volthaServiceClient) ListLogicalDevicePorts(ctx context.Context, in *common.ID, opts ...grpc.CallOption) (*LogicalPorts, error) {
678 out := new(LogicalPorts)
679 err := c.cc.Invoke(ctx, "/voltha.VolthaService/ListLogicalDevicePorts", in, out, opts...)
680 if err != nil {
681 return nil, err
682 }
683 return out, nil
684}
685
686func (c *volthaServiceClient) GetLogicalDevicePort(ctx context.Context, in *LogicalPortId, opts ...grpc.CallOption) (*LogicalPort, error) {
687 out := new(LogicalPort)
688 err := c.cc.Invoke(ctx, "/voltha.VolthaService/GetLogicalDevicePort", in, out, opts...)
689 if err != nil {
690 return nil, err
691 }
692 return out, nil
693}
694
695func (c *volthaServiceClient) EnableLogicalDevicePort(ctx context.Context, in *LogicalPortId, opts ...grpc.CallOption) (*empty.Empty, error) {
696 out := new(empty.Empty)
697 err := c.cc.Invoke(ctx, "/voltha.VolthaService/EnableLogicalDevicePort", in, out, opts...)
698 if err != nil {
699 return nil, err
700 }
701 return out, nil
702}
703
704func (c *volthaServiceClient) DisableLogicalDevicePort(ctx context.Context, in *LogicalPortId, opts ...grpc.CallOption) (*empty.Empty, error) {
705 out := new(empty.Empty)
706 err := c.cc.Invoke(ctx, "/voltha.VolthaService/DisableLogicalDevicePort", in, out, opts...)
707 if err != nil {
708 return nil, err
709 }
710 return out, nil
711}
712
713func (c *volthaServiceClient) ListLogicalDeviceFlows(ctx context.Context, in *common.ID, opts ...grpc.CallOption) (*openflow_13.Flows, error) {
714 out := new(openflow_13.Flows)
715 err := c.cc.Invoke(ctx, "/voltha.VolthaService/ListLogicalDeviceFlows", in, out, opts...)
716 if err != nil {
717 return nil, err
718 }
719 return out, nil
720}
721
722func (c *volthaServiceClient) UpdateLogicalDeviceFlowTable(ctx context.Context, in *openflow_13.FlowTableUpdate, opts ...grpc.CallOption) (*empty.Empty, error) {
723 out := new(empty.Empty)
724 err := c.cc.Invoke(ctx, "/voltha.VolthaService/UpdateLogicalDeviceFlowTable", in, out, opts...)
725 if err != nil {
726 return nil, err
727 }
728 return out, nil
729}
730
731func (c *volthaServiceClient) UpdateLogicalDeviceMeterTable(ctx context.Context, in *openflow_13.MeterModUpdate, opts ...grpc.CallOption) (*empty.Empty, error) {
732 out := new(empty.Empty)
733 err := c.cc.Invoke(ctx, "/voltha.VolthaService/UpdateLogicalDeviceMeterTable", in, out, opts...)
734 if err != nil {
735 return nil, err
736 }
737 return out, nil
738}
739
Abhilash Laxmeshwardfbb74d2019-07-23 08:03:08 -0400740func (c *volthaServiceClient) ListLogicalDeviceMeters(ctx context.Context, in *common.ID, opts ...grpc.CallOption) (*openflow_13.Meters, error) {
741 out := new(openflow_13.Meters)
742 err := c.cc.Invoke(ctx, "/voltha.VolthaService/ListLogicalDeviceMeters", in, out, opts...)
William Kurkian1b363f42019-03-12 15:28:12 -0400743 if err != nil {
744 return nil, err
745 }
746 return out, nil
747}
748
749func (c *volthaServiceClient) ListLogicalDeviceFlowGroups(ctx context.Context, in *common.ID, opts ...grpc.CallOption) (*openflow_13.FlowGroups, error) {
750 out := new(openflow_13.FlowGroups)
751 err := c.cc.Invoke(ctx, "/voltha.VolthaService/ListLogicalDeviceFlowGroups", in, out, opts...)
752 if err != nil {
753 return nil, err
754 }
755 return out, nil
756}
757
758func (c *volthaServiceClient) UpdateLogicalDeviceFlowGroupTable(ctx context.Context, in *openflow_13.FlowGroupTableUpdate, opts ...grpc.CallOption) (*empty.Empty, error) {
759 out := new(empty.Empty)
760 err := c.cc.Invoke(ctx, "/voltha.VolthaService/UpdateLogicalDeviceFlowGroupTable", in, out, opts...)
761 if err != nil {
762 return nil, err
763 }
764 return out, nil
765}
766
767func (c *volthaServiceClient) ListDevices(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*Devices, error) {
768 out := new(Devices)
769 err := c.cc.Invoke(ctx, "/voltha.VolthaService/ListDevices", in, out, opts...)
770 if err != nil {
771 return nil, err
772 }
773 return out, nil
774}
775
776func (c *volthaServiceClient) ListDeviceIds(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*common.IDs, error) {
777 out := new(common.IDs)
778 err := c.cc.Invoke(ctx, "/voltha.VolthaService/ListDeviceIds", in, out, opts...)
779 if err != nil {
780 return nil, err
781 }
782 return out, nil
783}
784
785func (c *volthaServiceClient) ReconcileDevices(ctx context.Context, in *common.IDs, opts ...grpc.CallOption) (*empty.Empty, error) {
786 out := new(empty.Empty)
787 err := c.cc.Invoke(ctx, "/voltha.VolthaService/ReconcileDevices", in, out, opts...)
788 if err != nil {
789 return nil, err
790 }
791 return out, nil
792}
793
794func (c *volthaServiceClient) GetDevice(ctx context.Context, in *common.ID, opts ...grpc.CallOption) (*Device, error) {
795 out := new(Device)
796 err := c.cc.Invoke(ctx, "/voltha.VolthaService/GetDevice", in, out, opts...)
797 if err != nil {
798 return nil, err
799 }
800 return out, nil
801}
802
803func (c *volthaServiceClient) CreateDevice(ctx context.Context, in *Device, opts ...grpc.CallOption) (*Device, error) {
804 out := new(Device)
805 err := c.cc.Invoke(ctx, "/voltha.VolthaService/CreateDevice", in, out, opts...)
806 if err != nil {
807 return nil, err
808 }
809 return out, nil
810}
811
812func (c *volthaServiceClient) EnableDevice(ctx context.Context, in *common.ID, opts ...grpc.CallOption) (*empty.Empty, error) {
813 out := new(empty.Empty)
814 err := c.cc.Invoke(ctx, "/voltha.VolthaService/EnableDevice", in, out, opts...)
815 if err != nil {
816 return nil, err
817 }
818 return out, nil
819}
820
821func (c *volthaServiceClient) DisableDevice(ctx context.Context, in *common.ID, opts ...grpc.CallOption) (*empty.Empty, error) {
822 out := new(empty.Empty)
823 err := c.cc.Invoke(ctx, "/voltha.VolthaService/DisableDevice", in, out, opts...)
824 if err != nil {
825 return nil, err
826 }
827 return out, nil
828}
829
830func (c *volthaServiceClient) RebootDevice(ctx context.Context, in *common.ID, opts ...grpc.CallOption) (*empty.Empty, error) {
831 out := new(empty.Empty)
832 err := c.cc.Invoke(ctx, "/voltha.VolthaService/RebootDevice", in, out, opts...)
833 if err != nil {
834 return nil, err
835 }
836 return out, nil
837}
838
839func (c *volthaServiceClient) DeleteDevice(ctx context.Context, in *common.ID, opts ...grpc.CallOption) (*empty.Empty, error) {
840 out := new(empty.Empty)
841 err := c.cc.Invoke(ctx, "/voltha.VolthaService/DeleteDevice", in, out, opts...)
842 if err != nil {
843 return nil, err
844 }
845 return out, nil
846}
847
Himani Chawla503b7ce2020-10-07 13:20:03 +0530848func (c *volthaServiceClient) ForceDeleteDevice(ctx context.Context, in *common.ID, opts ...grpc.CallOption) (*empty.Empty, error) {
849 out := new(empty.Empty)
850 err := c.cc.Invoke(ctx, "/voltha.VolthaService/ForceDeleteDevice", in, out, opts...)
851 if err != nil {
852 return nil, err
853 }
854 return out, nil
855}
856
khenaidoo4c6543e2021-10-19 17:25:58 -0400857// Deprecated: Do not use.
William Kurkian1b363f42019-03-12 15:28:12 -0400858func (c *volthaServiceClient) DownloadImage(ctx context.Context, in *ImageDownload, opts ...grpc.CallOption) (*common.OperationResp, error) {
859 out := new(common.OperationResp)
860 err := c.cc.Invoke(ctx, "/voltha.VolthaService/DownloadImage", in, out, opts...)
861 if err != nil {
862 return nil, err
863 }
864 return out, nil
865}
866
khenaidoo4c6543e2021-10-19 17:25:58 -0400867// Deprecated: Do not use.
William Kurkian1b363f42019-03-12 15:28:12 -0400868func (c *volthaServiceClient) GetImageDownloadStatus(ctx context.Context, in *ImageDownload, opts ...grpc.CallOption) (*ImageDownload, error) {
869 out := new(ImageDownload)
870 err := c.cc.Invoke(ctx, "/voltha.VolthaService/GetImageDownloadStatus", in, out, opts...)
871 if err != nil {
872 return nil, err
873 }
874 return out, nil
875}
876
khenaidoo4c6543e2021-10-19 17:25:58 -0400877// Deprecated: Do not use.
William Kurkian1b363f42019-03-12 15:28:12 -0400878func (c *volthaServiceClient) GetImageDownload(ctx context.Context, in *ImageDownload, opts ...grpc.CallOption) (*ImageDownload, error) {
879 out := new(ImageDownload)
880 err := c.cc.Invoke(ctx, "/voltha.VolthaService/GetImageDownload", in, out, opts...)
881 if err != nil {
882 return nil, err
883 }
884 return out, nil
885}
886
khenaidoo4c6543e2021-10-19 17:25:58 -0400887// Deprecated: Do not use.
William Kurkian1b363f42019-03-12 15:28:12 -0400888func (c *volthaServiceClient) ListImageDownloads(ctx context.Context, in *common.ID, opts ...grpc.CallOption) (*ImageDownloads, error) {
889 out := new(ImageDownloads)
890 err := c.cc.Invoke(ctx, "/voltha.VolthaService/ListImageDownloads", in, out, opts...)
891 if err != nil {
892 return nil, err
893 }
894 return out, nil
895}
896
khenaidoo4c6543e2021-10-19 17:25:58 -0400897// Deprecated: Do not use.
William Kurkian1b363f42019-03-12 15:28:12 -0400898func (c *volthaServiceClient) CancelImageDownload(ctx context.Context, in *ImageDownload, opts ...grpc.CallOption) (*common.OperationResp, error) {
899 out := new(common.OperationResp)
900 err := c.cc.Invoke(ctx, "/voltha.VolthaService/CancelImageDownload", in, out, opts...)
901 if err != nil {
902 return nil, err
903 }
904 return out, nil
905}
906
khenaidoo4c6543e2021-10-19 17:25:58 -0400907// Deprecated: Do not use.
William Kurkian1b363f42019-03-12 15:28:12 -0400908func (c *volthaServiceClient) ActivateImageUpdate(ctx context.Context, in *ImageDownload, opts ...grpc.CallOption) (*common.OperationResp, error) {
909 out := new(common.OperationResp)
910 err := c.cc.Invoke(ctx, "/voltha.VolthaService/ActivateImageUpdate", in, out, opts...)
911 if err != nil {
912 return nil, err
913 }
914 return out, nil
915}
916
khenaidoo4c6543e2021-10-19 17:25:58 -0400917// Deprecated: Do not use.
William Kurkian1b363f42019-03-12 15:28:12 -0400918func (c *volthaServiceClient) RevertImageUpdate(ctx context.Context, in *ImageDownload, opts ...grpc.CallOption) (*common.OperationResp, error) {
919 out := new(common.OperationResp)
920 err := c.cc.Invoke(ctx, "/voltha.VolthaService/RevertImageUpdate", in, out, opts...)
921 if err != nil {
922 return nil, err
923 }
924 return out, nil
925}
926
Andrea Campanella9e94e8a2021-01-19 15:21:25 +0100927func (c *volthaServiceClient) DownloadImageToDevice(ctx context.Context, in *DeviceImageDownloadRequest, opts ...grpc.CallOption) (*DeviceImageResponse, error) {
928 out := new(DeviceImageResponse)
929 err := c.cc.Invoke(ctx, "/voltha.VolthaService/DownloadImageToDevice", in, out, opts...)
930 if err != nil {
931 return nil, err
932 }
933 return out, nil
934}
935
936func (c *volthaServiceClient) GetImageStatus(ctx context.Context, in *DeviceImageRequest, opts ...grpc.CallOption) (*DeviceImageResponse, error) {
937 out := new(DeviceImageResponse)
938 err := c.cc.Invoke(ctx, "/voltha.VolthaService/GetImageStatus", in, out, opts...)
939 if err != nil {
940 return nil, err
941 }
942 return out, nil
943}
944
945func (c *volthaServiceClient) AbortImageUpgradeToDevice(ctx context.Context, in *DeviceImageRequest, opts ...grpc.CallOption) (*DeviceImageResponse, error) {
946 out := new(DeviceImageResponse)
947 err := c.cc.Invoke(ctx, "/voltha.VolthaService/AbortImageUpgradeToDevice", in, out, opts...)
948 if err != nil {
949 return nil, err
950 }
951 return out, nil
952}
953
954func (c *volthaServiceClient) GetOnuImages(ctx context.Context, in *common.ID, opts ...grpc.CallOption) (*OnuImages, error) {
955 out := new(OnuImages)
956 err := c.cc.Invoke(ctx, "/voltha.VolthaService/GetOnuImages", in, out, opts...)
957 if err != nil {
958 return nil, err
959 }
960 return out, nil
961}
962
963func (c *volthaServiceClient) ActivateImage(ctx context.Context, in *DeviceImageRequest, opts ...grpc.CallOption) (*DeviceImageResponse, error) {
964 out := new(DeviceImageResponse)
965 err := c.cc.Invoke(ctx, "/voltha.VolthaService/ActivateImage", in, out, opts...)
966 if err != nil {
967 return nil, err
968 }
969 return out, nil
970}
971
972func (c *volthaServiceClient) CommitImage(ctx context.Context, in *DeviceImageRequest, opts ...grpc.CallOption) (*DeviceImageResponse, error) {
973 out := new(DeviceImageResponse)
974 err := c.cc.Invoke(ctx, "/voltha.VolthaService/CommitImage", in, out, opts...)
975 if err != nil {
976 return nil, err
977 }
978 return out, nil
979}
980
William Kurkian1b363f42019-03-12 15:28:12 -0400981func (c *volthaServiceClient) ListDevicePorts(ctx context.Context, in *common.ID, opts ...grpc.CallOption) (*Ports, error) {
982 out := new(Ports)
983 err := c.cc.Invoke(ctx, "/voltha.VolthaService/ListDevicePorts", in, out, opts...)
984 if err != nil {
985 return nil, err
986 }
987 return out, nil
988}
989
990func (c *volthaServiceClient) ListDevicePmConfigs(ctx context.Context, in *common.ID, opts ...grpc.CallOption) (*PmConfigs, error) {
991 out := new(PmConfigs)
992 err := c.cc.Invoke(ctx, "/voltha.VolthaService/ListDevicePmConfigs", in, out, opts...)
993 if err != nil {
994 return nil, err
995 }
996 return out, nil
997}
998
999func (c *volthaServiceClient) UpdateDevicePmConfigs(ctx context.Context, in *PmConfigs, opts ...grpc.CallOption) (*empty.Empty, error) {
1000 out := new(empty.Empty)
1001 err := c.cc.Invoke(ctx, "/voltha.VolthaService/UpdateDevicePmConfigs", in, out, opts...)
1002 if err != nil {
1003 return nil, err
1004 }
1005 return out, nil
1006}
1007
1008func (c *volthaServiceClient) ListDeviceFlows(ctx context.Context, in *common.ID, opts ...grpc.CallOption) (*openflow_13.Flows, error) {
1009 out := new(openflow_13.Flows)
1010 err := c.cc.Invoke(ctx, "/voltha.VolthaService/ListDeviceFlows", in, out, opts...)
1011 if err != nil {
1012 return nil, err
1013 }
1014 return out, nil
1015}
1016
1017func (c *volthaServiceClient) ListDeviceFlowGroups(ctx context.Context, in *common.ID, opts ...grpc.CallOption) (*openflow_13.FlowGroups, error) {
1018 out := new(openflow_13.FlowGroups)
1019 err := c.cc.Invoke(ctx, "/voltha.VolthaService/ListDeviceFlowGroups", in, out, opts...)
1020 if err != nil {
1021 return nil, err
1022 }
1023 return out, nil
1024}
1025
1026func (c *volthaServiceClient) ListDeviceTypes(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*DeviceTypes, error) {
1027 out := new(DeviceTypes)
1028 err := c.cc.Invoke(ctx, "/voltha.VolthaService/ListDeviceTypes", in, out, opts...)
1029 if err != nil {
1030 return nil, err
1031 }
1032 return out, nil
1033}
1034
1035func (c *volthaServiceClient) GetDeviceType(ctx context.Context, in *common.ID, opts ...grpc.CallOption) (*DeviceType, error) {
1036 out := new(DeviceType)
1037 err := c.cc.Invoke(ctx, "/voltha.VolthaService/GetDeviceType", in, out, opts...)
1038 if err != nil {
1039 return nil, err
1040 }
1041 return out, nil
1042}
1043
William Kurkian1b363f42019-03-12 15:28:12 -04001044func (c *volthaServiceClient) StreamPacketsOut(ctx context.Context, opts ...grpc.CallOption) (VolthaService_StreamPacketsOutClient, error) {
1045 stream, err := c.cc.NewStream(ctx, &_VolthaService_serviceDesc.Streams[0], "/voltha.VolthaService/StreamPacketsOut", opts...)
1046 if err != nil {
1047 return nil, err
1048 }
1049 x := &volthaServiceStreamPacketsOutClient{stream}
1050 return x, nil
1051}
1052
1053type VolthaService_StreamPacketsOutClient interface {
1054 Send(*openflow_13.PacketOut) error
1055 CloseAndRecv() (*empty.Empty, error)
1056 grpc.ClientStream
1057}
1058
1059type volthaServiceStreamPacketsOutClient struct {
1060 grpc.ClientStream
1061}
1062
1063func (x *volthaServiceStreamPacketsOutClient) Send(m *openflow_13.PacketOut) error {
1064 return x.ClientStream.SendMsg(m)
1065}
1066
1067func (x *volthaServiceStreamPacketsOutClient) CloseAndRecv() (*empty.Empty, error) {
1068 if err := x.ClientStream.CloseSend(); err != nil {
1069 return nil, err
1070 }
1071 m := new(empty.Empty)
1072 if err := x.ClientStream.RecvMsg(m); err != nil {
1073 return nil, err
1074 }
1075 return m, nil
1076}
1077
1078func (c *volthaServiceClient) ReceivePacketsIn(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (VolthaService_ReceivePacketsInClient, error) {
1079 stream, err := c.cc.NewStream(ctx, &_VolthaService_serviceDesc.Streams[1], "/voltha.VolthaService/ReceivePacketsIn", opts...)
1080 if err != nil {
1081 return nil, err
1082 }
1083 x := &volthaServiceReceivePacketsInClient{stream}
1084 if err := x.ClientStream.SendMsg(in); err != nil {
1085 return nil, err
1086 }
1087 if err := x.ClientStream.CloseSend(); err != nil {
1088 return nil, err
1089 }
1090 return x, nil
1091}
1092
1093type VolthaService_ReceivePacketsInClient interface {
1094 Recv() (*openflow_13.PacketIn, error)
1095 grpc.ClientStream
1096}
1097
1098type volthaServiceReceivePacketsInClient struct {
1099 grpc.ClientStream
1100}
1101
1102func (x *volthaServiceReceivePacketsInClient) Recv() (*openflow_13.PacketIn, error) {
1103 m := new(openflow_13.PacketIn)
1104 if err := x.ClientStream.RecvMsg(m); err != nil {
1105 return nil, err
1106 }
1107 return m, nil
1108}
1109
1110func (c *volthaServiceClient) ReceiveChangeEvents(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (VolthaService_ReceiveChangeEventsClient, error) {
1111 stream, err := c.cc.NewStream(ctx, &_VolthaService_serviceDesc.Streams[2], "/voltha.VolthaService/ReceiveChangeEvents", opts...)
1112 if err != nil {
1113 return nil, err
1114 }
1115 x := &volthaServiceReceiveChangeEventsClient{stream}
1116 if err := x.ClientStream.SendMsg(in); err != nil {
1117 return nil, err
1118 }
1119 if err := x.ClientStream.CloseSend(); err != nil {
1120 return nil, err
1121 }
1122 return x, nil
1123}
1124
1125type VolthaService_ReceiveChangeEventsClient interface {
1126 Recv() (*openflow_13.ChangeEvent, error)
1127 grpc.ClientStream
1128}
1129
1130type volthaServiceReceiveChangeEventsClient struct {
1131 grpc.ClientStream
1132}
1133
1134func (x *volthaServiceReceiveChangeEventsClient) Recv() (*openflow_13.ChangeEvent, error) {
1135 m := new(openflow_13.ChangeEvent)
1136 if err := x.ClientStream.RecvMsg(m); err != nil {
1137 return nil, err
1138 }
1139 return m, nil
1140}
1141
Devmalya Paul96a2c9e2019-11-06 07:17:44 +00001142func (c *volthaServiceClient) CreateEventFilter(ctx context.Context, in *EventFilter, opts ...grpc.CallOption) (*EventFilter, error) {
1143 out := new(EventFilter)
1144 err := c.cc.Invoke(ctx, "/voltha.VolthaService/CreateEventFilter", in, out, opts...)
William Kurkian1b363f42019-03-12 15:28:12 -04001145 if err != nil {
1146 return nil, err
1147 }
1148 return out, nil
1149}
1150
Devmalya Paul96a2c9e2019-11-06 07:17:44 +00001151func (c *volthaServiceClient) GetEventFilter(ctx context.Context, in *common.ID, opts ...grpc.CallOption) (*EventFilters, error) {
1152 out := new(EventFilters)
1153 err := c.cc.Invoke(ctx, "/voltha.VolthaService/GetEventFilter", in, out, opts...)
William Kurkian1b363f42019-03-12 15:28:12 -04001154 if err != nil {
1155 return nil, err
1156 }
1157 return out, nil
1158}
1159
Devmalya Paul96a2c9e2019-11-06 07:17:44 +00001160func (c *volthaServiceClient) UpdateEventFilter(ctx context.Context, in *EventFilter, opts ...grpc.CallOption) (*EventFilter, error) {
1161 out := new(EventFilter)
1162 err := c.cc.Invoke(ctx, "/voltha.VolthaService/UpdateEventFilter", in, out, opts...)
William Kurkian1b363f42019-03-12 15:28:12 -04001163 if err != nil {
1164 return nil, err
1165 }
1166 return out, nil
1167}
1168
Devmalya Paul96a2c9e2019-11-06 07:17:44 +00001169func (c *volthaServiceClient) DeleteEventFilter(ctx context.Context, in *EventFilter, opts ...grpc.CallOption) (*empty.Empty, error) {
William Kurkian1b363f42019-03-12 15:28:12 -04001170 out := new(empty.Empty)
Devmalya Paul96a2c9e2019-11-06 07:17:44 +00001171 err := c.cc.Invoke(ctx, "/voltha.VolthaService/DeleteEventFilter", in, out, opts...)
William Kurkian1b363f42019-03-12 15:28:12 -04001172 if err != nil {
1173 return nil, err
1174 }
1175 return out, nil
1176}
1177
Devmalya Paul96a2c9e2019-11-06 07:17:44 +00001178func (c *volthaServiceClient) ListEventFilters(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*EventFilters, error) {
1179 out := new(EventFilters)
1180 err := c.cc.Invoke(ctx, "/voltha.VolthaService/ListEventFilters", in, out, opts...)
William Kurkian1b363f42019-03-12 15:28:12 -04001181 if err != nil {
1182 return nil, err
1183 }
1184 return out, nil
1185}
1186
1187func (c *volthaServiceClient) GetImages(ctx context.Context, in *common.ID, opts ...grpc.CallOption) (*Images, error) {
1188 out := new(Images)
1189 err := c.cc.Invoke(ctx, "/voltha.VolthaService/GetImages", in, out, opts...)
1190 if err != nil {
1191 return nil, err
1192 }
1193 return out, nil
1194}
1195
1196func (c *volthaServiceClient) SelfTest(ctx context.Context, in *common.ID, opts ...grpc.CallOption) (*SelfTestResponse, error) {
1197 out := new(SelfTestResponse)
1198 err := c.cc.Invoke(ctx, "/voltha.VolthaService/SelfTest", in, out, opts...)
1199 if err != nil {
1200 return nil, err
1201 }
1202 return out, nil
1203}
1204
1205func (c *volthaServiceClient) GetMibDeviceData(ctx context.Context, in *common.ID, opts ...grpc.CallOption) (*omci.MibDeviceData, error) {
1206 out := new(omci.MibDeviceData)
1207 err := c.cc.Invoke(ctx, "/voltha.VolthaService/GetMibDeviceData", in, out, opts...)
1208 if err != nil {
1209 return nil, err
1210 }
1211 return out, nil
1212}
1213
1214func (c *volthaServiceClient) GetAlarmDeviceData(ctx context.Context, in *common.ID, opts ...grpc.CallOption) (*omci.AlarmDeviceData, error) {
1215 out := new(omci.AlarmDeviceData)
1216 err := c.cc.Invoke(ctx, "/voltha.VolthaService/GetAlarmDeviceData", in, out, opts...)
1217 if err != nil {
1218 return nil, err
1219 }
1220 return out, nil
1221}
1222
1223func (c *volthaServiceClient) SimulateAlarm(ctx context.Context, in *SimulateAlarmRequest, opts ...grpc.CallOption) (*common.OperationResp, error) {
1224 out := new(common.OperationResp)
1225 err := c.cc.Invoke(ctx, "/voltha.VolthaService/SimulateAlarm", in, out, opts...)
1226 if err != nil {
1227 return nil, err
1228 }
1229 return out, nil
1230}
1231
kesavand4a002b02020-01-23 21:29:47 -05001232func (c *volthaServiceClient) EnablePort(ctx context.Context, in *Port, opts ...grpc.CallOption) (*empty.Empty, error) {
1233 out := new(empty.Empty)
1234 err := c.cc.Invoke(ctx, "/voltha.VolthaService/EnablePort", in, out, opts...)
1235 if err != nil {
1236 return nil, err
1237 }
1238 return out, nil
1239}
1240
1241func (c *volthaServiceClient) DisablePort(ctx context.Context, in *Port, opts ...grpc.CallOption) (*empty.Empty, error) {
1242 out := new(empty.Empty)
1243 err := c.cc.Invoke(ctx, "/voltha.VolthaService/DisablePort", in, out, opts...)
1244 if err != nil {
1245 return nil, err
1246 }
1247 return out, nil
1248}
1249
khenaidoo4c6543e2021-10-19 17:25:58 -04001250func (c *volthaServiceClient) GetExtValue(ctx context.Context, in *extension.ValueSpecifier, opts ...grpc.CallOption) (*extension.ReturnValues, error) {
1251 out := new(extension.ReturnValues)
Dinesh Belwalkared6da5e2020-02-25 11:23:57 -08001252 err := c.cc.Invoke(ctx, "/voltha.VolthaService/GetExtValue", in, out, opts...)
1253 if err != nil {
1254 return nil, err
1255 }
1256 return out, nil
1257}
1258
khenaidoo4c6543e2021-10-19 17:25:58 -04001259func (c *volthaServiceClient) SetExtValue(ctx context.Context, in *extension.ValueSet, opts ...grpc.CallOption) (*empty.Empty, error) {
dpaul2b52e712020-06-23 13:02:28 +05301260 out := new(empty.Empty)
1261 err := c.cc.Invoke(ctx, "/voltha.VolthaService/SetExtValue", in, out, opts...)
1262 if err != nil {
1263 return nil, err
1264 }
1265 return out, nil
1266}
1267
khenaidoo4c6543e2021-10-19 17:25:58 -04001268func (c *volthaServiceClient) StartOmciTestAction(ctx context.Context, in *omci.OmciTestRequest, opts ...grpc.CallOption) (*omci.TestResponse, error) {
1269 out := new(omci.TestResponse)
onkar.kundargi7b85fa12020-02-27 13:19:22 +05301270 err := c.cc.Invoke(ctx, "/voltha.VolthaService/StartOmciTestAction", in, out, opts...)
1271 if err != nil {
1272 return nil, err
1273 }
1274 return out, nil
1275}
1276
William Kurkian1b363f42019-03-12 15:28:12 -04001277// VolthaServiceServer is the server API for VolthaService service.
1278type VolthaServiceServer interface {
William Kurkian1b363f42019-03-12 15:28:12 -04001279 // Get high level information on the Voltha cluster
1280 GetVoltha(context.Context, *empty.Empty) (*Voltha, error)
1281 // List all Voltha cluster core instances
1282 ListCoreInstances(context.Context, *empty.Empty) (*CoreInstances, error)
1283 // Get details on a Voltha cluster instance
1284 GetCoreInstance(context.Context, *common.ID) (*CoreInstance, error)
1285 // List all active adapters (plugins) in the Voltha cluster
1286 ListAdapters(context.Context, *empty.Empty) (*Adapters, error)
1287 // List all logical devices managed by the Voltha cluster
1288 ListLogicalDevices(context.Context, *empty.Empty) (*LogicalDevices, error)
1289 // Get additional information on a given logical device
1290 GetLogicalDevice(context.Context, *common.ID) (*LogicalDevice, error)
1291 // List ports of a logical device
1292 ListLogicalDevicePorts(context.Context, *common.ID) (*LogicalPorts, error)
1293 // Gets a logical device port
1294 GetLogicalDevicePort(context.Context, *LogicalPortId) (*LogicalPort, error)
1295 // Enables a logical device port
1296 EnableLogicalDevicePort(context.Context, *LogicalPortId) (*empty.Empty, error)
1297 // Disables a logical device port
1298 DisableLogicalDevicePort(context.Context, *LogicalPortId) (*empty.Empty, error)
1299 // List all flows of a logical device
1300 ListLogicalDeviceFlows(context.Context, *common.ID) (*openflow_13.Flows, error)
1301 // Update flow table for logical device
1302 UpdateLogicalDeviceFlowTable(context.Context, *openflow_13.FlowTableUpdate) (*empty.Empty, error)
1303 // Update meter table for logical device
1304 UpdateLogicalDeviceMeterTable(context.Context, *openflow_13.MeterModUpdate) (*empty.Empty, error)
Abhilash Laxmeshwardfbb74d2019-07-23 08:03:08 -04001305 // List all meters of a logical device
1306 ListLogicalDeviceMeters(context.Context, *common.ID) (*openflow_13.Meters, error)
William Kurkian1b363f42019-03-12 15:28:12 -04001307 // List all flow groups of a logical device
1308 ListLogicalDeviceFlowGroups(context.Context, *common.ID) (*openflow_13.FlowGroups, error)
1309 // Update group table for device
1310 UpdateLogicalDeviceFlowGroupTable(context.Context, *openflow_13.FlowGroupTableUpdate) (*empty.Empty, error)
1311 // List all physical devices controlled by the Voltha cluster
1312 ListDevices(context.Context, *empty.Empty) (*Devices, error)
1313 // List all physical devices IDs controlled by the Voltha cluster
1314 ListDeviceIds(context.Context, *empty.Empty) (*common.IDs, error)
1315 // Request to a voltha Core to reconcile a set of devices based on their IDs
1316 ReconcileDevices(context.Context, *common.IDs) (*empty.Empty, error)
1317 // Get more information on a given physical device
1318 GetDevice(context.Context, *common.ID) (*Device, error)
1319 // Pre-provision a new physical device
1320 CreateDevice(context.Context, *Device) (*Device, error)
1321 // Enable a device. If the device was in pre-provisioned state then it
1322 // will transition to ENABLED state. If it was is DISABLED state then it
1323 // will transition to ENABLED state as well.
1324 EnableDevice(context.Context, *common.ID) (*empty.Empty, error)
1325 // Disable a device
1326 DisableDevice(context.Context, *common.ID) (*empty.Empty, error)
1327 // Reboot a device
1328 RebootDevice(context.Context, *common.ID) (*empty.Empty, error)
1329 // Delete a device
1330 DeleteDevice(context.Context, *common.ID) (*empty.Empty, error)
Himani Chawla503b7ce2020-10-07 13:20:03 +05301331 // Forcefully delete a device
1332 ForceDeleteDevice(context.Context, *common.ID) (*empty.Empty, error)
William Kurkian1b363f42019-03-12 15:28:12 -04001333 // Request an image download to the standby partition
1334 // of a device.
1335 // Note that the call is expected to be non-blocking.
1336 DownloadImage(context.Context, *ImageDownload) (*common.OperationResp, error)
1337 // Get image download status on a device
1338 // The request retrieves progress on device and updates db record
Andrea Campanella9e94e8a2021-01-19 15:21:25 +01001339 // Deprecated in voltha 2.8, will be removed
William Kurkian1b363f42019-03-12 15:28:12 -04001340 GetImageDownloadStatus(context.Context, *ImageDownload) (*ImageDownload, error)
1341 // Get image download db record
Andrea Campanella9e94e8a2021-01-19 15:21:25 +01001342 // Deprecated in voltha 2.8, will be removed
William Kurkian1b363f42019-03-12 15:28:12 -04001343 GetImageDownload(context.Context, *ImageDownload) (*ImageDownload, error)
1344 // List image download db records for a given device
Andrea Campanella9e94e8a2021-01-19 15:21:25 +01001345 // Deprecated in voltha 2.8, will be removed
William Kurkian1b363f42019-03-12 15:28:12 -04001346 ListImageDownloads(context.Context, *common.ID) (*ImageDownloads, error)
1347 // Cancel an existing image download process on a device
Andrea Campanella9e94e8a2021-01-19 15:21:25 +01001348 // Deprecated in voltha 2.8, will be removed
William Kurkian1b363f42019-03-12 15:28:12 -04001349 CancelImageDownload(context.Context, *ImageDownload) (*common.OperationResp, error)
1350 // Activate the specified image at a standby partition
1351 // to active partition.
1352 // Depending on the device implementation, this call
1353 // may or may not cause device reboot.
1354 // If no reboot, then a reboot is required to make the
1355 // activated image running on device
1356 // Note that the call is expected to be non-blocking.
Andrea Campanella9e94e8a2021-01-19 15:21:25 +01001357 // Deprecated in voltha 2.8, will be removed
William Kurkian1b363f42019-03-12 15:28:12 -04001358 ActivateImageUpdate(context.Context, *ImageDownload) (*common.OperationResp, error)
1359 // Revert the specified image at standby partition
1360 // to active partition, and revert to previous image
1361 // Depending on the device implementation, this call
1362 // may or may not cause device reboot.
1363 // If no reboot, then a reboot is required to make the
1364 // previous image running on device
1365 // Note that the call is expected to be non-blocking.
Andrea Campanella9e94e8a2021-01-19 15:21:25 +01001366 // Deprecated in voltha 2.8, will be removed
William Kurkian1b363f42019-03-12 15:28:12 -04001367 RevertImageUpdate(context.Context, *ImageDownload) (*common.OperationResp, error)
Andrea Campanella9e94e8a2021-01-19 15:21:25 +01001368 // Downloads a certain image to the standby partition of the devices
1369 // Note that the call is expected to be non-blocking.
1370 DownloadImageToDevice(context.Context, *DeviceImageDownloadRequest) (*DeviceImageResponse, error)
1371 // Get image status on a number of devices devices
1372 // Polled from northbound systems to get state of download/activate/commit
1373 GetImageStatus(context.Context, *DeviceImageRequest) (*DeviceImageResponse, error)
1374 // Aborts the upgrade of an image on a device
1375 // To be used carefully, stops any further operations for the Image on the given devices
1376 // Might also stop if possible existing work, but no guarantees are given,
1377 // depends on implementation and procedure status.
1378 AbortImageUpgradeToDevice(context.Context, *DeviceImageRequest) (*DeviceImageResponse, error)
1379 // Get Both Active and Standby image for a given device
1380 GetOnuImages(context.Context, *common.ID) (*OnuImages, error)
1381 // Activate the specified image from a standby partition
1382 // to active partition.
1383 // Depending on the device implementation, this call
1384 // may or may not cause device reboot.
1385 // If no reboot, then a reboot is required to make the
1386 // activated image running on device
1387 // Note that the call is expected to be non-blocking.
1388 ActivateImage(context.Context, *DeviceImageRequest) (*DeviceImageResponse, error)
1389 // Commit the specified image to be default.
1390 // Depending on the device implementation, this call
1391 // may or may not cause device reboot.
1392 // If no reboot, then a reboot is required to make the
1393 // activated image running on device upon next reboot
1394 // Note that the call is expected to be non-blocking.
1395 CommitImage(context.Context, *DeviceImageRequest) (*DeviceImageResponse, error)
William Kurkian1b363f42019-03-12 15:28:12 -04001396 // List ports of a device
1397 ListDevicePorts(context.Context, *common.ID) (*Ports, error)
1398 // List pm config of a device
1399 ListDevicePmConfigs(context.Context, *common.ID) (*PmConfigs, error)
1400 // Update the pm config of a device
1401 UpdateDevicePmConfigs(context.Context, *PmConfigs) (*empty.Empty, error)
1402 // List all flows of a device
1403 ListDeviceFlows(context.Context, *common.ID) (*openflow_13.Flows, error)
1404 // List all flow groups of a device
1405 ListDeviceFlowGroups(context.Context, *common.ID) (*openflow_13.FlowGroups, error)
1406 // List device types known to Voltha
1407 ListDeviceTypes(context.Context, *empty.Empty) (*DeviceTypes, error)
1408 // Get additional information on a device type
1409 GetDeviceType(context.Context, *common.ID) (*DeviceType, error)
William Kurkian1b363f42019-03-12 15:28:12 -04001410 // Stream control packets to the dataplane
1411 StreamPacketsOut(VolthaService_StreamPacketsOutServer) error
1412 // Receive control packet stream
1413 ReceivePacketsIn(*empty.Empty, VolthaService_ReceivePacketsInServer) error
1414 ReceiveChangeEvents(*empty.Empty, VolthaService_ReceiveChangeEventsServer) error
Devmalya Paul96a2c9e2019-11-06 07:17:44 +00001415 CreateEventFilter(context.Context, *EventFilter) (*EventFilter, error)
1416 // Get all filters present for a device
1417 GetEventFilter(context.Context, *common.ID) (*EventFilters, error)
1418 UpdateEventFilter(context.Context, *EventFilter) (*EventFilter, error)
1419 DeleteEventFilter(context.Context, *EventFilter) (*empty.Empty, error)
1420 // Get all the filters present
1421 ListEventFilters(context.Context, *empty.Empty) (*EventFilters, error)
William Kurkian1b363f42019-03-12 15:28:12 -04001422 GetImages(context.Context, *common.ID) (*Images, error)
1423 SelfTest(context.Context, *common.ID) (*SelfTestResponse, error)
1424 // OpenOMCI MIB information
1425 GetMibDeviceData(context.Context, *common.ID) (*omci.MibDeviceData, error)
1426 // OpenOMCI ALARM information
1427 GetAlarmDeviceData(context.Context, *common.ID) (*omci.AlarmDeviceData, error)
1428 // Simulate an Alarm
1429 SimulateAlarm(context.Context, *SimulateAlarmRequest) (*common.OperationResp, error)
kesavand4a002b02020-01-23 21:29:47 -05001430 EnablePort(context.Context, *Port) (*empty.Empty, error)
1431 DisablePort(context.Context, *Port) (*empty.Empty, error)
khenaidoo4c6543e2021-10-19 17:25:58 -04001432 GetExtValue(context.Context, *extension.ValueSpecifier) (*extension.ReturnValues, error)
1433 SetExtValue(context.Context, *extension.ValueSet) (*empty.Empty, error)
onkar.kundargi7b85fa12020-02-27 13:19:22 +05301434 // omci start and stop cli implementation
khenaidoo4c6543e2021-10-19 17:25:58 -04001435 StartOmciTestAction(context.Context, *omci.OmciTestRequest) (*omci.TestResponse, error)
William Kurkian1b363f42019-03-12 15:28:12 -04001436}
1437
David K. Bainbridgec4bf5382021-04-08 16:06:54 +00001438// UnimplementedVolthaServiceServer can be embedded to have forward compatible implementations.
1439type UnimplementedVolthaServiceServer struct {
1440}
1441
David K. Bainbridgec4bf5382021-04-08 16:06:54 +00001442func (*UnimplementedVolthaServiceServer) GetVoltha(ctx context.Context, req *empty.Empty) (*Voltha, error) {
1443 return nil, status.Errorf(codes.Unimplemented, "method GetVoltha not implemented")
1444}
1445func (*UnimplementedVolthaServiceServer) ListCoreInstances(ctx context.Context, req *empty.Empty) (*CoreInstances, error) {
1446 return nil, status.Errorf(codes.Unimplemented, "method ListCoreInstances not implemented")
1447}
1448func (*UnimplementedVolthaServiceServer) GetCoreInstance(ctx context.Context, req *common.ID) (*CoreInstance, error) {
1449 return nil, status.Errorf(codes.Unimplemented, "method GetCoreInstance not implemented")
1450}
1451func (*UnimplementedVolthaServiceServer) ListAdapters(ctx context.Context, req *empty.Empty) (*Adapters, error) {
1452 return nil, status.Errorf(codes.Unimplemented, "method ListAdapters not implemented")
1453}
1454func (*UnimplementedVolthaServiceServer) ListLogicalDevices(ctx context.Context, req *empty.Empty) (*LogicalDevices, error) {
1455 return nil, status.Errorf(codes.Unimplemented, "method ListLogicalDevices not implemented")
1456}
1457func (*UnimplementedVolthaServiceServer) GetLogicalDevice(ctx context.Context, req *common.ID) (*LogicalDevice, error) {
1458 return nil, status.Errorf(codes.Unimplemented, "method GetLogicalDevice not implemented")
1459}
1460func (*UnimplementedVolthaServiceServer) ListLogicalDevicePorts(ctx context.Context, req *common.ID) (*LogicalPorts, error) {
1461 return nil, status.Errorf(codes.Unimplemented, "method ListLogicalDevicePorts not implemented")
1462}
1463func (*UnimplementedVolthaServiceServer) GetLogicalDevicePort(ctx context.Context, req *LogicalPortId) (*LogicalPort, error) {
1464 return nil, status.Errorf(codes.Unimplemented, "method GetLogicalDevicePort not implemented")
1465}
1466func (*UnimplementedVolthaServiceServer) EnableLogicalDevicePort(ctx context.Context, req *LogicalPortId) (*empty.Empty, error) {
1467 return nil, status.Errorf(codes.Unimplemented, "method EnableLogicalDevicePort not implemented")
1468}
1469func (*UnimplementedVolthaServiceServer) DisableLogicalDevicePort(ctx context.Context, req *LogicalPortId) (*empty.Empty, error) {
1470 return nil, status.Errorf(codes.Unimplemented, "method DisableLogicalDevicePort not implemented")
1471}
1472func (*UnimplementedVolthaServiceServer) ListLogicalDeviceFlows(ctx context.Context, req *common.ID) (*openflow_13.Flows, error) {
1473 return nil, status.Errorf(codes.Unimplemented, "method ListLogicalDeviceFlows not implemented")
1474}
1475func (*UnimplementedVolthaServiceServer) UpdateLogicalDeviceFlowTable(ctx context.Context, req *openflow_13.FlowTableUpdate) (*empty.Empty, error) {
1476 return nil, status.Errorf(codes.Unimplemented, "method UpdateLogicalDeviceFlowTable not implemented")
1477}
1478func (*UnimplementedVolthaServiceServer) UpdateLogicalDeviceMeterTable(ctx context.Context, req *openflow_13.MeterModUpdate) (*empty.Empty, error) {
1479 return nil, status.Errorf(codes.Unimplemented, "method UpdateLogicalDeviceMeterTable not implemented")
1480}
1481func (*UnimplementedVolthaServiceServer) ListLogicalDeviceMeters(ctx context.Context, req *common.ID) (*openflow_13.Meters, error) {
1482 return nil, status.Errorf(codes.Unimplemented, "method ListLogicalDeviceMeters not implemented")
1483}
1484func (*UnimplementedVolthaServiceServer) ListLogicalDeviceFlowGroups(ctx context.Context, req *common.ID) (*openflow_13.FlowGroups, error) {
1485 return nil, status.Errorf(codes.Unimplemented, "method ListLogicalDeviceFlowGroups not implemented")
1486}
1487func (*UnimplementedVolthaServiceServer) UpdateLogicalDeviceFlowGroupTable(ctx context.Context, req *openflow_13.FlowGroupTableUpdate) (*empty.Empty, error) {
1488 return nil, status.Errorf(codes.Unimplemented, "method UpdateLogicalDeviceFlowGroupTable not implemented")
1489}
1490func (*UnimplementedVolthaServiceServer) ListDevices(ctx context.Context, req *empty.Empty) (*Devices, error) {
1491 return nil, status.Errorf(codes.Unimplemented, "method ListDevices not implemented")
1492}
1493func (*UnimplementedVolthaServiceServer) ListDeviceIds(ctx context.Context, req *empty.Empty) (*common.IDs, error) {
1494 return nil, status.Errorf(codes.Unimplemented, "method ListDeviceIds not implemented")
1495}
1496func (*UnimplementedVolthaServiceServer) ReconcileDevices(ctx context.Context, req *common.IDs) (*empty.Empty, error) {
1497 return nil, status.Errorf(codes.Unimplemented, "method ReconcileDevices not implemented")
1498}
1499func (*UnimplementedVolthaServiceServer) GetDevice(ctx context.Context, req *common.ID) (*Device, error) {
1500 return nil, status.Errorf(codes.Unimplemented, "method GetDevice not implemented")
1501}
1502func (*UnimplementedVolthaServiceServer) CreateDevice(ctx context.Context, req *Device) (*Device, error) {
1503 return nil, status.Errorf(codes.Unimplemented, "method CreateDevice not implemented")
1504}
1505func (*UnimplementedVolthaServiceServer) EnableDevice(ctx context.Context, req *common.ID) (*empty.Empty, error) {
1506 return nil, status.Errorf(codes.Unimplemented, "method EnableDevice not implemented")
1507}
1508func (*UnimplementedVolthaServiceServer) DisableDevice(ctx context.Context, req *common.ID) (*empty.Empty, error) {
1509 return nil, status.Errorf(codes.Unimplemented, "method DisableDevice not implemented")
1510}
1511func (*UnimplementedVolthaServiceServer) RebootDevice(ctx context.Context, req *common.ID) (*empty.Empty, error) {
1512 return nil, status.Errorf(codes.Unimplemented, "method RebootDevice not implemented")
1513}
1514func (*UnimplementedVolthaServiceServer) DeleteDevice(ctx context.Context, req *common.ID) (*empty.Empty, error) {
1515 return nil, status.Errorf(codes.Unimplemented, "method DeleteDevice not implemented")
1516}
1517func (*UnimplementedVolthaServiceServer) ForceDeleteDevice(ctx context.Context, req *common.ID) (*empty.Empty, error) {
1518 return nil, status.Errorf(codes.Unimplemented, "method ForceDeleteDevice not implemented")
1519}
1520func (*UnimplementedVolthaServiceServer) DownloadImage(ctx context.Context, req *ImageDownload) (*common.OperationResp, error) {
1521 return nil, status.Errorf(codes.Unimplemented, "method DownloadImage not implemented")
1522}
1523func (*UnimplementedVolthaServiceServer) GetImageDownloadStatus(ctx context.Context, req *ImageDownload) (*ImageDownload, error) {
1524 return nil, status.Errorf(codes.Unimplemented, "method GetImageDownloadStatus not implemented")
1525}
1526func (*UnimplementedVolthaServiceServer) GetImageDownload(ctx context.Context, req *ImageDownload) (*ImageDownload, error) {
1527 return nil, status.Errorf(codes.Unimplemented, "method GetImageDownload not implemented")
1528}
1529func (*UnimplementedVolthaServiceServer) ListImageDownloads(ctx context.Context, req *common.ID) (*ImageDownloads, error) {
1530 return nil, status.Errorf(codes.Unimplemented, "method ListImageDownloads not implemented")
1531}
1532func (*UnimplementedVolthaServiceServer) CancelImageDownload(ctx context.Context, req *ImageDownload) (*common.OperationResp, error) {
1533 return nil, status.Errorf(codes.Unimplemented, "method CancelImageDownload not implemented")
1534}
1535func (*UnimplementedVolthaServiceServer) ActivateImageUpdate(ctx context.Context, req *ImageDownload) (*common.OperationResp, error) {
1536 return nil, status.Errorf(codes.Unimplemented, "method ActivateImageUpdate not implemented")
1537}
1538func (*UnimplementedVolthaServiceServer) RevertImageUpdate(ctx context.Context, req *ImageDownload) (*common.OperationResp, error) {
1539 return nil, status.Errorf(codes.Unimplemented, "method RevertImageUpdate not implemented")
1540}
Andrea Campanella9e94e8a2021-01-19 15:21:25 +01001541func (*UnimplementedVolthaServiceServer) DownloadImageToDevice(ctx context.Context, req *DeviceImageDownloadRequest) (*DeviceImageResponse, error) {
1542 return nil, status.Errorf(codes.Unimplemented, "method DownloadImageToDevice not implemented")
1543}
1544func (*UnimplementedVolthaServiceServer) GetImageStatus(ctx context.Context, req *DeviceImageRequest) (*DeviceImageResponse, error) {
1545 return nil, status.Errorf(codes.Unimplemented, "method GetImageStatus not implemented")
1546}
1547func (*UnimplementedVolthaServiceServer) AbortImageUpgradeToDevice(ctx context.Context, req *DeviceImageRequest) (*DeviceImageResponse, error) {
1548 return nil, status.Errorf(codes.Unimplemented, "method AbortImageUpgradeToDevice not implemented")
1549}
1550func (*UnimplementedVolthaServiceServer) GetOnuImages(ctx context.Context, req *common.ID) (*OnuImages, error) {
1551 return nil, status.Errorf(codes.Unimplemented, "method GetOnuImages not implemented")
1552}
1553func (*UnimplementedVolthaServiceServer) ActivateImage(ctx context.Context, req *DeviceImageRequest) (*DeviceImageResponse, error) {
1554 return nil, status.Errorf(codes.Unimplemented, "method ActivateImage not implemented")
1555}
1556func (*UnimplementedVolthaServiceServer) CommitImage(ctx context.Context, req *DeviceImageRequest) (*DeviceImageResponse, error) {
1557 return nil, status.Errorf(codes.Unimplemented, "method CommitImage not implemented")
1558}
David K. Bainbridgec4bf5382021-04-08 16:06:54 +00001559func (*UnimplementedVolthaServiceServer) ListDevicePorts(ctx context.Context, req *common.ID) (*Ports, error) {
1560 return nil, status.Errorf(codes.Unimplemented, "method ListDevicePorts not implemented")
1561}
1562func (*UnimplementedVolthaServiceServer) ListDevicePmConfigs(ctx context.Context, req *common.ID) (*PmConfigs, error) {
1563 return nil, status.Errorf(codes.Unimplemented, "method ListDevicePmConfigs not implemented")
1564}
1565func (*UnimplementedVolthaServiceServer) UpdateDevicePmConfigs(ctx context.Context, req *PmConfigs) (*empty.Empty, error) {
1566 return nil, status.Errorf(codes.Unimplemented, "method UpdateDevicePmConfigs not implemented")
1567}
1568func (*UnimplementedVolthaServiceServer) ListDeviceFlows(ctx context.Context, req *common.ID) (*openflow_13.Flows, error) {
1569 return nil, status.Errorf(codes.Unimplemented, "method ListDeviceFlows not implemented")
1570}
1571func (*UnimplementedVolthaServiceServer) ListDeviceFlowGroups(ctx context.Context, req *common.ID) (*openflow_13.FlowGroups, error) {
1572 return nil, status.Errorf(codes.Unimplemented, "method ListDeviceFlowGroups not implemented")
1573}
1574func (*UnimplementedVolthaServiceServer) ListDeviceTypes(ctx context.Context, req *empty.Empty) (*DeviceTypes, error) {
1575 return nil, status.Errorf(codes.Unimplemented, "method ListDeviceTypes not implemented")
1576}
1577func (*UnimplementedVolthaServiceServer) GetDeviceType(ctx context.Context, req *common.ID) (*DeviceType, error) {
1578 return nil, status.Errorf(codes.Unimplemented, "method GetDeviceType not implemented")
1579}
David K. Bainbridgec4bf5382021-04-08 16:06:54 +00001580func (*UnimplementedVolthaServiceServer) StreamPacketsOut(srv VolthaService_StreamPacketsOutServer) error {
1581 return status.Errorf(codes.Unimplemented, "method StreamPacketsOut not implemented")
1582}
1583func (*UnimplementedVolthaServiceServer) ReceivePacketsIn(req *empty.Empty, srv VolthaService_ReceivePacketsInServer) error {
1584 return status.Errorf(codes.Unimplemented, "method ReceivePacketsIn not implemented")
1585}
1586func (*UnimplementedVolthaServiceServer) ReceiveChangeEvents(req *empty.Empty, srv VolthaService_ReceiveChangeEventsServer) error {
1587 return status.Errorf(codes.Unimplemented, "method ReceiveChangeEvents not implemented")
1588}
David K. Bainbridgec4bf5382021-04-08 16:06:54 +00001589func (*UnimplementedVolthaServiceServer) CreateEventFilter(ctx context.Context, req *EventFilter) (*EventFilter, error) {
1590 return nil, status.Errorf(codes.Unimplemented, "method CreateEventFilter not implemented")
1591}
1592func (*UnimplementedVolthaServiceServer) GetEventFilter(ctx context.Context, req *common.ID) (*EventFilters, error) {
1593 return nil, status.Errorf(codes.Unimplemented, "method GetEventFilter not implemented")
1594}
1595func (*UnimplementedVolthaServiceServer) UpdateEventFilter(ctx context.Context, req *EventFilter) (*EventFilter, error) {
1596 return nil, status.Errorf(codes.Unimplemented, "method UpdateEventFilter not implemented")
1597}
1598func (*UnimplementedVolthaServiceServer) DeleteEventFilter(ctx context.Context, req *EventFilter) (*empty.Empty, error) {
1599 return nil, status.Errorf(codes.Unimplemented, "method DeleteEventFilter not implemented")
1600}
1601func (*UnimplementedVolthaServiceServer) ListEventFilters(ctx context.Context, req *empty.Empty) (*EventFilters, error) {
1602 return nil, status.Errorf(codes.Unimplemented, "method ListEventFilters not implemented")
1603}
1604func (*UnimplementedVolthaServiceServer) GetImages(ctx context.Context, req *common.ID) (*Images, error) {
1605 return nil, status.Errorf(codes.Unimplemented, "method GetImages not implemented")
1606}
1607func (*UnimplementedVolthaServiceServer) SelfTest(ctx context.Context, req *common.ID) (*SelfTestResponse, error) {
1608 return nil, status.Errorf(codes.Unimplemented, "method SelfTest not implemented")
1609}
1610func (*UnimplementedVolthaServiceServer) GetMibDeviceData(ctx context.Context, req *common.ID) (*omci.MibDeviceData, error) {
1611 return nil, status.Errorf(codes.Unimplemented, "method GetMibDeviceData not implemented")
1612}
1613func (*UnimplementedVolthaServiceServer) GetAlarmDeviceData(ctx context.Context, req *common.ID) (*omci.AlarmDeviceData, error) {
1614 return nil, status.Errorf(codes.Unimplemented, "method GetAlarmDeviceData not implemented")
1615}
1616func (*UnimplementedVolthaServiceServer) SimulateAlarm(ctx context.Context, req *SimulateAlarmRequest) (*common.OperationResp, error) {
1617 return nil, status.Errorf(codes.Unimplemented, "method SimulateAlarm not implemented")
1618}
David K. Bainbridgec4bf5382021-04-08 16:06:54 +00001619func (*UnimplementedVolthaServiceServer) EnablePort(ctx context.Context, req *Port) (*empty.Empty, error) {
1620 return nil, status.Errorf(codes.Unimplemented, "method EnablePort not implemented")
1621}
1622func (*UnimplementedVolthaServiceServer) DisablePort(ctx context.Context, req *Port) (*empty.Empty, error) {
1623 return nil, status.Errorf(codes.Unimplemented, "method DisablePort not implemented")
1624}
khenaidoo4c6543e2021-10-19 17:25:58 -04001625func (*UnimplementedVolthaServiceServer) GetExtValue(ctx context.Context, req *extension.ValueSpecifier) (*extension.ReturnValues, error) {
David K. Bainbridgec4bf5382021-04-08 16:06:54 +00001626 return nil, status.Errorf(codes.Unimplemented, "method GetExtValue not implemented")
1627}
khenaidoo4c6543e2021-10-19 17:25:58 -04001628func (*UnimplementedVolthaServiceServer) SetExtValue(ctx context.Context, req *extension.ValueSet) (*empty.Empty, error) {
David K. Bainbridgec4bf5382021-04-08 16:06:54 +00001629 return nil, status.Errorf(codes.Unimplemented, "method SetExtValue not implemented")
1630}
khenaidoo4c6543e2021-10-19 17:25:58 -04001631func (*UnimplementedVolthaServiceServer) StartOmciTestAction(ctx context.Context, req *omci.OmciTestRequest) (*omci.TestResponse, error) {
David K. Bainbridgec4bf5382021-04-08 16:06:54 +00001632 return nil, status.Errorf(codes.Unimplemented, "method StartOmciTestAction not implemented")
1633}
1634
William Kurkian1b363f42019-03-12 15:28:12 -04001635func RegisterVolthaServiceServer(s *grpc.Server, srv VolthaServiceServer) {
1636 s.RegisterService(&_VolthaService_serviceDesc, srv)
1637}
1638
William Kurkian1b363f42019-03-12 15:28:12 -04001639func _VolthaService_GetVoltha_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
1640 in := new(empty.Empty)
1641 if err := dec(in); err != nil {
1642 return nil, err
1643 }
1644 if interceptor == nil {
1645 return srv.(VolthaServiceServer).GetVoltha(ctx, in)
1646 }
1647 info := &grpc.UnaryServerInfo{
1648 Server: srv,
1649 FullMethod: "/voltha.VolthaService/GetVoltha",
1650 }
1651 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
1652 return srv.(VolthaServiceServer).GetVoltha(ctx, req.(*empty.Empty))
1653 }
1654 return interceptor(ctx, in, info, handler)
1655}
1656
1657func _VolthaService_ListCoreInstances_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
1658 in := new(empty.Empty)
1659 if err := dec(in); err != nil {
1660 return nil, err
1661 }
1662 if interceptor == nil {
1663 return srv.(VolthaServiceServer).ListCoreInstances(ctx, in)
1664 }
1665 info := &grpc.UnaryServerInfo{
1666 Server: srv,
1667 FullMethod: "/voltha.VolthaService/ListCoreInstances",
1668 }
1669 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
1670 return srv.(VolthaServiceServer).ListCoreInstances(ctx, req.(*empty.Empty))
1671 }
1672 return interceptor(ctx, in, info, handler)
1673}
1674
1675func _VolthaService_GetCoreInstance_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
1676 in := new(common.ID)
1677 if err := dec(in); err != nil {
1678 return nil, err
1679 }
1680 if interceptor == nil {
1681 return srv.(VolthaServiceServer).GetCoreInstance(ctx, in)
1682 }
1683 info := &grpc.UnaryServerInfo{
1684 Server: srv,
1685 FullMethod: "/voltha.VolthaService/GetCoreInstance",
1686 }
1687 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
1688 return srv.(VolthaServiceServer).GetCoreInstance(ctx, req.(*common.ID))
1689 }
1690 return interceptor(ctx, in, info, handler)
1691}
1692
1693func _VolthaService_ListAdapters_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
1694 in := new(empty.Empty)
1695 if err := dec(in); err != nil {
1696 return nil, err
1697 }
1698 if interceptor == nil {
1699 return srv.(VolthaServiceServer).ListAdapters(ctx, in)
1700 }
1701 info := &grpc.UnaryServerInfo{
1702 Server: srv,
1703 FullMethod: "/voltha.VolthaService/ListAdapters",
1704 }
1705 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
1706 return srv.(VolthaServiceServer).ListAdapters(ctx, req.(*empty.Empty))
1707 }
1708 return interceptor(ctx, in, info, handler)
1709}
1710
1711func _VolthaService_ListLogicalDevices_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
1712 in := new(empty.Empty)
1713 if err := dec(in); err != nil {
1714 return nil, err
1715 }
1716 if interceptor == nil {
1717 return srv.(VolthaServiceServer).ListLogicalDevices(ctx, in)
1718 }
1719 info := &grpc.UnaryServerInfo{
1720 Server: srv,
1721 FullMethod: "/voltha.VolthaService/ListLogicalDevices",
1722 }
1723 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
1724 return srv.(VolthaServiceServer).ListLogicalDevices(ctx, req.(*empty.Empty))
1725 }
1726 return interceptor(ctx, in, info, handler)
1727}
1728
1729func _VolthaService_GetLogicalDevice_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
1730 in := new(common.ID)
1731 if err := dec(in); err != nil {
1732 return nil, err
1733 }
1734 if interceptor == nil {
1735 return srv.(VolthaServiceServer).GetLogicalDevice(ctx, in)
1736 }
1737 info := &grpc.UnaryServerInfo{
1738 Server: srv,
1739 FullMethod: "/voltha.VolthaService/GetLogicalDevice",
1740 }
1741 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
1742 return srv.(VolthaServiceServer).GetLogicalDevice(ctx, req.(*common.ID))
1743 }
1744 return interceptor(ctx, in, info, handler)
1745}
1746
1747func _VolthaService_ListLogicalDevicePorts_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
1748 in := new(common.ID)
1749 if err := dec(in); err != nil {
1750 return nil, err
1751 }
1752 if interceptor == nil {
1753 return srv.(VolthaServiceServer).ListLogicalDevicePorts(ctx, in)
1754 }
1755 info := &grpc.UnaryServerInfo{
1756 Server: srv,
1757 FullMethod: "/voltha.VolthaService/ListLogicalDevicePorts",
1758 }
1759 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
1760 return srv.(VolthaServiceServer).ListLogicalDevicePorts(ctx, req.(*common.ID))
1761 }
1762 return interceptor(ctx, in, info, handler)
1763}
1764
1765func _VolthaService_GetLogicalDevicePort_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
1766 in := new(LogicalPortId)
1767 if err := dec(in); err != nil {
1768 return nil, err
1769 }
1770 if interceptor == nil {
1771 return srv.(VolthaServiceServer).GetLogicalDevicePort(ctx, in)
1772 }
1773 info := &grpc.UnaryServerInfo{
1774 Server: srv,
1775 FullMethod: "/voltha.VolthaService/GetLogicalDevicePort",
1776 }
1777 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
1778 return srv.(VolthaServiceServer).GetLogicalDevicePort(ctx, req.(*LogicalPortId))
1779 }
1780 return interceptor(ctx, in, info, handler)
1781}
1782
1783func _VolthaService_EnableLogicalDevicePort_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
1784 in := new(LogicalPortId)
1785 if err := dec(in); err != nil {
1786 return nil, err
1787 }
1788 if interceptor == nil {
1789 return srv.(VolthaServiceServer).EnableLogicalDevicePort(ctx, in)
1790 }
1791 info := &grpc.UnaryServerInfo{
1792 Server: srv,
1793 FullMethod: "/voltha.VolthaService/EnableLogicalDevicePort",
1794 }
1795 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
1796 return srv.(VolthaServiceServer).EnableLogicalDevicePort(ctx, req.(*LogicalPortId))
1797 }
1798 return interceptor(ctx, in, info, handler)
1799}
1800
1801func _VolthaService_DisableLogicalDevicePort_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
1802 in := new(LogicalPortId)
1803 if err := dec(in); err != nil {
1804 return nil, err
1805 }
1806 if interceptor == nil {
1807 return srv.(VolthaServiceServer).DisableLogicalDevicePort(ctx, in)
1808 }
1809 info := &grpc.UnaryServerInfo{
1810 Server: srv,
1811 FullMethod: "/voltha.VolthaService/DisableLogicalDevicePort",
1812 }
1813 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
1814 return srv.(VolthaServiceServer).DisableLogicalDevicePort(ctx, req.(*LogicalPortId))
1815 }
1816 return interceptor(ctx, in, info, handler)
1817}
1818
1819func _VolthaService_ListLogicalDeviceFlows_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
1820 in := new(common.ID)
1821 if err := dec(in); err != nil {
1822 return nil, err
1823 }
1824 if interceptor == nil {
1825 return srv.(VolthaServiceServer).ListLogicalDeviceFlows(ctx, in)
1826 }
1827 info := &grpc.UnaryServerInfo{
1828 Server: srv,
1829 FullMethod: "/voltha.VolthaService/ListLogicalDeviceFlows",
1830 }
1831 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
1832 return srv.(VolthaServiceServer).ListLogicalDeviceFlows(ctx, req.(*common.ID))
1833 }
1834 return interceptor(ctx, in, info, handler)
1835}
1836
1837func _VolthaService_UpdateLogicalDeviceFlowTable_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
1838 in := new(openflow_13.FlowTableUpdate)
1839 if err := dec(in); err != nil {
1840 return nil, err
1841 }
1842 if interceptor == nil {
1843 return srv.(VolthaServiceServer).UpdateLogicalDeviceFlowTable(ctx, in)
1844 }
1845 info := &grpc.UnaryServerInfo{
1846 Server: srv,
1847 FullMethod: "/voltha.VolthaService/UpdateLogicalDeviceFlowTable",
1848 }
1849 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
1850 return srv.(VolthaServiceServer).UpdateLogicalDeviceFlowTable(ctx, req.(*openflow_13.FlowTableUpdate))
1851 }
1852 return interceptor(ctx, in, info, handler)
1853}
1854
1855func _VolthaService_UpdateLogicalDeviceMeterTable_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
1856 in := new(openflow_13.MeterModUpdate)
1857 if err := dec(in); err != nil {
1858 return nil, err
1859 }
1860 if interceptor == nil {
1861 return srv.(VolthaServiceServer).UpdateLogicalDeviceMeterTable(ctx, in)
1862 }
1863 info := &grpc.UnaryServerInfo{
1864 Server: srv,
1865 FullMethod: "/voltha.VolthaService/UpdateLogicalDeviceMeterTable",
1866 }
1867 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
1868 return srv.(VolthaServiceServer).UpdateLogicalDeviceMeterTable(ctx, req.(*openflow_13.MeterModUpdate))
1869 }
1870 return interceptor(ctx, in, info, handler)
1871}
1872
Abhilash Laxmeshwardfbb74d2019-07-23 08:03:08 -04001873func _VolthaService_ListLogicalDeviceMeters_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
William Kurkian1b363f42019-03-12 15:28:12 -04001874 in := new(common.ID)
1875 if err := dec(in); err != nil {
1876 return nil, err
1877 }
1878 if interceptor == nil {
Abhilash Laxmeshwardfbb74d2019-07-23 08:03:08 -04001879 return srv.(VolthaServiceServer).ListLogicalDeviceMeters(ctx, in)
William Kurkian1b363f42019-03-12 15:28:12 -04001880 }
1881 info := &grpc.UnaryServerInfo{
1882 Server: srv,
Abhilash Laxmeshwardfbb74d2019-07-23 08:03:08 -04001883 FullMethod: "/voltha.VolthaService/ListLogicalDeviceMeters",
William Kurkian1b363f42019-03-12 15:28:12 -04001884 }
1885 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
Abhilash Laxmeshwardfbb74d2019-07-23 08:03:08 -04001886 return srv.(VolthaServiceServer).ListLogicalDeviceMeters(ctx, req.(*common.ID))
William Kurkian1b363f42019-03-12 15:28:12 -04001887 }
1888 return interceptor(ctx, in, info, handler)
1889}
1890
1891func _VolthaService_ListLogicalDeviceFlowGroups_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
1892 in := new(common.ID)
1893 if err := dec(in); err != nil {
1894 return nil, err
1895 }
1896 if interceptor == nil {
1897 return srv.(VolthaServiceServer).ListLogicalDeviceFlowGroups(ctx, in)
1898 }
1899 info := &grpc.UnaryServerInfo{
1900 Server: srv,
1901 FullMethod: "/voltha.VolthaService/ListLogicalDeviceFlowGroups",
1902 }
1903 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
1904 return srv.(VolthaServiceServer).ListLogicalDeviceFlowGroups(ctx, req.(*common.ID))
1905 }
1906 return interceptor(ctx, in, info, handler)
1907}
1908
1909func _VolthaService_UpdateLogicalDeviceFlowGroupTable_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
1910 in := new(openflow_13.FlowGroupTableUpdate)
1911 if err := dec(in); err != nil {
1912 return nil, err
1913 }
1914 if interceptor == nil {
1915 return srv.(VolthaServiceServer).UpdateLogicalDeviceFlowGroupTable(ctx, in)
1916 }
1917 info := &grpc.UnaryServerInfo{
1918 Server: srv,
1919 FullMethod: "/voltha.VolthaService/UpdateLogicalDeviceFlowGroupTable",
1920 }
1921 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
1922 return srv.(VolthaServiceServer).UpdateLogicalDeviceFlowGroupTable(ctx, req.(*openflow_13.FlowGroupTableUpdate))
1923 }
1924 return interceptor(ctx, in, info, handler)
1925}
1926
1927func _VolthaService_ListDevices_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
1928 in := new(empty.Empty)
1929 if err := dec(in); err != nil {
1930 return nil, err
1931 }
1932 if interceptor == nil {
1933 return srv.(VolthaServiceServer).ListDevices(ctx, in)
1934 }
1935 info := &grpc.UnaryServerInfo{
1936 Server: srv,
1937 FullMethod: "/voltha.VolthaService/ListDevices",
1938 }
1939 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
1940 return srv.(VolthaServiceServer).ListDevices(ctx, req.(*empty.Empty))
1941 }
1942 return interceptor(ctx, in, info, handler)
1943}
1944
1945func _VolthaService_ListDeviceIds_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
1946 in := new(empty.Empty)
1947 if err := dec(in); err != nil {
1948 return nil, err
1949 }
1950 if interceptor == nil {
1951 return srv.(VolthaServiceServer).ListDeviceIds(ctx, in)
1952 }
1953 info := &grpc.UnaryServerInfo{
1954 Server: srv,
1955 FullMethod: "/voltha.VolthaService/ListDeviceIds",
1956 }
1957 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
1958 return srv.(VolthaServiceServer).ListDeviceIds(ctx, req.(*empty.Empty))
1959 }
1960 return interceptor(ctx, in, info, handler)
1961}
1962
1963func _VolthaService_ReconcileDevices_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
1964 in := new(common.IDs)
1965 if err := dec(in); err != nil {
1966 return nil, err
1967 }
1968 if interceptor == nil {
1969 return srv.(VolthaServiceServer).ReconcileDevices(ctx, in)
1970 }
1971 info := &grpc.UnaryServerInfo{
1972 Server: srv,
1973 FullMethod: "/voltha.VolthaService/ReconcileDevices",
1974 }
1975 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
1976 return srv.(VolthaServiceServer).ReconcileDevices(ctx, req.(*common.IDs))
1977 }
1978 return interceptor(ctx, in, info, handler)
1979}
1980
1981func _VolthaService_GetDevice_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
1982 in := new(common.ID)
1983 if err := dec(in); err != nil {
1984 return nil, err
1985 }
1986 if interceptor == nil {
1987 return srv.(VolthaServiceServer).GetDevice(ctx, in)
1988 }
1989 info := &grpc.UnaryServerInfo{
1990 Server: srv,
1991 FullMethod: "/voltha.VolthaService/GetDevice",
1992 }
1993 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
1994 return srv.(VolthaServiceServer).GetDevice(ctx, req.(*common.ID))
1995 }
1996 return interceptor(ctx, in, info, handler)
1997}
1998
1999func _VolthaService_CreateDevice_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
2000 in := new(Device)
2001 if err := dec(in); err != nil {
2002 return nil, err
2003 }
2004 if interceptor == nil {
2005 return srv.(VolthaServiceServer).CreateDevice(ctx, in)
2006 }
2007 info := &grpc.UnaryServerInfo{
2008 Server: srv,
2009 FullMethod: "/voltha.VolthaService/CreateDevice",
2010 }
2011 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
2012 return srv.(VolthaServiceServer).CreateDevice(ctx, req.(*Device))
2013 }
2014 return interceptor(ctx, in, info, handler)
2015}
2016
2017func _VolthaService_EnableDevice_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
2018 in := new(common.ID)
2019 if err := dec(in); err != nil {
2020 return nil, err
2021 }
2022 if interceptor == nil {
2023 return srv.(VolthaServiceServer).EnableDevice(ctx, in)
2024 }
2025 info := &grpc.UnaryServerInfo{
2026 Server: srv,
2027 FullMethod: "/voltha.VolthaService/EnableDevice",
2028 }
2029 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
2030 return srv.(VolthaServiceServer).EnableDevice(ctx, req.(*common.ID))
2031 }
2032 return interceptor(ctx, in, info, handler)
2033}
2034
2035func _VolthaService_DisableDevice_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
2036 in := new(common.ID)
2037 if err := dec(in); err != nil {
2038 return nil, err
2039 }
2040 if interceptor == nil {
2041 return srv.(VolthaServiceServer).DisableDevice(ctx, in)
2042 }
2043 info := &grpc.UnaryServerInfo{
2044 Server: srv,
2045 FullMethod: "/voltha.VolthaService/DisableDevice",
2046 }
2047 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
2048 return srv.(VolthaServiceServer).DisableDevice(ctx, req.(*common.ID))
2049 }
2050 return interceptor(ctx, in, info, handler)
2051}
2052
2053func _VolthaService_RebootDevice_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
2054 in := new(common.ID)
2055 if err := dec(in); err != nil {
2056 return nil, err
2057 }
2058 if interceptor == nil {
2059 return srv.(VolthaServiceServer).RebootDevice(ctx, in)
2060 }
2061 info := &grpc.UnaryServerInfo{
2062 Server: srv,
2063 FullMethod: "/voltha.VolthaService/RebootDevice",
2064 }
2065 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
2066 return srv.(VolthaServiceServer).RebootDevice(ctx, req.(*common.ID))
2067 }
2068 return interceptor(ctx, in, info, handler)
2069}
2070
2071func _VolthaService_DeleteDevice_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
2072 in := new(common.ID)
2073 if err := dec(in); err != nil {
2074 return nil, err
2075 }
2076 if interceptor == nil {
2077 return srv.(VolthaServiceServer).DeleteDevice(ctx, in)
2078 }
2079 info := &grpc.UnaryServerInfo{
2080 Server: srv,
2081 FullMethod: "/voltha.VolthaService/DeleteDevice",
2082 }
2083 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
2084 return srv.(VolthaServiceServer).DeleteDevice(ctx, req.(*common.ID))
2085 }
2086 return interceptor(ctx, in, info, handler)
2087}
2088
Himani Chawla503b7ce2020-10-07 13:20:03 +05302089func _VolthaService_ForceDeleteDevice_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
2090 in := new(common.ID)
2091 if err := dec(in); err != nil {
2092 return nil, err
2093 }
2094 if interceptor == nil {
2095 return srv.(VolthaServiceServer).ForceDeleteDevice(ctx, in)
2096 }
2097 info := &grpc.UnaryServerInfo{
2098 Server: srv,
2099 FullMethod: "/voltha.VolthaService/ForceDeleteDevice",
2100 }
2101 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
2102 return srv.(VolthaServiceServer).ForceDeleteDevice(ctx, req.(*common.ID))
2103 }
2104 return interceptor(ctx, in, info, handler)
2105}
2106
William Kurkian1b363f42019-03-12 15:28:12 -04002107func _VolthaService_DownloadImage_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
2108 in := new(ImageDownload)
2109 if err := dec(in); err != nil {
2110 return nil, err
2111 }
2112 if interceptor == nil {
2113 return srv.(VolthaServiceServer).DownloadImage(ctx, in)
2114 }
2115 info := &grpc.UnaryServerInfo{
2116 Server: srv,
2117 FullMethod: "/voltha.VolthaService/DownloadImage",
2118 }
2119 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
2120 return srv.(VolthaServiceServer).DownloadImage(ctx, req.(*ImageDownload))
2121 }
2122 return interceptor(ctx, in, info, handler)
2123}
2124
2125func _VolthaService_GetImageDownloadStatus_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
2126 in := new(ImageDownload)
2127 if err := dec(in); err != nil {
2128 return nil, err
2129 }
2130 if interceptor == nil {
2131 return srv.(VolthaServiceServer).GetImageDownloadStatus(ctx, in)
2132 }
2133 info := &grpc.UnaryServerInfo{
2134 Server: srv,
2135 FullMethod: "/voltha.VolthaService/GetImageDownloadStatus",
2136 }
2137 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
2138 return srv.(VolthaServiceServer).GetImageDownloadStatus(ctx, req.(*ImageDownload))
2139 }
2140 return interceptor(ctx, in, info, handler)
2141}
2142
2143func _VolthaService_GetImageDownload_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
2144 in := new(ImageDownload)
2145 if err := dec(in); err != nil {
2146 return nil, err
2147 }
2148 if interceptor == nil {
2149 return srv.(VolthaServiceServer).GetImageDownload(ctx, in)
2150 }
2151 info := &grpc.UnaryServerInfo{
2152 Server: srv,
2153 FullMethod: "/voltha.VolthaService/GetImageDownload",
2154 }
2155 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
2156 return srv.(VolthaServiceServer).GetImageDownload(ctx, req.(*ImageDownload))
2157 }
2158 return interceptor(ctx, in, info, handler)
2159}
2160
2161func _VolthaService_ListImageDownloads_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
2162 in := new(common.ID)
2163 if err := dec(in); err != nil {
2164 return nil, err
2165 }
2166 if interceptor == nil {
2167 return srv.(VolthaServiceServer).ListImageDownloads(ctx, in)
2168 }
2169 info := &grpc.UnaryServerInfo{
2170 Server: srv,
2171 FullMethod: "/voltha.VolthaService/ListImageDownloads",
2172 }
2173 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
2174 return srv.(VolthaServiceServer).ListImageDownloads(ctx, req.(*common.ID))
2175 }
2176 return interceptor(ctx, in, info, handler)
2177}
2178
2179func _VolthaService_CancelImageDownload_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
2180 in := new(ImageDownload)
2181 if err := dec(in); err != nil {
2182 return nil, err
2183 }
2184 if interceptor == nil {
2185 return srv.(VolthaServiceServer).CancelImageDownload(ctx, in)
2186 }
2187 info := &grpc.UnaryServerInfo{
2188 Server: srv,
2189 FullMethod: "/voltha.VolthaService/CancelImageDownload",
2190 }
2191 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
2192 return srv.(VolthaServiceServer).CancelImageDownload(ctx, req.(*ImageDownload))
2193 }
2194 return interceptor(ctx, in, info, handler)
2195}
2196
2197func _VolthaService_ActivateImageUpdate_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
2198 in := new(ImageDownload)
2199 if err := dec(in); err != nil {
2200 return nil, err
2201 }
2202 if interceptor == nil {
2203 return srv.(VolthaServiceServer).ActivateImageUpdate(ctx, in)
2204 }
2205 info := &grpc.UnaryServerInfo{
2206 Server: srv,
2207 FullMethod: "/voltha.VolthaService/ActivateImageUpdate",
2208 }
2209 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
2210 return srv.(VolthaServiceServer).ActivateImageUpdate(ctx, req.(*ImageDownload))
2211 }
2212 return interceptor(ctx, in, info, handler)
2213}
2214
2215func _VolthaService_RevertImageUpdate_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
2216 in := new(ImageDownload)
2217 if err := dec(in); err != nil {
2218 return nil, err
2219 }
2220 if interceptor == nil {
2221 return srv.(VolthaServiceServer).RevertImageUpdate(ctx, in)
2222 }
2223 info := &grpc.UnaryServerInfo{
2224 Server: srv,
2225 FullMethod: "/voltha.VolthaService/RevertImageUpdate",
2226 }
2227 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
2228 return srv.(VolthaServiceServer).RevertImageUpdate(ctx, req.(*ImageDownload))
2229 }
2230 return interceptor(ctx, in, info, handler)
2231}
2232
Andrea Campanella9e94e8a2021-01-19 15:21:25 +01002233func _VolthaService_DownloadImageToDevice_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
2234 in := new(DeviceImageDownloadRequest)
2235 if err := dec(in); err != nil {
2236 return nil, err
2237 }
2238 if interceptor == nil {
2239 return srv.(VolthaServiceServer).DownloadImageToDevice(ctx, in)
2240 }
2241 info := &grpc.UnaryServerInfo{
2242 Server: srv,
2243 FullMethod: "/voltha.VolthaService/DownloadImageToDevice",
2244 }
2245 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
2246 return srv.(VolthaServiceServer).DownloadImageToDevice(ctx, req.(*DeviceImageDownloadRequest))
2247 }
2248 return interceptor(ctx, in, info, handler)
2249}
2250
2251func _VolthaService_GetImageStatus_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
2252 in := new(DeviceImageRequest)
2253 if err := dec(in); err != nil {
2254 return nil, err
2255 }
2256 if interceptor == nil {
2257 return srv.(VolthaServiceServer).GetImageStatus(ctx, in)
2258 }
2259 info := &grpc.UnaryServerInfo{
2260 Server: srv,
2261 FullMethod: "/voltha.VolthaService/GetImageStatus",
2262 }
2263 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
2264 return srv.(VolthaServiceServer).GetImageStatus(ctx, req.(*DeviceImageRequest))
2265 }
2266 return interceptor(ctx, in, info, handler)
2267}
2268
2269func _VolthaService_AbortImageUpgradeToDevice_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
2270 in := new(DeviceImageRequest)
2271 if err := dec(in); err != nil {
2272 return nil, err
2273 }
2274 if interceptor == nil {
2275 return srv.(VolthaServiceServer).AbortImageUpgradeToDevice(ctx, in)
2276 }
2277 info := &grpc.UnaryServerInfo{
2278 Server: srv,
2279 FullMethod: "/voltha.VolthaService/AbortImageUpgradeToDevice",
2280 }
2281 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
2282 return srv.(VolthaServiceServer).AbortImageUpgradeToDevice(ctx, req.(*DeviceImageRequest))
2283 }
2284 return interceptor(ctx, in, info, handler)
2285}
2286
2287func _VolthaService_GetOnuImages_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
2288 in := new(common.ID)
2289 if err := dec(in); err != nil {
2290 return nil, err
2291 }
2292 if interceptor == nil {
2293 return srv.(VolthaServiceServer).GetOnuImages(ctx, in)
2294 }
2295 info := &grpc.UnaryServerInfo{
2296 Server: srv,
2297 FullMethod: "/voltha.VolthaService/GetOnuImages",
2298 }
2299 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
2300 return srv.(VolthaServiceServer).GetOnuImages(ctx, req.(*common.ID))
2301 }
2302 return interceptor(ctx, in, info, handler)
2303}
2304
2305func _VolthaService_ActivateImage_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
2306 in := new(DeviceImageRequest)
2307 if err := dec(in); err != nil {
2308 return nil, err
2309 }
2310 if interceptor == nil {
2311 return srv.(VolthaServiceServer).ActivateImage(ctx, in)
2312 }
2313 info := &grpc.UnaryServerInfo{
2314 Server: srv,
2315 FullMethod: "/voltha.VolthaService/ActivateImage",
2316 }
2317 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
2318 return srv.(VolthaServiceServer).ActivateImage(ctx, req.(*DeviceImageRequest))
2319 }
2320 return interceptor(ctx, in, info, handler)
2321}
2322
2323func _VolthaService_CommitImage_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
2324 in := new(DeviceImageRequest)
2325 if err := dec(in); err != nil {
2326 return nil, err
2327 }
2328 if interceptor == nil {
2329 return srv.(VolthaServiceServer).CommitImage(ctx, in)
2330 }
2331 info := &grpc.UnaryServerInfo{
2332 Server: srv,
2333 FullMethod: "/voltha.VolthaService/CommitImage",
2334 }
2335 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
2336 return srv.(VolthaServiceServer).CommitImage(ctx, req.(*DeviceImageRequest))
2337 }
2338 return interceptor(ctx, in, info, handler)
2339}
2340
William Kurkian1b363f42019-03-12 15:28:12 -04002341func _VolthaService_ListDevicePorts_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
2342 in := new(common.ID)
2343 if err := dec(in); err != nil {
2344 return nil, err
2345 }
2346 if interceptor == nil {
2347 return srv.(VolthaServiceServer).ListDevicePorts(ctx, in)
2348 }
2349 info := &grpc.UnaryServerInfo{
2350 Server: srv,
2351 FullMethod: "/voltha.VolthaService/ListDevicePorts",
2352 }
2353 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
2354 return srv.(VolthaServiceServer).ListDevicePorts(ctx, req.(*common.ID))
2355 }
2356 return interceptor(ctx, in, info, handler)
2357}
2358
2359func _VolthaService_ListDevicePmConfigs_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
2360 in := new(common.ID)
2361 if err := dec(in); err != nil {
2362 return nil, err
2363 }
2364 if interceptor == nil {
2365 return srv.(VolthaServiceServer).ListDevicePmConfigs(ctx, in)
2366 }
2367 info := &grpc.UnaryServerInfo{
2368 Server: srv,
2369 FullMethod: "/voltha.VolthaService/ListDevicePmConfigs",
2370 }
2371 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
2372 return srv.(VolthaServiceServer).ListDevicePmConfigs(ctx, req.(*common.ID))
2373 }
2374 return interceptor(ctx, in, info, handler)
2375}
2376
2377func _VolthaService_UpdateDevicePmConfigs_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
2378 in := new(PmConfigs)
2379 if err := dec(in); err != nil {
2380 return nil, err
2381 }
2382 if interceptor == nil {
2383 return srv.(VolthaServiceServer).UpdateDevicePmConfigs(ctx, in)
2384 }
2385 info := &grpc.UnaryServerInfo{
2386 Server: srv,
2387 FullMethod: "/voltha.VolthaService/UpdateDevicePmConfigs",
2388 }
2389 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
2390 return srv.(VolthaServiceServer).UpdateDevicePmConfigs(ctx, req.(*PmConfigs))
2391 }
2392 return interceptor(ctx, in, info, handler)
2393}
2394
2395func _VolthaService_ListDeviceFlows_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
2396 in := new(common.ID)
2397 if err := dec(in); err != nil {
2398 return nil, err
2399 }
2400 if interceptor == nil {
2401 return srv.(VolthaServiceServer).ListDeviceFlows(ctx, in)
2402 }
2403 info := &grpc.UnaryServerInfo{
2404 Server: srv,
2405 FullMethod: "/voltha.VolthaService/ListDeviceFlows",
2406 }
2407 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
2408 return srv.(VolthaServiceServer).ListDeviceFlows(ctx, req.(*common.ID))
2409 }
2410 return interceptor(ctx, in, info, handler)
2411}
2412
2413func _VolthaService_ListDeviceFlowGroups_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
2414 in := new(common.ID)
2415 if err := dec(in); err != nil {
2416 return nil, err
2417 }
2418 if interceptor == nil {
2419 return srv.(VolthaServiceServer).ListDeviceFlowGroups(ctx, in)
2420 }
2421 info := &grpc.UnaryServerInfo{
2422 Server: srv,
2423 FullMethod: "/voltha.VolthaService/ListDeviceFlowGroups",
2424 }
2425 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
2426 return srv.(VolthaServiceServer).ListDeviceFlowGroups(ctx, req.(*common.ID))
2427 }
2428 return interceptor(ctx, in, info, handler)
2429}
2430
2431func _VolthaService_ListDeviceTypes_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
2432 in := new(empty.Empty)
2433 if err := dec(in); err != nil {
2434 return nil, err
2435 }
2436 if interceptor == nil {
2437 return srv.(VolthaServiceServer).ListDeviceTypes(ctx, in)
2438 }
2439 info := &grpc.UnaryServerInfo{
2440 Server: srv,
2441 FullMethod: "/voltha.VolthaService/ListDeviceTypes",
2442 }
2443 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
2444 return srv.(VolthaServiceServer).ListDeviceTypes(ctx, req.(*empty.Empty))
2445 }
2446 return interceptor(ctx, in, info, handler)
2447}
2448
2449func _VolthaService_GetDeviceType_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
2450 in := new(common.ID)
2451 if err := dec(in); err != nil {
2452 return nil, err
2453 }
2454 if interceptor == nil {
2455 return srv.(VolthaServiceServer).GetDeviceType(ctx, in)
2456 }
2457 info := &grpc.UnaryServerInfo{
2458 Server: srv,
2459 FullMethod: "/voltha.VolthaService/GetDeviceType",
2460 }
2461 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
2462 return srv.(VolthaServiceServer).GetDeviceType(ctx, req.(*common.ID))
2463 }
2464 return interceptor(ctx, in, info, handler)
2465}
2466
William Kurkian1b363f42019-03-12 15:28:12 -04002467func _VolthaService_StreamPacketsOut_Handler(srv interface{}, stream grpc.ServerStream) error {
2468 return srv.(VolthaServiceServer).StreamPacketsOut(&volthaServiceStreamPacketsOutServer{stream})
2469}
2470
2471type VolthaService_StreamPacketsOutServer interface {
2472 SendAndClose(*empty.Empty) error
2473 Recv() (*openflow_13.PacketOut, error)
2474 grpc.ServerStream
2475}
2476
2477type volthaServiceStreamPacketsOutServer struct {
2478 grpc.ServerStream
2479}
2480
2481func (x *volthaServiceStreamPacketsOutServer) SendAndClose(m *empty.Empty) error {
2482 return x.ServerStream.SendMsg(m)
2483}
2484
2485func (x *volthaServiceStreamPacketsOutServer) Recv() (*openflow_13.PacketOut, error) {
2486 m := new(openflow_13.PacketOut)
2487 if err := x.ServerStream.RecvMsg(m); err != nil {
2488 return nil, err
2489 }
2490 return m, nil
2491}
2492
2493func _VolthaService_ReceivePacketsIn_Handler(srv interface{}, stream grpc.ServerStream) error {
2494 m := new(empty.Empty)
2495 if err := stream.RecvMsg(m); err != nil {
2496 return err
2497 }
2498 return srv.(VolthaServiceServer).ReceivePacketsIn(m, &volthaServiceReceivePacketsInServer{stream})
2499}
2500
2501type VolthaService_ReceivePacketsInServer interface {
2502 Send(*openflow_13.PacketIn) error
2503 grpc.ServerStream
2504}
2505
2506type volthaServiceReceivePacketsInServer struct {
2507 grpc.ServerStream
2508}
2509
2510func (x *volthaServiceReceivePacketsInServer) Send(m *openflow_13.PacketIn) error {
2511 return x.ServerStream.SendMsg(m)
2512}
2513
2514func _VolthaService_ReceiveChangeEvents_Handler(srv interface{}, stream grpc.ServerStream) error {
2515 m := new(empty.Empty)
2516 if err := stream.RecvMsg(m); err != nil {
2517 return err
2518 }
2519 return srv.(VolthaServiceServer).ReceiveChangeEvents(m, &volthaServiceReceiveChangeEventsServer{stream})
2520}
2521
2522type VolthaService_ReceiveChangeEventsServer interface {
2523 Send(*openflow_13.ChangeEvent) error
2524 grpc.ServerStream
2525}
2526
2527type volthaServiceReceiveChangeEventsServer struct {
2528 grpc.ServerStream
2529}
2530
2531func (x *volthaServiceReceiveChangeEventsServer) Send(m *openflow_13.ChangeEvent) error {
2532 return x.ServerStream.SendMsg(m)
2533}
2534
Devmalya Paul96a2c9e2019-11-06 07:17:44 +00002535func _VolthaService_CreateEventFilter_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
2536 in := new(EventFilter)
William Kurkian1b363f42019-03-12 15:28:12 -04002537 if err := dec(in); err != nil {
2538 return nil, err
2539 }
2540 if interceptor == nil {
Devmalya Paul96a2c9e2019-11-06 07:17:44 +00002541 return srv.(VolthaServiceServer).CreateEventFilter(ctx, in)
William Kurkian1b363f42019-03-12 15:28:12 -04002542 }
2543 info := &grpc.UnaryServerInfo{
2544 Server: srv,
Devmalya Paul96a2c9e2019-11-06 07:17:44 +00002545 FullMethod: "/voltha.VolthaService/CreateEventFilter",
William Kurkian1b363f42019-03-12 15:28:12 -04002546 }
2547 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
Devmalya Paul96a2c9e2019-11-06 07:17:44 +00002548 return srv.(VolthaServiceServer).CreateEventFilter(ctx, req.(*EventFilter))
William Kurkian1b363f42019-03-12 15:28:12 -04002549 }
2550 return interceptor(ctx, in, info, handler)
2551}
2552
Devmalya Paul96a2c9e2019-11-06 07:17:44 +00002553func _VolthaService_GetEventFilter_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
William Kurkian1b363f42019-03-12 15:28:12 -04002554 in := new(common.ID)
2555 if err := dec(in); err != nil {
2556 return nil, err
2557 }
2558 if interceptor == nil {
Devmalya Paul96a2c9e2019-11-06 07:17:44 +00002559 return srv.(VolthaServiceServer).GetEventFilter(ctx, in)
William Kurkian1b363f42019-03-12 15:28:12 -04002560 }
2561 info := &grpc.UnaryServerInfo{
2562 Server: srv,
Devmalya Paul96a2c9e2019-11-06 07:17:44 +00002563 FullMethod: "/voltha.VolthaService/GetEventFilter",
William Kurkian1b363f42019-03-12 15:28:12 -04002564 }
2565 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
Devmalya Paul96a2c9e2019-11-06 07:17:44 +00002566 return srv.(VolthaServiceServer).GetEventFilter(ctx, req.(*common.ID))
William Kurkian1b363f42019-03-12 15:28:12 -04002567 }
2568 return interceptor(ctx, in, info, handler)
2569}
2570
Devmalya Paul96a2c9e2019-11-06 07:17:44 +00002571func _VolthaService_UpdateEventFilter_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
2572 in := new(EventFilter)
William Kurkian1b363f42019-03-12 15:28:12 -04002573 if err := dec(in); err != nil {
2574 return nil, err
2575 }
2576 if interceptor == nil {
Devmalya Paul96a2c9e2019-11-06 07:17:44 +00002577 return srv.(VolthaServiceServer).UpdateEventFilter(ctx, in)
William Kurkian1b363f42019-03-12 15:28:12 -04002578 }
2579 info := &grpc.UnaryServerInfo{
2580 Server: srv,
Devmalya Paul96a2c9e2019-11-06 07:17:44 +00002581 FullMethod: "/voltha.VolthaService/UpdateEventFilter",
William Kurkian1b363f42019-03-12 15:28:12 -04002582 }
2583 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
Devmalya Paul96a2c9e2019-11-06 07:17:44 +00002584 return srv.(VolthaServiceServer).UpdateEventFilter(ctx, req.(*EventFilter))
William Kurkian1b363f42019-03-12 15:28:12 -04002585 }
2586 return interceptor(ctx, in, info, handler)
2587}
2588
Devmalya Paul96a2c9e2019-11-06 07:17:44 +00002589func _VolthaService_DeleteEventFilter_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
2590 in := new(EventFilter)
William Kurkian1b363f42019-03-12 15:28:12 -04002591 if err := dec(in); err != nil {
2592 return nil, err
2593 }
2594 if interceptor == nil {
Devmalya Paul96a2c9e2019-11-06 07:17:44 +00002595 return srv.(VolthaServiceServer).DeleteEventFilter(ctx, in)
William Kurkian1b363f42019-03-12 15:28:12 -04002596 }
2597 info := &grpc.UnaryServerInfo{
2598 Server: srv,
Devmalya Paul96a2c9e2019-11-06 07:17:44 +00002599 FullMethod: "/voltha.VolthaService/DeleteEventFilter",
William Kurkian1b363f42019-03-12 15:28:12 -04002600 }
2601 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
Devmalya Paul96a2c9e2019-11-06 07:17:44 +00002602 return srv.(VolthaServiceServer).DeleteEventFilter(ctx, req.(*EventFilter))
William Kurkian1b363f42019-03-12 15:28:12 -04002603 }
2604 return interceptor(ctx, in, info, handler)
2605}
2606
Devmalya Paul96a2c9e2019-11-06 07:17:44 +00002607func _VolthaService_ListEventFilters_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
William Kurkian1b363f42019-03-12 15:28:12 -04002608 in := new(empty.Empty)
2609 if err := dec(in); err != nil {
2610 return nil, err
2611 }
2612 if interceptor == nil {
Devmalya Paul96a2c9e2019-11-06 07:17:44 +00002613 return srv.(VolthaServiceServer).ListEventFilters(ctx, in)
William Kurkian1b363f42019-03-12 15:28:12 -04002614 }
2615 info := &grpc.UnaryServerInfo{
2616 Server: srv,
Devmalya Paul96a2c9e2019-11-06 07:17:44 +00002617 FullMethod: "/voltha.VolthaService/ListEventFilters",
William Kurkian1b363f42019-03-12 15:28:12 -04002618 }
2619 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
Devmalya Paul96a2c9e2019-11-06 07:17:44 +00002620 return srv.(VolthaServiceServer).ListEventFilters(ctx, req.(*empty.Empty))
William Kurkian1b363f42019-03-12 15:28:12 -04002621 }
2622 return interceptor(ctx, in, info, handler)
2623}
2624
2625func _VolthaService_GetImages_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
2626 in := new(common.ID)
2627 if err := dec(in); err != nil {
2628 return nil, err
2629 }
2630 if interceptor == nil {
2631 return srv.(VolthaServiceServer).GetImages(ctx, in)
2632 }
2633 info := &grpc.UnaryServerInfo{
2634 Server: srv,
2635 FullMethod: "/voltha.VolthaService/GetImages",
2636 }
2637 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
2638 return srv.(VolthaServiceServer).GetImages(ctx, req.(*common.ID))
2639 }
2640 return interceptor(ctx, in, info, handler)
2641}
2642
2643func _VolthaService_SelfTest_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
2644 in := new(common.ID)
2645 if err := dec(in); err != nil {
2646 return nil, err
2647 }
2648 if interceptor == nil {
2649 return srv.(VolthaServiceServer).SelfTest(ctx, in)
2650 }
2651 info := &grpc.UnaryServerInfo{
2652 Server: srv,
2653 FullMethod: "/voltha.VolthaService/SelfTest",
2654 }
2655 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
2656 return srv.(VolthaServiceServer).SelfTest(ctx, req.(*common.ID))
2657 }
2658 return interceptor(ctx, in, info, handler)
2659}
2660
2661func _VolthaService_GetMibDeviceData_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
2662 in := new(common.ID)
2663 if err := dec(in); err != nil {
2664 return nil, err
2665 }
2666 if interceptor == nil {
2667 return srv.(VolthaServiceServer).GetMibDeviceData(ctx, in)
2668 }
2669 info := &grpc.UnaryServerInfo{
2670 Server: srv,
2671 FullMethod: "/voltha.VolthaService/GetMibDeviceData",
2672 }
2673 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
2674 return srv.(VolthaServiceServer).GetMibDeviceData(ctx, req.(*common.ID))
2675 }
2676 return interceptor(ctx, in, info, handler)
2677}
2678
2679func _VolthaService_GetAlarmDeviceData_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
2680 in := new(common.ID)
2681 if err := dec(in); err != nil {
2682 return nil, err
2683 }
2684 if interceptor == nil {
2685 return srv.(VolthaServiceServer).GetAlarmDeviceData(ctx, in)
2686 }
2687 info := &grpc.UnaryServerInfo{
2688 Server: srv,
2689 FullMethod: "/voltha.VolthaService/GetAlarmDeviceData",
2690 }
2691 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
2692 return srv.(VolthaServiceServer).GetAlarmDeviceData(ctx, req.(*common.ID))
2693 }
2694 return interceptor(ctx, in, info, handler)
2695}
2696
2697func _VolthaService_SimulateAlarm_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
2698 in := new(SimulateAlarmRequest)
2699 if err := dec(in); err != nil {
2700 return nil, err
2701 }
2702 if interceptor == nil {
2703 return srv.(VolthaServiceServer).SimulateAlarm(ctx, in)
2704 }
2705 info := &grpc.UnaryServerInfo{
2706 Server: srv,
2707 FullMethod: "/voltha.VolthaService/SimulateAlarm",
2708 }
2709 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
2710 return srv.(VolthaServiceServer).SimulateAlarm(ctx, req.(*SimulateAlarmRequest))
2711 }
2712 return interceptor(ctx, in, info, handler)
2713}
2714
kesavand4a002b02020-01-23 21:29:47 -05002715func _VolthaService_EnablePort_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
2716 in := new(Port)
2717 if err := dec(in); err != nil {
2718 return nil, err
2719 }
2720 if interceptor == nil {
2721 return srv.(VolthaServiceServer).EnablePort(ctx, in)
2722 }
2723 info := &grpc.UnaryServerInfo{
2724 Server: srv,
2725 FullMethod: "/voltha.VolthaService/EnablePort",
2726 }
2727 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
2728 return srv.(VolthaServiceServer).EnablePort(ctx, req.(*Port))
2729 }
2730 return interceptor(ctx, in, info, handler)
2731}
2732
2733func _VolthaService_DisablePort_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
2734 in := new(Port)
2735 if err := dec(in); err != nil {
2736 return nil, err
2737 }
2738 if interceptor == nil {
2739 return srv.(VolthaServiceServer).DisablePort(ctx, in)
2740 }
2741 info := &grpc.UnaryServerInfo{
2742 Server: srv,
2743 FullMethod: "/voltha.VolthaService/DisablePort",
2744 }
2745 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
2746 return srv.(VolthaServiceServer).DisablePort(ctx, req.(*Port))
2747 }
2748 return interceptor(ctx, in, info, handler)
2749}
2750
Dinesh Belwalkared6da5e2020-02-25 11:23:57 -08002751func _VolthaService_GetExtValue_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
khenaidoo4c6543e2021-10-19 17:25:58 -04002752 in := new(extension.ValueSpecifier)
Dinesh Belwalkared6da5e2020-02-25 11:23:57 -08002753 if err := dec(in); err != nil {
2754 return nil, err
2755 }
2756 if interceptor == nil {
2757 return srv.(VolthaServiceServer).GetExtValue(ctx, in)
2758 }
2759 info := &grpc.UnaryServerInfo{
2760 Server: srv,
2761 FullMethod: "/voltha.VolthaService/GetExtValue",
2762 }
2763 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
khenaidoo4c6543e2021-10-19 17:25:58 -04002764 return srv.(VolthaServiceServer).GetExtValue(ctx, req.(*extension.ValueSpecifier))
Dinesh Belwalkared6da5e2020-02-25 11:23:57 -08002765 }
2766 return interceptor(ctx, in, info, handler)
2767}
2768
dpaul2b52e712020-06-23 13:02:28 +05302769func _VolthaService_SetExtValue_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
khenaidoo4c6543e2021-10-19 17:25:58 -04002770 in := new(extension.ValueSet)
dpaul2b52e712020-06-23 13:02:28 +05302771 if err := dec(in); err != nil {
2772 return nil, err
2773 }
2774 if interceptor == nil {
2775 return srv.(VolthaServiceServer).SetExtValue(ctx, in)
2776 }
2777 info := &grpc.UnaryServerInfo{
2778 Server: srv,
2779 FullMethod: "/voltha.VolthaService/SetExtValue",
2780 }
2781 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
khenaidoo4c6543e2021-10-19 17:25:58 -04002782 return srv.(VolthaServiceServer).SetExtValue(ctx, req.(*extension.ValueSet))
dpaul2b52e712020-06-23 13:02:28 +05302783 }
2784 return interceptor(ctx, in, info, handler)
2785}
2786
onkar.kundargi7b85fa12020-02-27 13:19:22 +05302787func _VolthaService_StartOmciTestAction_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
khenaidoo4c6543e2021-10-19 17:25:58 -04002788 in := new(omci.OmciTestRequest)
onkar.kundargi7b85fa12020-02-27 13:19:22 +05302789 if err := dec(in); err != nil {
2790 return nil, err
2791 }
2792 if interceptor == nil {
2793 return srv.(VolthaServiceServer).StartOmciTestAction(ctx, in)
2794 }
2795 info := &grpc.UnaryServerInfo{
2796 Server: srv,
2797 FullMethod: "/voltha.VolthaService/StartOmciTestAction",
2798 }
2799 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
khenaidoo4c6543e2021-10-19 17:25:58 -04002800 return srv.(VolthaServiceServer).StartOmciTestAction(ctx, req.(*omci.OmciTestRequest))
onkar.kundargi7b85fa12020-02-27 13:19:22 +05302801 }
2802 return interceptor(ctx, in, info, handler)
2803}
2804
William Kurkian1b363f42019-03-12 15:28:12 -04002805var _VolthaService_serviceDesc = grpc.ServiceDesc{
2806 ServiceName: "voltha.VolthaService",
2807 HandlerType: (*VolthaServiceServer)(nil),
2808 Methods: []grpc.MethodDesc{
2809 {
William Kurkian1b363f42019-03-12 15:28:12 -04002810 MethodName: "GetVoltha",
2811 Handler: _VolthaService_GetVoltha_Handler,
2812 },
2813 {
2814 MethodName: "ListCoreInstances",
2815 Handler: _VolthaService_ListCoreInstances_Handler,
2816 },
2817 {
2818 MethodName: "GetCoreInstance",
2819 Handler: _VolthaService_GetCoreInstance_Handler,
2820 },
2821 {
2822 MethodName: "ListAdapters",
2823 Handler: _VolthaService_ListAdapters_Handler,
2824 },
2825 {
2826 MethodName: "ListLogicalDevices",
2827 Handler: _VolthaService_ListLogicalDevices_Handler,
2828 },
2829 {
2830 MethodName: "GetLogicalDevice",
2831 Handler: _VolthaService_GetLogicalDevice_Handler,
2832 },
2833 {
2834 MethodName: "ListLogicalDevicePorts",
2835 Handler: _VolthaService_ListLogicalDevicePorts_Handler,
2836 },
2837 {
2838 MethodName: "GetLogicalDevicePort",
2839 Handler: _VolthaService_GetLogicalDevicePort_Handler,
2840 },
2841 {
2842 MethodName: "EnableLogicalDevicePort",
2843 Handler: _VolthaService_EnableLogicalDevicePort_Handler,
2844 },
2845 {
2846 MethodName: "DisableLogicalDevicePort",
2847 Handler: _VolthaService_DisableLogicalDevicePort_Handler,
2848 },
2849 {
2850 MethodName: "ListLogicalDeviceFlows",
2851 Handler: _VolthaService_ListLogicalDeviceFlows_Handler,
2852 },
2853 {
2854 MethodName: "UpdateLogicalDeviceFlowTable",
2855 Handler: _VolthaService_UpdateLogicalDeviceFlowTable_Handler,
2856 },
2857 {
2858 MethodName: "UpdateLogicalDeviceMeterTable",
2859 Handler: _VolthaService_UpdateLogicalDeviceMeterTable_Handler,
2860 },
2861 {
Abhilash Laxmeshwardfbb74d2019-07-23 08:03:08 -04002862 MethodName: "ListLogicalDeviceMeters",
2863 Handler: _VolthaService_ListLogicalDeviceMeters_Handler,
William Kurkian1b363f42019-03-12 15:28:12 -04002864 },
2865 {
2866 MethodName: "ListLogicalDeviceFlowGroups",
2867 Handler: _VolthaService_ListLogicalDeviceFlowGroups_Handler,
2868 },
2869 {
2870 MethodName: "UpdateLogicalDeviceFlowGroupTable",
2871 Handler: _VolthaService_UpdateLogicalDeviceFlowGroupTable_Handler,
2872 },
2873 {
2874 MethodName: "ListDevices",
2875 Handler: _VolthaService_ListDevices_Handler,
2876 },
2877 {
2878 MethodName: "ListDeviceIds",
2879 Handler: _VolthaService_ListDeviceIds_Handler,
2880 },
2881 {
2882 MethodName: "ReconcileDevices",
2883 Handler: _VolthaService_ReconcileDevices_Handler,
2884 },
2885 {
2886 MethodName: "GetDevice",
2887 Handler: _VolthaService_GetDevice_Handler,
2888 },
2889 {
2890 MethodName: "CreateDevice",
2891 Handler: _VolthaService_CreateDevice_Handler,
2892 },
2893 {
2894 MethodName: "EnableDevice",
2895 Handler: _VolthaService_EnableDevice_Handler,
2896 },
2897 {
2898 MethodName: "DisableDevice",
2899 Handler: _VolthaService_DisableDevice_Handler,
2900 },
2901 {
2902 MethodName: "RebootDevice",
2903 Handler: _VolthaService_RebootDevice_Handler,
2904 },
2905 {
2906 MethodName: "DeleteDevice",
2907 Handler: _VolthaService_DeleteDevice_Handler,
2908 },
2909 {
Himani Chawla503b7ce2020-10-07 13:20:03 +05302910 MethodName: "ForceDeleteDevice",
2911 Handler: _VolthaService_ForceDeleteDevice_Handler,
2912 },
2913 {
William Kurkian1b363f42019-03-12 15:28:12 -04002914 MethodName: "DownloadImage",
2915 Handler: _VolthaService_DownloadImage_Handler,
2916 },
2917 {
2918 MethodName: "GetImageDownloadStatus",
2919 Handler: _VolthaService_GetImageDownloadStatus_Handler,
2920 },
2921 {
2922 MethodName: "GetImageDownload",
2923 Handler: _VolthaService_GetImageDownload_Handler,
2924 },
2925 {
2926 MethodName: "ListImageDownloads",
2927 Handler: _VolthaService_ListImageDownloads_Handler,
2928 },
2929 {
2930 MethodName: "CancelImageDownload",
2931 Handler: _VolthaService_CancelImageDownload_Handler,
2932 },
2933 {
2934 MethodName: "ActivateImageUpdate",
2935 Handler: _VolthaService_ActivateImageUpdate_Handler,
2936 },
2937 {
2938 MethodName: "RevertImageUpdate",
2939 Handler: _VolthaService_RevertImageUpdate_Handler,
2940 },
2941 {
Andrea Campanella9e94e8a2021-01-19 15:21:25 +01002942 MethodName: "DownloadImageToDevice",
2943 Handler: _VolthaService_DownloadImageToDevice_Handler,
2944 },
2945 {
2946 MethodName: "GetImageStatus",
2947 Handler: _VolthaService_GetImageStatus_Handler,
2948 },
2949 {
2950 MethodName: "AbortImageUpgradeToDevice",
2951 Handler: _VolthaService_AbortImageUpgradeToDevice_Handler,
2952 },
2953 {
2954 MethodName: "GetOnuImages",
2955 Handler: _VolthaService_GetOnuImages_Handler,
2956 },
2957 {
2958 MethodName: "ActivateImage",
2959 Handler: _VolthaService_ActivateImage_Handler,
2960 },
2961 {
2962 MethodName: "CommitImage",
2963 Handler: _VolthaService_CommitImage_Handler,
2964 },
2965 {
William Kurkian1b363f42019-03-12 15:28:12 -04002966 MethodName: "ListDevicePorts",
2967 Handler: _VolthaService_ListDevicePorts_Handler,
2968 },
2969 {
2970 MethodName: "ListDevicePmConfigs",
2971 Handler: _VolthaService_ListDevicePmConfigs_Handler,
2972 },
2973 {
2974 MethodName: "UpdateDevicePmConfigs",
2975 Handler: _VolthaService_UpdateDevicePmConfigs_Handler,
2976 },
2977 {
2978 MethodName: "ListDeviceFlows",
2979 Handler: _VolthaService_ListDeviceFlows_Handler,
2980 },
2981 {
2982 MethodName: "ListDeviceFlowGroups",
2983 Handler: _VolthaService_ListDeviceFlowGroups_Handler,
2984 },
2985 {
2986 MethodName: "ListDeviceTypes",
2987 Handler: _VolthaService_ListDeviceTypes_Handler,
2988 },
2989 {
2990 MethodName: "GetDeviceType",
2991 Handler: _VolthaService_GetDeviceType_Handler,
2992 },
2993 {
Devmalya Paul96a2c9e2019-11-06 07:17:44 +00002994 MethodName: "CreateEventFilter",
2995 Handler: _VolthaService_CreateEventFilter_Handler,
William Kurkian1b363f42019-03-12 15:28:12 -04002996 },
2997 {
Devmalya Paul96a2c9e2019-11-06 07:17:44 +00002998 MethodName: "GetEventFilter",
2999 Handler: _VolthaService_GetEventFilter_Handler,
William Kurkian1b363f42019-03-12 15:28:12 -04003000 },
3001 {
Devmalya Paul96a2c9e2019-11-06 07:17:44 +00003002 MethodName: "UpdateEventFilter",
3003 Handler: _VolthaService_UpdateEventFilter_Handler,
William Kurkian1b363f42019-03-12 15:28:12 -04003004 },
3005 {
Devmalya Paul96a2c9e2019-11-06 07:17:44 +00003006 MethodName: "DeleteEventFilter",
3007 Handler: _VolthaService_DeleteEventFilter_Handler,
William Kurkian1b363f42019-03-12 15:28:12 -04003008 },
3009 {
Devmalya Paul96a2c9e2019-11-06 07:17:44 +00003010 MethodName: "ListEventFilters",
3011 Handler: _VolthaService_ListEventFilters_Handler,
William Kurkian1b363f42019-03-12 15:28:12 -04003012 },
3013 {
3014 MethodName: "GetImages",
3015 Handler: _VolthaService_GetImages_Handler,
3016 },
3017 {
3018 MethodName: "SelfTest",
3019 Handler: _VolthaService_SelfTest_Handler,
3020 },
3021 {
3022 MethodName: "GetMibDeviceData",
3023 Handler: _VolthaService_GetMibDeviceData_Handler,
3024 },
3025 {
3026 MethodName: "GetAlarmDeviceData",
3027 Handler: _VolthaService_GetAlarmDeviceData_Handler,
3028 },
3029 {
3030 MethodName: "SimulateAlarm",
3031 Handler: _VolthaService_SimulateAlarm_Handler,
3032 },
3033 {
kesavand4a002b02020-01-23 21:29:47 -05003034 MethodName: "EnablePort",
3035 Handler: _VolthaService_EnablePort_Handler,
3036 },
3037 {
3038 MethodName: "DisablePort",
3039 Handler: _VolthaService_DisablePort_Handler,
3040 },
onkar.kundargi7b85fa12020-02-27 13:19:22 +05303041 {
Dinesh Belwalkared6da5e2020-02-25 11:23:57 -08003042 MethodName: "GetExtValue",
3043 Handler: _VolthaService_GetExtValue_Handler,
3044 },
3045 {
dpaul2b52e712020-06-23 13:02:28 +05303046 MethodName: "SetExtValue",
3047 Handler: _VolthaService_SetExtValue_Handler,
3048 },
3049 {
onkar.kundargi7b85fa12020-02-27 13:19:22 +05303050 MethodName: "StartOmciTestAction",
3051 Handler: _VolthaService_StartOmciTestAction_Handler,
3052 },
William Kurkian1b363f42019-03-12 15:28:12 -04003053 },
3054 Streams: []grpc.StreamDesc{
3055 {
3056 StreamName: "StreamPacketsOut",
3057 Handler: _VolthaService_StreamPacketsOut_Handler,
3058 ClientStreams: true,
3059 },
3060 {
3061 StreamName: "ReceivePacketsIn",
3062 Handler: _VolthaService_ReceivePacketsIn_Handler,
3063 ServerStreams: true,
3064 },
3065 {
3066 StreamName: "ReceiveChangeEvents",
3067 Handler: _VolthaService_ReceiveChangeEvents_Handler,
3068 ServerStreams: true,
3069 },
3070 },
3071 Metadata: "voltha_protos/voltha.proto",
3072}