blob: acd0402dabd676d84d0c2f898b688c7ba00dc709 [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"
yasin sapli2bbfbb42021-11-01 14:30:10 +000016 voip_system_profile "github.com/opencord/voltha-protos/v5/go/voip_system_profile"
17 voip_user_profile "github.com/opencord/voltha-protos/v5/go/voip_user_profile"
William Kurkianad745652019-03-20 08:45:51 -040018 _ "google.golang.org/genproto/googleapis/api/annotations"
William Kurkian1b363f42019-03-12 15:28:12 -040019 grpc "google.golang.org/grpc"
David K. Bainbridgec4bf5382021-04-08 16:06:54 +000020 codes "google.golang.org/grpc/codes"
21 status "google.golang.org/grpc/status"
William Kurkianad745652019-03-20 08:45:51 -040022 math "math"
William Kurkian1b363f42019-03-12 15:28:12 -040023)
24
25// Reference imports to suppress errors if they are not otherwise used.
26var _ = proto.Marshal
27var _ = fmt.Errorf
28var _ = math.Inf
29
30// This is a compile-time assertion to ensure that this generated file
31// is compatible with the proto package it is being compiled against.
32// A compilation error at this line likely means your copy of the
33// proto package needs to be updated.
William Kurkianad745652019-03-20 08:45:51 -040034const _ = proto.ProtoPackageIsVersion3 // please upgrade the proto package
William Kurkian1b363f42019-03-12 15:28:12 -040035
yasin sapli2bbfbb42021-11-01 14:30:10 +000036// Key from public import voltha_protos/common.proto
37type Key = common.Key
38
William Kurkian1b363f42019-03-12 15:28:12 -040039// ID from public import voltha_protos/common.proto
40type ID = common.ID
41
42// IDs from public import voltha_protos/common.proto
43type IDs = common.IDs
44
khenaidoo5cb0d402021-12-08 14:09:16 -050045// Connection from public import voltha_protos/common.proto
46type Connection = common.Connection
47
William Kurkian1b363f42019-03-12 15:28:12 -040048// AdminState from public import voltha_protos/common.proto
49type AdminState = common.AdminState
50
51// OperStatus from public import voltha_protos/common.proto
52type OperStatus = common.OperStatus
53
54// ConnectStatus from public import voltha_protos/common.proto
55type ConnectStatus = common.ConnectStatus
56
57// OperationResp from public import voltha_protos/common.proto
58type OperationResp = common.OperationResp
59
60// TestModeKeys from public import voltha_protos/common.proto
61type TestModeKeys = common.TestModeKeys
62
63var TestModeKeys_name = common.TestModeKeys_name
64var TestModeKeys_value = common.TestModeKeys_value
65
66const TestModeKeys_api_test = TestModeKeys(common.TestModeKeys_api_test)
67
Serkant Uluderyacbcfaa42019-10-18 13:25:08 +030068// AdminState_Types from public import voltha_protos/common.proto
69type AdminState_Types = common.AdminState_Types
William Kurkian1b363f42019-03-12 15:28:12 -040070
Serkant Uluderyacbcfaa42019-10-18 13:25:08 +030071var AdminState_Types_name = common.AdminState_Types_name
72var AdminState_Types_value = common.AdminState_Types_value
William Kurkian1b363f42019-03-12 15:28:12 -040073
Serkant Uluderyacbcfaa42019-10-18 13:25:08 +030074const AdminState_UNKNOWN = AdminState_Types(common.AdminState_UNKNOWN)
75const AdminState_PREPROVISIONED = AdminState_Types(common.AdminState_PREPROVISIONED)
76const AdminState_ENABLED = AdminState_Types(common.AdminState_ENABLED)
77const AdminState_DISABLED = AdminState_Types(common.AdminState_DISABLED)
78const AdminState_DOWNLOADING_IMAGE = AdminState_Types(common.AdminState_DOWNLOADING_IMAGE)
William Kurkian1b363f42019-03-12 15:28:12 -040079
Serkant Uluderyacbcfaa42019-10-18 13:25:08 +030080// OperStatus_Types from public import voltha_protos/common.proto
81type OperStatus_Types = common.OperStatus_Types
William Kurkian1b363f42019-03-12 15:28:12 -040082
Serkant Uluderyacbcfaa42019-10-18 13:25:08 +030083var OperStatus_Types_name = common.OperStatus_Types_name
84var OperStatus_Types_value = common.OperStatus_Types_value
William Kurkian1b363f42019-03-12 15:28:12 -040085
Serkant Uluderyacbcfaa42019-10-18 13:25:08 +030086const OperStatus_UNKNOWN = OperStatus_Types(common.OperStatus_UNKNOWN)
87const OperStatus_DISCOVERED = OperStatus_Types(common.OperStatus_DISCOVERED)
88const OperStatus_ACTIVATING = OperStatus_Types(common.OperStatus_ACTIVATING)
89const OperStatus_TESTING = OperStatus_Types(common.OperStatus_TESTING)
90const OperStatus_ACTIVE = OperStatus_Types(common.OperStatus_ACTIVE)
91const OperStatus_FAILED = OperStatus_Types(common.OperStatus_FAILED)
Maninder4ed97f52021-03-15 10:14:55 +053092const OperStatus_RECONCILING = OperStatus_Types(common.OperStatus_RECONCILING)
Manindera4b9e552021-06-16 17:33:04 +053093const OperStatus_RECONCILING_FAILED = OperStatus_Types(common.OperStatus_RECONCILING_FAILED)
Abhilash Laxmeshwar540a0b92022-06-13 11:24:06 +053094const OperStatus_REBOOTED = OperStatus_Types(common.OperStatus_REBOOTED)
William Kurkian1b363f42019-03-12 15:28:12 -040095
Serkant Uluderyacbcfaa42019-10-18 13:25:08 +030096// ConnectStatus_Types from public import voltha_protos/common.proto
97type ConnectStatus_Types = common.ConnectStatus_Types
William Kurkian1b363f42019-03-12 15:28:12 -040098
Serkant Uluderyacbcfaa42019-10-18 13:25:08 +030099var ConnectStatus_Types_name = common.ConnectStatus_Types_name
100var ConnectStatus_Types_value = common.ConnectStatus_Types_value
William Kurkian1b363f42019-03-12 15:28:12 -0400101
Serkant Uluderyacbcfaa42019-10-18 13:25:08 +0300102const ConnectStatus_UNKNOWN = ConnectStatus_Types(common.ConnectStatus_UNKNOWN)
103const ConnectStatus_UNREACHABLE = ConnectStatus_Types(common.ConnectStatus_UNREACHABLE)
104const ConnectStatus_REACHABLE = ConnectStatus_Types(common.ConnectStatus_REACHABLE)
William Kurkian1b363f42019-03-12 15:28:12 -0400105
William Kurkianad745652019-03-20 08:45:51 -0400106// OperationResp_OperationReturnCode from public import voltha_protos/common.proto
William Kurkian1b363f42019-03-12 15:28:12 -0400107type OperationResp_OperationReturnCode = common.OperationResp_OperationReturnCode
108
109var OperationResp_OperationReturnCode_name = common.OperationResp_OperationReturnCode_name
110var OperationResp_OperationReturnCode_value = common.OperationResp_OperationReturnCode_value
111
112const OperationResp_OPERATION_SUCCESS = OperationResp_OperationReturnCode(common.OperationResp_OPERATION_SUCCESS)
113const OperationResp_OPERATION_FAILURE = OperationResp_OperationReturnCode(common.OperationResp_OPERATION_FAILURE)
114const OperationResp_OPERATION_UNSUPPORTED = OperationResp_OperationReturnCode(common.OperationResp_OPERATION_UNSUPPORTED)
Maninder2f9d63e2021-02-08 11:42:19 +0530115const OperationResp_OPERATION_IN_PROGRESS = OperationResp_OperationReturnCode(common.OperationResp_OPERATION_IN_PROGRESS)
William Kurkian1b363f42019-03-12 15:28:12 -0400116
William Kurkian1b363f42019-03-12 15:28:12 -0400117// CoreInstance represents a core instance. It is data held in memory when a core
118// is running. This data is not persistent.
119type CoreInstance struct {
khenaidoo4c6543e2021-10-19 17:25:58 -0400120 InstanceId string `protobuf:"bytes,1,opt,name=instance_id,json=instanceId,proto3" json:"instance_id,omitempty"`
121 Health *health.HealthStatus `protobuf:"bytes,2,opt,name=health,proto3" json:"health,omitempty"`
122 XXX_NoUnkeyedLiteral struct{} `json:"-"`
123 XXX_unrecognized []byte `json:"-"`
124 XXX_sizecache int32 `json:"-"`
William Kurkian1b363f42019-03-12 15:28:12 -0400125}
126
127func (m *CoreInstance) Reset() { *m = CoreInstance{} }
128func (m *CoreInstance) String() string { return proto.CompactTextString(m) }
129func (*CoreInstance) ProtoMessage() {}
130func (*CoreInstance) Descriptor() ([]byte, []int) {
khenaidoo4c6543e2021-10-19 17:25:58 -0400131 return fileDescriptor_e084f1a60ce7016c, []int{0}
William Kurkian1b363f42019-03-12 15:28:12 -0400132}
William Kurkianad745652019-03-20 08:45:51 -0400133
William Kurkian1b363f42019-03-12 15:28:12 -0400134func (m *CoreInstance) XXX_Unmarshal(b []byte) error {
135 return xxx_messageInfo_CoreInstance.Unmarshal(m, b)
136}
137func (m *CoreInstance) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
138 return xxx_messageInfo_CoreInstance.Marshal(b, m, deterministic)
139}
William Kurkianad745652019-03-20 08:45:51 -0400140func (m *CoreInstance) XXX_Merge(src proto.Message) {
141 xxx_messageInfo_CoreInstance.Merge(m, src)
William Kurkian1b363f42019-03-12 15:28:12 -0400142}
143func (m *CoreInstance) XXX_Size() int {
144 return xxx_messageInfo_CoreInstance.Size(m)
145}
146func (m *CoreInstance) XXX_DiscardUnknown() {
147 xxx_messageInfo_CoreInstance.DiscardUnknown(m)
148}
149
150var xxx_messageInfo_CoreInstance proto.InternalMessageInfo
151
152func (m *CoreInstance) GetInstanceId() string {
153 if m != nil {
154 return m.InstanceId
155 }
156 return ""
157}
158
khenaidoo4c6543e2021-10-19 17:25:58 -0400159func (m *CoreInstance) GetHealth() *health.HealthStatus {
William Kurkian1b363f42019-03-12 15:28:12 -0400160 if m != nil {
161 return m.Health
162 }
163 return nil
164}
165
166type CoreInstances struct {
167 Items []*CoreInstance `protobuf:"bytes,1,rep,name=items,proto3" json:"items,omitempty"`
168 XXX_NoUnkeyedLiteral struct{} `json:"-"`
169 XXX_unrecognized []byte `json:"-"`
170 XXX_sizecache int32 `json:"-"`
171}
172
173func (m *CoreInstances) Reset() { *m = CoreInstances{} }
174func (m *CoreInstances) String() string { return proto.CompactTextString(m) }
175func (*CoreInstances) ProtoMessage() {}
176func (*CoreInstances) Descriptor() ([]byte, []int) {
khenaidoo4c6543e2021-10-19 17:25:58 -0400177 return fileDescriptor_e084f1a60ce7016c, []int{1}
William Kurkian1b363f42019-03-12 15:28:12 -0400178}
William Kurkianad745652019-03-20 08:45:51 -0400179
William Kurkian1b363f42019-03-12 15:28:12 -0400180func (m *CoreInstances) XXX_Unmarshal(b []byte) error {
181 return xxx_messageInfo_CoreInstances.Unmarshal(m, b)
182}
183func (m *CoreInstances) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
184 return xxx_messageInfo_CoreInstances.Marshal(b, m, deterministic)
185}
William Kurkianad745652019-03-20 08:45:51 -0400186func (m *CoreInstances) XXX_Merge(src proto.Message) {
187 xxx_messageInfo_CoreInstances.Merge(m, src)
William Kurkian1b363f42019-03-12 15:28:12 -0400188}
189func (m *CoreInstances) XXX_Size() int {
190 return xxx_messageInfo_CoreInstances.Size(m)
191}
192func (m *CoreInstances) XXX_DiscardUnknown() {
193 xxx_messageInfo_CoreInstances.DiscardUnknown(m)
194}
195
196var xxx_messageInfo_CoreInstances proto.InternalMessageInfo
197
198func (m *CoreInstances) GetItems() []*CoreInstance {
199 if m != nil {
200 return m.Items
201 }
202 return nil
203}
204
205// Voltha represents the Voltha cluster data. Each Core instance will hold a subset of
206// the entire cluster. However, some items (e.g. adapters) will be held by all cores
207// for better performance
208type Voltha struct {
209 Version string `protobuf:"bytes,1,opt,name=version,proto3" json:"version,omitempty"`
210 Adapters []*Adapter `protobuf:"bytes,2,rep,name=adapters,proto3" json:"adapters,omitempty"`
211 LogicalDevices []*LogicalDevice `protobuf:"bytes,3,rep,name=logical_devices,json=logicalDevices,proto3" json:"logical_devices,omitempty"`
212 Devices []*Device `protobuf:"bytes,4,rep,name=devices,proto3" json:"devices,omitempty"`
213 DeviceTypes []*DeviceType `protobuf:"bytes,5,rep,name=device_types,json=deviceTypes,proto3" json:"device_types,omitempty"`
Devmalya Paul96a2c9e2019-11-06 07:17:44 +0000214 EventFilters []*EventFilter `protobuf:"bytes,7,rep,name=event_filters,json=eventFilters,proto3" json:"event_filters,omitempty"`
William Kurkian1b363f42019-03-12 15:28:12 -0400215 OmciMibDatabase []*omci.MibDeviceData `protobuf:"bytes,28,rep,name=omci_mib_database,json=omciMibDatabase,proto3" json:"omci_mib_database,omitempty"`
216 OmciAlarmDatabase []*omci.AlarmDeviceData `protobuf:"bytes,29,rep,name=omci_alarm_database,json=omciAlarmDatabase,proto3" json:"omci_alarm_database,omitempty"`
217 XXX_NoUnkeyedLiteral struct{} `json:"-"`
218 XXX_unrecognized []byte `json:"-"`
219 XXX_sizecache int32 `json:"-"`
220}
221
222func (m *Voltha) Reset() { *m = Voltha{} }
223func (m *Voltha) String() string { return proto.CompactTextString(m) }
224func (*Voltha) ProtoMessage() {}
225func (*Voltha) Descriptor() ([]byte, []int) {
khenaidoo4c6543e2021-10-19 17:25:58 -0400226 return fileDescriptor_e084f1a60ce7016c, []int{2}
William Kurkian1b363f42019-03-12 15:28:12 -0400227}
William Kurkianad745652019-03-20 08:45:51 -0400228
William Kurkian1b363f42019-03-12 15:28:12 -0400229func (m *Voltha) XXX_Unmarshal(b []byte) error {
230 return xxx_messageInfo_Voltha.Unmarshal(m, b)
231}
232func (m *Voltha) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
233 return xxx_messageInfo_Voltha.Marshal(b, m, deterministic)
234}
William Kurkianad745652019-03-20 08:45:51 -0400235func (m *Voltha) XXX_Merge(src proto.Message) {
236 xxx_messageInfo_Voltha.Merge(m, src)
William Kurkian1b363f42019-03-12 15:28:12 -0400237}
238func (m *Voltha) XXX_Size() int {
239 return xxx_messageInfo_Voltha.Size(m)
240}
241func (m *Voltha) XXX_DiscardUnknown() {
242 xxx_messageInfo_Voltha.DiscardUnknown(m)
243}
244
245var xxx_messageInfo_Voltha proto.InternalMessageInfo
246
247func (m *Voltha) GetVersion() string {
248 if m != nil {
249 return m.Version
250 }
251 return ""
252}
253
254func (m *Voltha) GetAdapters() []*Adapter {
255 if m != nil {
256 return m.Adapters
257 }
258 return nil
259}
260
261func (m *Voltha) GetLogicalDevices() []*LogicalDevice {
262 if m != nil {
263 return m.LogicalDevices
264 }
265 return nil
266}
267
268func (m *Voltha) GetDevices() []*Device {
269 if m != nil {
270 return m.Devices
271 }
272 return nil
273}
274
275func (m *Voltha) GetDeviceTypes() []*DeviceType {
276 if m != nil {
277 return m.DeviceTypes
278 }
279 return nil
280}
281
Devmalya Paul96a2c9e2019-11-06 07:17:44 +0000282func (m *Voltha) GetEventFilters() []*EventFilter {
William Kurkian1b363f42019-03-12 15:28:12 -0400283 if m != nil {
Devmalya Paul96a2c9e2019-11-06 07:17:44 +0000284 return m.EventFilters
William Kurkian1b363f42019-03-12 15:28:12 -0400285 }
286 return nil
287}
288
289func (m *Voltha) GetOmciMibDatabase() []*omci.MibDeviceData {
290 if m != nil {
291 return m.OmciMibDatabase
292 }
293 return nil
294}
295
296func (m *Voltha) GetOmciAlarmDatabase() []*omci.AlarmDeviceData {
297 if m != nil {
298 return m.OmciAlarmDatabase
299 }
300 return nil
301}
302
William Kurkian1b363f42019-03-12 15:28:12 -0400303func init() {
William Kurkian1b363f42019-03-12 15:28:12 -0400304 proto.RegisterType((*CoreInstance)(nil), "voltha.CoreInstance")
305 proto.RegisterType((*CoreInstances)(nil), "voltha.CoreInstances")
306 proto.RegisterType((*Voltha)(nil), "voltha.Voltha")
William Kurkianad745652019-03-20 08:45:51 -0400307}
308
309func init() { proto.RegisterFile("voltha_protos/voltha.proto", fileDescriptor_e084f1a60ce7016c) }
310
311var fileDescriptor_e084f1a60ce7016c = []byte{
yasin sapli2bbfbb42021-11-01 14:30:10 +0000312 // 2265 bytes of a gzipped FileDescriptorProto
313 0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0xc4, 0x5a, 0xeb, 0x6e, 0x1b, 0xc7,
314 0x15, 0xce, 0x2a, 0x89, 0x2f, 0xa3, 0x2b, 0x87, 0xba, 0x50, 0x24, 0x65, 0x4b, 0xe3, 0x9b, 0x4c,
315 0xdb, 0x4b, 0x5f, 0x93, 0x36, 0x69, 0x50, 0x38, 0xba, 0x55, 0x89, 0x0d, 0x09, 0xa4, 0x2d, 0xb7,
316 0x45, 0x1c, 0x62, 0xc9, 0x1d, 0xd2, 0x8b, 0x2c, 0x77, 0xd9, 0x9d, 0xa1, 0x64, 0x41, 0xf0, 0x9f,
317 0xb6, 0x01, 0x5c, 0x14, 0x45, 0x7f, 0xe4, 0x2d, 0xfa, 0xa3, 0xcf, 0xd0, 0x77, 0xe8, 0x2b, 0xf4,
318 0x41, 0x8a, 0x39, 0x33, 0x43, 0xee, 0x95, 0x22, 0xdd, 0x00, 0xfd, 0x63, 0x6a, 0xe6, 0x9c, 0xf9,
319 0xbe, 0x6f, 0xce, 0x9c, 0xb9, 0xae, 0x51, 0xf1, 0xd8, 0x77, 0xf9, 0x1b, 0xab, 0xd1, 0x0b, 0x7c,
320 0xee, 0xb3, 0xaa, 0x2c, 0x99, 0x50, 0xc2, 0x17, 0x64, 0xa9, 0x58, 0xee, 0xf8, 0x7e, 0xc7, 0xa5,
321 0x55, 0xab, 0xe7, 0x54, 0x2d, 0xcf, 0xf3, 0xb9, 0xc5, 0x1d, 0xdf, 0x63, 0xd2, 0xab, 0x58, 0x52,
322 0x56, 0x28, 0x35, 0xfb, 0xed, 0x2a, 0xed, 0xf6, 0xf8, 0xa9, 0x32, 0xc6, 0xe0, 0x5b, 0x7e, 0xb7,
323 0xeb, 0x7b, 0xe9, 0xb6, 0x37, 0xd4, 0x72, 0xf9, 0x1b, 0x65, 0x23, 0x51, 0x9b, 0xeb, 0x77, 0x9c,
324 0x96, 0xe5, 0x36, 0x6c, 0x7a, 0xec, 0xb4, 0x68, 0x7a, 0xfb, 0x88, 0xad, 0x14, 0xb5, 0x59, 0xb6,
325 0xd5, 0xe3, 0x34, 0x50, 0xc6, 0xab, 0x51, 0xa3, 0xdf, 0xa3, 0x5e, 0xdb, 0xf5, 0x4f, 0x1a, 0x0f,
326 0x1e, 0xa5, 0x23, 0xd3, 0x63, 0xea, 0x71, 0xdd, 0xdd, 0x2b, 0x31, 0xdb, 0x5b, 0x4e, 0x3d, 0x16,
327 0x0a, 0xc7, 0xad, 0x78, 0x40, 0x9d, 0x5e, 0x83, 0x9d, 0x32, 0x4e, 0xbb, 0xa2, 0xaa, 0xed, 0xb8,
328 0x5a, 0xe2, 0x8d, 0x14, 0xc7, 0x3e, 0xa3, 0x41, 0xcc, 0x2d, 0x2e, 0xb6, 0xdb, 0x72, 0x1a, 0x5d,
329 0xa7, 0xd9, 0xb0, 0x9b, 0xca, 0x61, 0x23, 0xc5, 0xc1, 0x72, 0xad, 0xa0, 0x3b, 0x74, 0x59, 0x4b,
330 0x71, 0xe1, 0x94, 0x71, 0x69, 0x26, 0xaf, 0xd1, 0xcc, 0x96, 0x1f, 0xd0, 0x7d, 0x8f, 0x71, 0xcb,
331 0x6b, 0x51, 0x7c, 0x15, 0x4d, 0x3b, 0xea, 0xef, 0x86, 0x63, 0x17, 0x8c, 0x75, 0x63, 0xf3, 0x72,
332 0x0d, 0xe9, 0xaa, 0x7d, 0x1b, 0xdf, 0x45, 0x17, 0xe4, 0x68, 0x15, 0xa6, 0xd6, 0x8d, 0xcd, 0xe9,
333 0x87, 0x8b, 0xa6, 0x1a, 0xbc, 0xdf, 0xc0, 0x4f, 0x9d, 0x5b, 0xbc, 0xcf, 0x6a, 0xca, 0x87, 0x7c,
334 0x89, 0x66, 0xc3, 0xf0, 0x0c, 0x57, 0xd0, 0xa7, 0x0e, 0xa7, 0x5d, 0x56, 0x30, 0xd6, 0x3f, 0x86,
335 0xd6, 0x2a, 0xeb, 0xc2, 0x5e, 0x35, 0xe9, 0x42, 0xfe, 0xf5, 0x31, 0xba, 0x70, 0x04, 0x66, 0x5c,
336 0x40, 0x17, 0x8f, 0x69, 0x20, 0x62, 0xad, 0x24, 0xe9, 0x22, 0xbe, 0x8b, 0x2e, 0xa9, 0x11, 0x66,
337 0x85, 0x29, 0xc0, 0x5c, 0x30, 0xf5, 0x90, 0x3f, 0x95, 0xbf, 0xb5, 0x81, 0x07, 0xde, 0x45, 0xf3,
338 0xd1, 0x7c, 0x62, 0x85, 0x8f, 0xa1, 0xd1, 0x9a, 0x19, 0xcb, 0xb3, 0x67, 0xb2, 0xb8, 0x0d, 0xa5,
339 0xda, 0x9c, 0x1b, 0x2e, 0x32, 0xbc, 0x89, 0x2e, 0xea, 0xf6, 0x9f, 0x40, 0xfb, 0x39, 0x53, 0xb5,
340 0x53, 0x0d, 0xb4, 0x19, 0x3f, 0x41, 0x33, 0xf2, 0xcf, 0x06, 0x3f, 0xed, 0x51, 0x56, 0xf8, 0x14,
341 0xdc, 0x71, 0xd4, 0xfd, 0xc5, 0x69, 0x8f, 0xd6, 0xa6, 0xed, 0xc1, 0xdf, 0x0c, 0x7f, 0x8e, 0x66,
342 0x21, 0xf5, 0x1a, 0x6d, 0xc7, 0x85, 0xbe, 0x5d, 0x54, 0xed, 0xa0, 0xd6, 0xdc, 0x11, 0xff, 0xee,
343 0x82, 0xa9, 0x36, 0x43, 0x87, 0x05, 0x86, 0x7f, 0x8d, 0x72, 0xc3, 0x3c, 0xb1, 0xb8, 0xd5, 0xb4,
344 0x18, 0x2d, 0x94, 0xa1, 0x71, 0xde, 0x14, 0x16, 0xf3, 0xb9, 0xd3, 0x94, 0xac, 0xdb, 0x16, 0xb7,
345 0x6a, 0xf3, 0xa2, 0x4e, 0x54, 0x29, 0x5f, 0xbc, 0x83, 0xf2, 0xe1, 0x3c, 0xd2, 0x10, 0x6b, 0x00,
346 0xb1, 0x24, 0x21, 0x9e, 0x0a, 0x5b, 0x08, 0x04, 0x28, 0x65, 0xa5, 0xf2, 0xff, 0xe6, 0x93, 0x4b,
347 0x17, 0x16, 0x2e, 0x3e, 0xfc, 0xe7, 0xe7, 0x68, 0x56, 0x0e, 0x61, 0x9d, 0x06, 0xc2, 0x1d, 0x6f,
348 0xa3, 0xcb, 0x7b, 0x94, 0xab, 0x61, 0x5d, 0x36, 0xe5, 0x02, 0x62, 0xea, 0x05, 0xc4, 0xdc, 0x11,
349 0x0b, 0x48, 0x71, 0x4e, 0xa7, 0x85, 0xf4, 0x23, 0xf3, 0x7f, 0xfc, 0xf7, 0x7f, 0x7e, 0x9a, 0xba,
350 0x8c, 0x2f, 0xc2, 0x3a, 0x74, 0xfc, 0x00, 0xbf, 0x46, 0xb9, 0x67, 0x0e, 0xe3, 0xd1, 0xdc, 0xca,
351 0x42, 0x5b, 0x4a, 0x4b, 0x32, 0x46, 0x56, 0x01, 0x34, 0x8f, 0x73, 0x0a, 0xb4, 0xea, 0x0c, 0x90,
352 0xea, 0x68, 0x7e, 0x8f, 0x46, 0xd0, 0x31, 0x32, 0xd5, 0x02, 0xb6, 0xbf, 0x5d, 0x4c, 0xcd, 0x5a,
353 0x72, 0x05, 0xf0, 0x0a, 0x78, 0x39, 0x81, 0x57, 0x3d, 0x73, 0xec, 0x77, 0xb8, 0x8e, 0x66, 0x84,
354 0xe6, 0xa7, 0x3a, 0x17, 0xb3, 0xe4, 0xe6, 0xe2, 0xf9, 0xcb, 0x48, 0x01, 0xa0, 0x31, 0x5e, 0xd0,
355 0xd0, 0x83, 0x84, 0xee, 0x22, 0x2c, 0x40, 0x9f, 0x45, 0xd3, 0x33, 0x0b, 0xfa, 0xca, 0xc8, 0x2c,
356 0x67, 0xe4, 0x2a, 0xf0, 0xac, 0xe2, 0x15, 0xcd, 0x13, 0x9b, 0x2c, 0xb8, 0x85, 0x16, 0xf6, 0x68,
357 0x94, 0x2d, 0x12, 0x99, 0xd1, 0xd3, 0x88, 0x5c, 0x07, 0xfc, 0x2b, 0xb8, 0x9c, 0x81, 0x2f, 0x03,
358 0xe5, 0xa1, 0xe5, 0x44, 0x9f, 0x0e, 0xfd, 0x80, 0xb3, 0x08, 0x55, 0x39, 0x83, 0x0a, 0x3c, 0x49,
359 0x05, 0x98, 0xae, 0x63, 0x32, 0x8a, 0xa9, 0xda, 0x03, 0xd4, 0xf7, 0x06, 0x5a, 0x8c, 0xf7, 0x4a,
360 0xa0, 0xe0, 0xb5, 0x11, 0x14, 0xfb, 0x76, 0xb1, 0x34, 0xc2, 0x4c, 0x1e, 0x83, 0x00, 0x13, 0xdf,
361 0x3d, 0x5f, 0x40, 0xf5, 0x4c, 0xfc, 0x34, 0x44, 0xd7, 0xff, 0x66, 0xa0, 0x95, 0x1d, 0xcf, 0x6a,
362 0xba, 0x74, 0x62, 0x35, 0x19, 0x63, 0x4e, 0xbe, 0x04, 0x21, 0x4f, 0xc8, 0xa3, 0x49, 0x84, 0x54,
363 0x29, 0x88, 0xc0, 0x7f, 0x37, 0x50, 0x61, 0xdb, 0x61, 0x3f, 0xab, 0xa0, 0x5f, 0x81, 0xa0, 0xcf,
364 0xc8, 0xe3, 0x89, 0x04, 0xd9, 0x52, 0x05, 0xb6, 0x53, 0x92, 0x63, 0xd7, 0xf5, 0x4f, 0xa2, 0xc9,
365 0x81, 0xcd, 0xf0, 0xce, 0x0e, 0xf6, 0x31, 0x53, 0xa2, 0x0d, 0x58, 0x7f, 0x32, 0x50, 0xf9, 0x65,
366 0xcf, 0xb6, 0x38, 0x4d, 0x10, 0xbd, 0x00, 0x19, 0xe5, 0x04, 0x01, 0xd4, 0xcb, 0x36, 0x99, 0x5d,
367 0xbf, 0x07, 0x12, 0x6e, 0x91, 0x31, 0x24, 0x7c, 0x61, 0x54, 0xf0, 0x9f, 0x0d, 0xb4, 0x96, 0xa2,
368 0xe2, 0x39, 0xe5, 0x34, 0x90, 0x32, 0x4a, 0x11, 0x19, 0x60, 0x78, 0xee, 0xdb, 0xe7, 0xa8, 0x30,
369 0x41, 0xc5, 0x26, 0xb9, 0x36, 0x52, 0x45, 0x57, 0x80, 0x81, 0x8c, 0x0e, 0x5a, 0x49, 0x84, 0x1c,
370 0xa8, 0xa2, 0x31, 0xcf, 0x27, 0xb5, 0x30, 0x72, 0x07, 0xb8, 0x6e, 0xe0, 0x71, 0xb8, 0x30, 0x47,
371 0xa5, 0xd4, 0xb1, 0xdd, 0x0b, 0xfc, 0x7e, 0x2f, 0x4a, 0xb6, 0x92, 0x88, 0xbf, 0x74, 0x22, 0xf7,
372 0x81, 0xb0, 0x82, 0x37, 0xcf, 0x0d, 0x71, 0xa3, 0x23, 0x61, 0x7f, 0x32, 0xd0, 0x46, 0xc6, 0x58,
373 0x03, 0xa6, 0x8c, 0xf4, 0x46, 0x3a, 0xe1, 0x38, 0xa3, 0xfe, 0x08, 0x24, 0xdd, 0x23, 0x63, 0x4b,
374 0x12, 0x41, 0x3f, 0x40, 0xd3, 0x22, 0x16, 0xe7, 0xad, 0xe8, 0xf3, 0xd1, 0x83, 0x04, 0x23, 0x2b,
375 0x40, 0x96, 0xc3, 0xf3, 0x9a, 0x4c, 0x2f, 0xdd, 0x07, 0x68, 0x76, 0x08, 0xb8, 0x6f, 0x67, 0x43,
376 0x4e, 0x0f, 0xc3, 0x9c, 0xb2, 0x49, 0x4a, 0x38, 0xc7, 0x66, 0xf8, 0x25, 0x5a, 0xa8, 0xd1, 0x96,
377 0xef, 0xb5, 0x1c, 0x97, 0x6a, 0x99, 0xe1, 0xb6, 0x99, 0xf1, 0x28, 0x03, 0xe6, 0x32, 0x49, 0x62,
378 0x8a, 0x8e, 0xef, 0xc0, 0x01, 0x21, 0x65, 0x6f, 0x89, 0x1d, 0xb1, 0x34, 0x0c, 0x5e, 0x8c, 0xf5,
379 0x54, 0x6e, 0x22, 0xdf, 0xa0, 0x99, 0xad, 0x80, 0x5a, 0x5c, 0x49, 0xc3, 0xb1, 0xd6, 0x09, 0xb4,
380 0x22, 0xa0, 0x2d, 0x92, 0x78, 0xdc, 0x84, 0xa4, 0x57, 0x68, 0x46, 0x2e, 0xca, 0x29, 0xaa, 0xb2,
381 0x3a, 0x79, 0x0d, 0xf0, 0xd6, 0x48, 0x29, 0x4d, 0x9d, 0x5e, 0x5e, 0x7f, 0x87, 0x66, 0xd5, 0xea,
382 0x3a, 0x01, 0xb2, 0xda, 0x44, 0x49, 0x39, 0x15, 0x59, 0xaf, 0x93, 0xaf, 0xd0, 0x4c, 0x8d, 0x36,
383 0x7d, 0x9f, 0xff, 0x6c, 0x9a, 0x03, 0x80, 0x13, 0xc0, 0xdb, 0xd4, 0xa5, 0xfc, 0x03, 0x82, 0x51,
384 0x49, 0x07, 0xb6, 0x01, 0x0e, 0x37, 0x51, 0x6e, 0xd7, 0x0f, 0x5a, 0x74, 0x62, 0xf4, 0xdb, 0x80,
385 0x7e, 0xad, 0xb2, 0x91, 0x8a, 0xde, 0x16, 0x98, 0x0d, 0xc5, 0xf1, 0x16, 0xcd, 0x6e, 0xfb, 0x27,
386 0x9e, 0xeb, 0x5b, 0xf6, 0x7e, 0xd7, 0xea, 0x50, 0xbc, 0xa4, 0xd3, 0x00, 0x8a, 0xda, 0x56, 0x5c,
387 0xd2, 0xb4, 0x07, 0x3d, 0x1a, 0xc0, 0x95, 0xb7, 0x46, 0x59, 0x8f, 0xfc, 0x12, 0x98, 0xee, 0x93,
388 0x3b, 0xa9, 0x4c, 0x8e, 0x80, 0x68, 0xd8, 0x0a, 0x83, 0x55, 0xcf, 0x3c, 0xab, 0x4b, 0xdf, 0x7d,
389 0x61, 0x54, 0xde, 0x4f, 0x19, 0xf8, 0x47, 0x03, 0x2d, 0xef, 0x51, 0x1e, 0xa1, 0x91, 0x97, 0xa5,
390 0x6c, 0x0d, 0x69, 0xd5, 0xe4, 0x2b, 0xd0, 0xf0, 0x18, 0x3f, 0x9c, 0x40, 0x43, 0x95, 0x01, 0x93,
391 0xd0, 0xf1, 0x16, 0x4e, 0x70, 0x11, 0xc8, 0x09, 0x05, 0x7c, 0x26, 0x97, 0x33, 0x3c, 0x49, 0x10,
392 0x04, 0xb3, 0x23, 0x8f, 0xaa, 0x11, 0x30, 0x16, 0x1b, 0xe0, 0x34, 0x42, 0x46, 0xaa, 0xc0, 0x78,
393 0x13, 0x5f, 0x1f, 0x87, 0x51, 0x50, 0x9d, 0xa1, 0xfc, 0x96, 0x38, 0x79, 0xbb, 0x63, 0xf6, 0x33,
394 0x75, 0xb0, 0x55, 0x3f, 0x2b, 0x93, 0xf6, 0xf3, 0xaf, 0x06, 0xca, 0x3f, 0x6d, 0x71, 0xe7, 0xd8,
395 0xe2, 0x14, 0x88, 0xe4, 0xf6, 0x30, 0x21, 0xfb, 0x2e, 0xb0, 0x7f, 0x45, 0x7e, 0x31, 0xc9, 0x30,
396 0xcb, 0xea, 0x3e, 0xf0, 0xa9, 0xbc, 0xfb, 0x8b, 0x81, 0x72, 0x35, 0x7a, 0x4c, 0x03, 0xfe, 0x7f,
397 0xd1, 0x12, 0x00, 0xb5, 0xd2, 0xf2, 0xde, 0x40, 0x4b, 0x91, 0xe9, 0xf7, 0xc2, 0x57, 0xd3, 0x9c,
398 0x44, 0x57, 0xe3, 0x88, 0xaa, 0x1a, 0xfd, 0x43, 0x9f, 0x32, 0x5e, 0x2c, 0xa5, 0xf8, 0x08, 0x79,
399 0xbe, 0xc7, 0xa8, 0x3e, 0xd3, 0xe0, 0x9b, 0x71, 0x89, 0x20, 0x83, 0x55, 0xb5, 0xbc, 0x86, 0x2c,
400 0xe3, 0x13, 0x34, 0xa7, 0xa7, 0x81, 0x9a, 0x85, 0xc5, 0x54, 0xf8, 0x31, 0xa8, 0xef, 0x66, 0x65,
401 0xa7, 0xa2, 0x96, 0x3f, 0x0d, 0x39, 0x05, 0xc5, 0x78, 0xac, 0x3e, 0x6d, 0xfa, 0x83, 0xe1, 0xe8,
402 0x04, 0x96, 0x3d, 0x8c, 0xc3, 0x07, 0x8b, 0x78, 0x94, 0x35, 0x29, 0x95, 0x08, 0x4b, 0x50, 0x36,
403 0xfa, 0x92, 0x4e, 0x07, 0xe1, 0x08, 0xcd, 0xec, 0x51, 0x7e, 0xe0, 0xf5, 0xf7, 0x65, 0x39, 0x3c,
404 0x17, 0x73, 0x9a, 0x6d, 0x60, 0x26, 0xb7, 0x80, 0x63, 0x03, 0x5f, 0x4d, 0x4d, 0x03, 0xdf, 0xeb,
405 0x6b, 0xdc, 0x33, 0x34, 0x1b, 0x99, 0x00, 0x1f, 0xde, 0xad, 0x07, 0x40, 0x79, 0x87, 0x64, 0x0d,
406 0xab, 0xa5, 0x68, 0x14, 0xb3, 0xd8, 0xac, 0x4f, 0xd0, 0xf4, 0x96, 0xdf, 0xed, 0x3a, 0xfc, 0x7f,
407 0xa4, 0x96, 0x8b, 0xce, 0x6d, 0x92, 0x35, 0xac, 0x2d, 0x20, 0x09, 0x11, 0x1f, 0xa2, 0xf9, 0xe1,
408 0x01, 0x2b, 0x79, 0x5f, 0x9d, 0xd5, 0x64, 0xf2, 0x82, 0x4a, 0x00, 0xbe, 0x8c, 0x8b, 0xa9, 0xc1,
409 0x94, 0x17, 0xd3, 0xd7, 0x28, 0x1f, 0x42, 0xec, 0x6e, 0xf9, 0x5e, 0xdb, 0xe9, 0x64, 0x0c, 0xd3,
410 0xc0, 0x7c, 0xce, 0x30, 0xf5, 0xba, 0x8d, 0x96, 0xc2, 0xf1, 0xd0, 0x92, 0x5c, 0x0e, 0xe2, 0x04,
411 0x49, 0xd0, 0xcc, 0xbd, 0x57, 0x5d, 0xaa, 0xc8, 0x79, 0x64, 0x22, 0x40, 0x2f, 0xc3, 0x01, 0x1a,
412 0xef, 0xce, 0x36, 0x3a, 0x4a, 0xf2, 0xae, 0x46, 0xd1, 0x62, 0x14, 0x76, 0x92, 0xeb, 0xc2, 0x26,
413 0x10, 0x10, 0xbc, 0x9e, 0x49, 0xa0, 0xaf, 0x09, 0xdf, 0x85, 0xd5, 0xcb, 0x47, 0xba, 0xac, 0x13,
414 0x74, 0x3e, 0xf9, 0xba, 0xc7, 0xb2, 0x8e, 0xab, 0xf2, 0x59, 0x10, 0xd7, 0xd0, 0xec, 0xe0, 0xd4,
415 0x2b, 0xfc, 0x63, 0x91, 0x49, 0xe0, 0x91, 0x0d, 0x80, 0x2b, 0xe1, 0xd5, 0x34, 0x38, 0x79, 0x04,
416 0xde, 0x45, 0x0b, 0x75, 0x1e, 0x50, 0xab, 0x7b, 0x68, 0xb5, 0x7e, 0xa0, 0x9c, 0x1d, 0xf4, 0x39,
417 0x5e, 0x8e, 0x04, 0x42, 0x1a, 0x0e, 0xfa, 0x3c, 0x73, 0x7c, 0x3f, 0xda, 0x34, 0xf0, 0x0e, 0x1c,
418 0xf4, 0xa9, 0x73, 0x4c, 0x15, 0xd0, 0xbe, 0x37, 0xe2, 0xad, 0x2d, 0x89, 0xbf, 0xef, 0x91, 0x8f,
419 0xee, 0x1b, 0xf8, 0x5b, 0x94, 0x57, 0x30, 0x5b, 0x6f, 0x2c, 0xaf, 0x43, 0xe1, 0x0d, 0x33, 0x3b,
420 0x88, 0x85, 0x08, 0x52, 0xa8, 0x09, 0x80, 0xbd, 0x46, 0x39, 0x79, 0xbc, 0x0f, 0xbd, 0x84, 0xe2,
421 0x94, 0xd7, 0xd1, 0x62, 0x4a, 0x1d, 0x59, 0x87, 0xd8, 0x15, 0xc9, 0x92, 0x8e, 0x5d, 0xe4, 0xa9,
422 0x55, 0xa6, 0xaa, 0xd8, 0x1e, 0xc2, 0xd8, 0xd1, 0x9b, 0x6e, 0x02, 0x33, 0x25, 0x55, 0x23, 0xa0,
423 0x72, 0x44, 0x9a, 0x28, 0x27, 0x67, 0xdc, 0x87, 0xa8, 0xbe, 0x01, 0x04, 0x57, 0x8b, 0x23, 0x08,
424 0x84, 0xf4, 0x16, 0xca, 0xc9, 0x13, 0xf4, 0x79, 0x1c, 0x59, 0x43, 0xae, 0x3a, 0x52, 0x19, 0xd5,
425 0x91, 0xef, 0xd1, 0x82, 0x98, 0x0c, 0xe1, 0x00, 0x8c, 0x98, 0x0d, 0x29, 0xd1, 0x5a, 0x03, 0x92,
426 0x15, 0x9c, 0x3e, 0x04, 0xf8, 0x19, 0x5c, 0x02, 0x53, 0xb6, 0xa5, 0xb9, 0xc8, 0xc1, 0x85, 0xe9,
427 0x9b, 0x05, 0x2e, 0x65, 0x1f, 0x4d, 0x18, 0xfe, 0x2d, 0xba, 0x54, 0xa7, 0x6e, 0xfb, 0x05, 0x65,
428 0x3c, 0x02, 0x56, 0xd0, 0x60, 0xda, 0x3a, 0x58, 0xfc, 0x6f, 0x02, 0xec, 0x3a, 0xb9, 0x92, 0x0a,
429 0xcb, 0xa8, 0xdb, 0x86, 0x8f, 0x28, 0xf8, 0x08, 0x4e, 0xd3, 0x91, 0x17, 0xf5, 0xf8, 0x9b, 0x48,
430 0xe2, 0xc9, 0x3d, 0x39, 0x75, 0x45, 0xa2, 0x0b, 0x3f, 0xf5, 0x18, 0xe2, 0x34, 0xf1, 0x77, 0x08,
431 0xef, 0x51, 0x1e, 0x7b, 0x66, 0x8f, 0x20, 0xa7, 0xbf, 0xc4, 0x27, 0xe3, 0x11, 0xc5, 0x86, 0x47,
432 0x7d, 0xcc, 0xd0, 0x6c, 0xdd, 0xe9, 0xf6, 0x5d, 0x8b, 0x53, 0x68, 0x8f, 0xcb, 0x83, 0x40, 0x84,
433 0xab, 0xf5, 0x36, 0x99, 0x71, 0x2a, 0x4c, 0x3c, 0x66, 0x45, 0x63, 0xa4, 0x90, 0x1a, 0x02, 0x49,
434 0xe4, 0xe5, 0x73, 0x84, 0xe4, 0x25, 0x1a, 0xde, 0x0e, 0x67, 0xc2, 0xbb, 0x61, 0x66, 0x2a, 0xaa,
435 0xd7, 0x07, 0x32, 0x27, 0xe0, 0x87, 0xad, 0xd5, 0xfb, 0x88, 0xba, 0x3a, 0x4f, 0x80, 0x37, 0xbc,
436 0xe4, 0x1f, 0x3f, 0xa8, 0x86, 0x9a, 0x0b, 0xc0, 0xef, 0xd1, 0xb4, 0x98, 0xf2, 0x6f, 0xf9, 0x91,
437 0xe5, 0xf6, 0x29, 0x5e, 0x35, 0x07, 0x9f, 0xf7, 0x4c, 0xa8, 0xa9, 0xf7, 0x68, 0xcb, 0x69, 0x3b,
438 0x34, 0x28, 0xae, 0x84, 0x4c, 0x35, 0xca, 0xfb, 0x81, 0x07, 0x0e, 0x8c, 0x94, 0x00, 0x7e, 0x09,
439 0xe7, 0x75, 0x44, 0xc2, 0x80, 0xaf, 0xd0, 0x74, 0x3d, 0x54, 0xcc, 0x27, 0xf0, 0x69, 0xb6, 0xee,
440 0x04, 0x70, 0x18, 0xc9, 0x46, 0xf9, 0x3a, 0xb7, 0x02, 0x7e, 0xd0, 0x6d, 0x39, 0x22, 0x89, 0xc5,
441 0xd1, 0xcb, 0xf7, 0xb0, 0x4a, 0x10, 0x5d, 0xab, 0x07, 0x13, 0xcb, 0xea, 0x48, 0xb6, 0xab, 0x19,
442 0x4f, 0x06, 0xcf, 0xfe, 0x4c, 0xe0, 0x35, 0x06, 0xdf, 0x0a, 0x45, 0x78, 0x7e, 0x34, 0xd0, 0xe2,
443 0x61, 0x9f, 0x1f, 0xf9, 0x4e, 0xaf, 0x0e, 0x9f, 0x34, 0x0f, 0xe5, 0xa7, 0x4a, 0x7c, 0xcf, 0x4c,
444 0xfb, 0xce, 0x99, 0xf0, 0xd3, 0xfc, 0x59, 0x5d, 0xd4, 0x33, 0x6e, 0x90, 0xb8, 0x29, 0xa8, 0x42,
445 0x47, 0x0f, 0xad, 0xc8, 0xe5, 0x2d, 0xa9, 0x64, 0xf0, 0xf8, 0xf4, 0x2d, 0x3d, 0xcd, 0xe4, 0x51,
446 0xef, 0x83, 0x95, 0xcd, 0x11, 0x3c, 0xd5, 0xb3, 0x1f, 0xe8, 0xe9, 0xe0, 0x5d, 0xe2, 0x1d, 0xc2,
447 0xaa, 0xe3, 0x2f, 0x19, 0x0d, 0x34, 0xd9, 0x6d, 0x33, 0xf9, 0xd5, 0x36, 0xe6, 0x73, 0x5e, 0x97,
448 0xf5, 0x43, 0xce, 0x6a, 0x44, 0x4a, 0x18, 0x51, 0x74, 0xd8, 0x45, 0x4b, 0xc3, 0x0e, 0x87, 0x15,
449 0x8c, 0xd5, 0x5d, 0x75, 0x2f, 0xaa, 0xdc, 0xcc, 0xe4, 0x88, 0x74, 0xf6, 0x6b, 0x17, 0xe5, 0xfd,
450 0xa0, 0x03, 0x5b, 0x6f, 0xcb, 0x0f, 0x6c, 0xf5, 0xa1, 0xeb, 0xeb, 0x19, 0xf9, 0x21, 0xee, 0x10,
451 0x3e, 0x22, 0xff, 0xde, 0xec, 0x38, 0xfc, 0x4d, 0xbf, 0x29, 0xf8, 0xab, 0xda, 0x53, 0xfd, 0xf7,
452 0x81, 0x7b, 0xfa, 0x93, 0xf6, 0x93, 0x6a, 0xc7, 0x57, 0x75, 0xff, 0x98, 0x5a, 0x3e, 0xd0, 0x78,
453 0x47, 0xe1, 0xef, 0x7a, 0x87, 0x53, 0xcd, 0x0b, 0xe0, 0xff, 0xe8, 0xbf, 0x01, 0x00, 0x00, 0xff,
454 0xff, 0xda, 0x32, 0x13, 0xef, 0x8c, 0x20, 0x00, 0x00,
William Kurkian1b363f42019-03-12 15:28:12 -0400455}
456
457// Reference imports to suppress errors if they are not otherwise used.
458var _ context.Context
459var _ grpc.ClientConn
460
461// This is a compile-time assertion to ensure that this generated file
462// is compatible with the grpc package it is being compiled against.
463const _ = grpc.SupportPackageIsVersion4
464
465// VolthaServiceClient is the client API for VolthaService service.
466//
467// For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
468type VolthaServiceClient interface {
William Kurkian1b363f42019-03-12 15:28:12 -0400469 // Get high level information on the Voltha cluster
470 GetVoltha(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*Voltha, error)
471 // List all Voltha cluster core instances
472 ListCoreInstances(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*CoreInstances, error)
473 // Get details on a Voltha cluster instance
474 GetCoreInstance(ctx context.Context, in *common.ID, opts ...grpc.CallOption) (*CoreInstance, error)
475 // List all active adapters (plugins) in the Voltha cluster
476 ListAdapters(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*Adapters, error)
477 // List all logical devices managed by the Voltha cluster
478 ListLogicalDevices(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*LogicalDevices, error)
479 // Get additional information on a given logical device
480 GetLogicalDevice(ctx context.Context, in *common.ID, opts ...grpc.CallOption) (*LogicalDevice, error)
481 // List ports of a logical device
482 ListLogicalDevicePorts(ctx context.Context, in *common.ID, opts ...grpc.CallOption) (*LogicalPorts, error)
483 // Gets a logical device port
484 GetLogicalDevicePort(ctx context.Context, in *LogicalPortId, opts ...grpc.CallOption) (*LogicalPort, error)
485 // Enables a logical device port
486 EnableLogicalDevicePort(ctx context.Context, in *LogicalPortId, opts ...grpc.CallOption) (*empty.Empty, error)
487 // Disables a logical device port
488 DisableLogicalDevicePort(ctx context.Context, in *LogicalPortId, opts ...grpc.CallOption) (*empty.Empty, error)
489 // List all flows of a logical device
490 ListLogicalDeviceFlows(ctx context.Context, in *common.ID, opts ...grpc.CallOption) (*openflow_13.Flows, error)
491 // Update flow table for logical device
492 UpdateLogicalDeviceFlowTable(ctx context.Context, in *openflow_13.FlowTableUpdate, opts ...grpc.CallOption) (*empty.Empty, error)
493 // Update meter table for logical device
494 UpdateLogicalDeviceMeterTable(ctx context.Context, in *openflow_13.MeterModUpdate, opts ...grpc.CallOption) (*empty.Empty, error)
Abhilash Laxmeshwardfbb74d2019-07-23 08:03:08 -0400495 // List all meters of a logical device
496 ListLogicalDeviceMeters(ctx context.Context, in *common.ID, opts ...grpc.CallOption) (*openflow_13.Meters, error)
William Kurkian1b363f42019-03-12 15:28:12 -0400497 // List all flow groups of a logical device
498 ListLogicalDeviceFlowGroups(ctx context.Context, in *common.ID, opts ...grpc.CallOption) (*openflow_13.FlowGroups, error)
499 // Update group table for device
500 UpdateLogicalDeviceFlowGroupTable(ctx context.Context, in *openflow_13.FlowGroupTableUpdate, opts ...grpc.CallOption) (*empty.Empty, error)
501 // List all physical devices controlled by the Voltha cluster
502 ListDevices(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*Devices, error)
503 // List all physical devices IDs controlled by the Voltha cluster
504 ListDeviceIds(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*common.IDs, error)
505 // Request to a voltha Core to reconcile a set of devices based on their IDs
506 ReconcileDevices(ctx context.Context, in *common.IDs, opts ...grpc.CallOption) (*empty.Empty, error)
507 // Get more information on a given physical device
508 GetDevice(ctx context.Context, in *common.ID, opts ...grpc.CallOption) (*Device, error)
509 // Pre-provision a new physical device
510 CreateDevice(ctx context.Context, in *Device, opts ...grpc.CallOption) (*Device, error)
511 // Enable a device. If the device was in pre-provisioned state then it
512 // will transition to ENABLED state. If it was is DISABLED state then it
513 // will transition to ENABLED state as well.
514 EnableDevice(ctx context.Context, in *common.ID, opts ...grpc.CallOption) (*empty.Empty, error)
515 // Disable a device
516 DisableDevice(ctx context.Context, in *common.ID, opts ...grpc.CallOption) (*empty.Empty, error)
517 // Reboot a device
518 RebootDevice(ctx context.Context, in *common.ID, opts ...grpc.CallOption) (*empty.Empty, error)
519 // Delete a device
520 DeleteDevice(ctx context.Context, in *common.ID, opts ...grpc.CallOption) (*empty.Empty, error)
Himani Chawla503b7ce2020-10-07 13:20:03 +0530521 // Forcefully delete a device
522 ForceDeleteDevice(ctx context.Context, in *common.ID, opts ...grpc.CallOption) (*empty.Empty, error)
William Kurkian1b363f42019-03-12 15:28:12 -0400523 // Request an image download to the standby partition
524 // of a device.
525 // Note that the call is expected to be non-blocking.
526 DownloadImage(ctx context.Context, in *ImageDownload, opts ...grpc.CallOption) (*common.OperationResp, error)
527 // Get image download status on a device
528 // The request retrieves progress on device and updates db record
Andrea Campanella9e94e8a2021-01-19 15:21:25 +0100529 // Deprecated in voltha 2.8, will be removed
William Kurkian1b363f42019-03-12 15:28:12 -0400530 GetImageDownloadStatus(ctx context.Context, in *ImageDownload, opts ...grpc.CallOption) (*ImageDownload, error)
531 // Get image download db record
Andrea Campanella9e94e8a2021-01-19 15:21:25 +0100532 // Deprecated in voltha 2.8, will be removed
William Kurkian1b363f42019-03-12 15:28:12 -0400533 GetImageDownload(ctx context.Context, in *ImageDownload, opts ...grpc.CallOption) (*ImageDownload, error)
534 // List image download db records for a given device
Andrea Campanella9e94e8a2021-01-19 15:21:25 +0100535 // Deprecated in voltha 2.8, will be removed
William Kurkian1b363f42019-03-12 15:28:12 -0400536 ListImageDownloads(ctx context.Context, in *common.ID, opts ...grpc.CallOption) (*ImageDownloads, error)
537 // Cancel an existing image download process on a device
Andrea Campanella9e94e8a2021-01-19 15:21:25 +0100538 // Deprecated in voltha 2.8, will be removed
William Kurkian1b363f42019-03-12 15:28:12 -0400539 CancelImageDownload(ctx context.Context, in *ImageDownload, opts ...grpc.CallOption) (*common.OperationResp, error)
540 // Activate the specified image at a standby partition
541 // to active partition.
542 // Depending on the device implementation, this call
543 // may or may not cause device reboot.
544 // If no reboot, then a reboot is required to make the
545 // activated image running on device
546 // Note that the call is expected to be non-blocking.
Andrea Campanella9e94e8a2021-01-19 15:21:25 +0100547 // Deprecated in voltha 2.8, will be removed
William Kurkian1b363f42019-03-12 15:28:12 -0400548 ActivateImageUpdate(ctx context.Context, in *ImageDownload, opts ...grpc.CallOption) (*common.OperationResp, error)
549 // Revert the specified image at standby partition
550 // to active partition, and revert to previous image
551 // Depending on the device implementation, this call
552 // may or may not cause device reboot.
553 // If no reboot, then a reboot is required to make the
554 // previous image running on device
555 // Note that the call is expected to be non-blocking.
Andrea Campanella9e94e8a2021-01-19 15:21:25 +0100556 // Deprecated in voltha 2.8, will be removed
William Kurkian1b363f42019-03-12 15:28:12 -0400557 RevertImageUpdate(ctx context.Context, in *ImageDownload, opts ...grpc.CallOption) (*common.OperationResp, error)
Andrea Campanella9e94e8a2021-01-19 15:21:25 +0100558 // Downloads a certain image to the standby partition of the devices
559 // Note that the call is expected to be non-blocking.
560 DownloadImageToDevice(ctx context.Context, in *DeviceImageDownloadRequest, opts ...grpc.CallOption) (*DeviceImageResponse, error)
561 // Get image status on a number of devices devices
562 // Polled from northbound systems to get state of download/activate/commit
563 GetImageStatus(ctx context.Context, in *DeviceImageRequest, opts ...grpc.CallOption) (*DeviceImageResponse, error)
564 // Aborts the upgrade of an image on a device
565 // To be used carefully, stops any further operations for the Image on the given devices
566 // Might also stop if possible existing work, but no guarantees are given,
567 // depends on implementation and procedure status.
568 AbortImageUpgradeToDevice(ctx context.Context, in *DeviceImageRequest, opts ...grpc.CallOption) (*DeviceImageResponse, error)
569 // Get Both Active and Standby image for a given device
570 GetOnuImages(ctx context.Context, in *common.ID, opts ...grpc.CallOption) (*OnuImages, error)
571 // Activate the specified image from a standby partition
572 // to active partition.
573 // Depending on the device implementation, this call
574 // may or may not cause device reboot.
575 // If no reboot, then a reboot is required to make the
576 // activated image running on device
577 // Note that the call is expected to be non-blocking.
578 ActivateImage(ctx context.Context, in *DeviceImageRequest, opts ...grpc.CallOption) (*DeviceImageResponse, error)
579 // Commit the specified image to be default.
580 // Depending on the device implementation, this call
581 // may or may not cause device reboot.
582 // If no reboot, then a reboot is required to make the
583 // activated image running on device upon next reboot
584 // Note that the call is expected to be non-blocking.
585 CommitImage(ctx context.Context, in *DeviceImageRequest, opts ...grpc.CallOption) (*DeviceImageResponse, error)
William Kurkian1b363f42019-03-12 15:28:12 -0400586 // List ports of a device
587 ListDevicePorts(ctx context.Context, in *common.ID, opts ...grpc.CallOption) (*Ports, error)
588 // List pm config of a device
589 ListDevicePmConfigs(ctx context.Context, in *common.ID, opts ...grpc.CallOption) (*PmConfigs, error)
590 // Update the pm config of a device
591 UpdateDevicePmConfigs(ctx context.Context, in *PmConfigs, opts ...grpc.CallOption) (*empty.Empty, error)
592 // List all flows of a device
593 ListDeviceFlows(ctx context.Context, in *common.ID, opts ...grpc.CallOption) (*openflow_13.Flows, error)
594 // List all flow groups of a device
595 ListDeviceFlowGroups(ctx context.Context, in *common.ID, opts ...grpc.CallOption) (*openflow_13.FlowGroups, error)
596 // List device types known to Voltha
597 ListDeviceTypes(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*DeviceTypes, error)
598 // Get additional information on a device type
599 GetDeviceType(ctx context.Context, in *common.ID, opts ...grpc.CallOption) (*DeviceType, error)
William Kurkian1b363f42019-03-12 15:28:12 -0400600 // Stream control packets to the dataplane
601 StreamPacketsOut(ctx context.Context, opts ...grpc.CallOption) (VolthaService_StreamPacketsOutClient, error)
602 // Receive control packet stream
603 ReceivePacketsIn(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (VolthaService_ReceivePacketsInClient, error)
604 ReceiveChangeEvents(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (VolthaService_ReceiveChangeEventsClient, error)
Devmalya Paul96a2c9e2019-11-06 07:17:44 +0000605 CreateEventFilter(ctx context.Context, in *EventFilter, opts ...grpc.CallOption) (*EventFilter, error)
606 // Get all filters present for a device
607 GetEventFilter(ctx context.Context, in *common.ID, opts ...grpc.CallOption) (*EventFilters, error)
608 UpdateEventFilter(ctx context.Context, in *EventFilter, opts ...grpc.CallOption) (*EventFilter, error)
609 DeleteEventFilter(ctx context.Context, in *EventFilter, opts ...grpc.CallOption) (*empty.Empty, error)
610 // Get all the filters present
611 ListEventFilters(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*EventFilters, error)
William Kurkian1b363f42019-03-12 15:28:12 -0400612 GetImages(ctx context.Context, in *common.ID, opts ...grpc.CallOption) (*Images, error)
613 SelfTest(ctx context.Context, in *common.ID, opts ...grpc.CallOption) (*SelfTestResponse, error)
614 // OpenOMCI MIB information
615 GetMibDeviceData(ctx context.Context, in *common.ID, opts ...grpc.CallOption) (*omci.MibDeviceData, error)
616 // OpenOMCI ALARM information
617 GetAlarmDeviceData(ctx context.Context, in *common.ID, opts ...grpc.CallOption) (*omci.AlarmDeviceData, error)
618 // Simulate an Alarm
619 SimulateAlarm(ctx context.Context, in *SimulateAlarmRequest, opts ...grpc.CallOption) (*common.OperationResp, error)
kesavand4a002b02020-01-23 21:29:47 -0500620 EnablePort(ctx context.Context, in *Port, opts ...grpc.CallOption) (*empty.Empty, error)
621 DisablePort(ctx context.Context, in *Port, opts ...grpc.CallOption) (*empty.Empty, error)
khenaidoo4c6543e2021-10-19 17:25:58 -0400622 GetExtValue(ctx context.Context, in *extension.ValueSpecifier, opts ...grpc.CallOption) (*extension.ReturnValues, error)
623 SetExtValue(ctx context.Context, in *extension.ValueSet, opts ...grpc.CallOption) (*empty.Empty, error)
onkar.kundargi7b85fa12020-02-27 13:19:22 +0530624 // omci start and stop cli implementation
khenaidoo4c6543e2021-10-19 17:25:58 -0400625 StartOmciTestAction(ctx context.Context, in *omci.OmciTestRequest, opts ...grpc.CallOption) (*omci.TestResponse, error)
yasin sapli2bbfbb42021-11-01 14:30:10 +0000626 // Saves or updates system wide configuration into voltha KV
627 PutVoipSystemProfile(ctx context.Context, in *voip_system_profile.VoipSystemProfileRequest, opts ...grpc.CallOption) (*empty.Empty, error)
628 // Deletes the given profile from voltha KV
629 DeleteVoipSystemProfile(ctx context.Context, in *common.Key, opts ...grpc.CallOption) (*empty.Empty, error)
630 // Saves or updates a profile (VOIP) into voltha KV
631 PutVoipUserProfile(ctx context.Context, in *voip_user_profile.VoipUserProfileRequest, opts ...grpc.CallOption) (*empty.Empty, error)
632 // Deletes the given profile from voltha KV
633 DeleteVoipUserProfile(ctx context.Context, in *common.Key, opts ...grpc.CallOption) (*empty.Empty, error)
William Kurkian1b363f42019-03-12 15:28:12 -0400634}
635
636type volthaServiceClient struct {
637 cc *grpc.ClientConn
638}
639
640func NewVolthaServiceClient(cc *grpc.ClientConn) VolthaServiceClient {
641 return &volthaServiceClient{cc}
642}
643
William Kurkian1b363f42019-03-12 15:28:12 -0400644func (c *volthaServiceClient) GetVoltha(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*Voltha, error) {
645 out := new(Voltha)
646 err := c.cc.Invoke(ctx, "/voltha.VolthaService/GetVoltha", in, out, opts...)
647 if err != nil {
648 return nil, err
649 }
650 return out, nil
651}
652
653func (c *volthaServiceClient) ListCoreInstances(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*CoreInstances, error) {
654 out := new(CoreInstances)
655 err := c.cc.Invoke(ctx, "/voltha.VolthaService/ListCoreInstances", in, out, opts...)
656 if err != nil {
657 return nil, err
658 }
659 return out, nil
660}
661
662func (c *volthaServiceClient) GetCoreInstance(ctx context.Context, in *common.ID, opts ...grpc.CallOption) (*CoreInstance, error) {
663 out := new(CoreInstance)
664 err := c.cc.Invoke(ctx, "/voltha.VolthaService/GetCoreInstance", in, out, opts...)
665 if err != nil {
666 return nil, err
667 }
668 return out, nil
669}
670
671func (c *volthaServiceClient) ListAdapters(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*Adapters, error) {
672 out := new(Adapters)
673 err := c.cc.Invoke(ctx, "/voltha.VolthaService/ListAdapters", in, out, opts...)
674 if err != nil {
675 return nil, err
676 }
677 return out, nil
678}
679
680func (c *volthaServiceClient) ListLogicalDevices(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*LogicalDevices, error) {
681 out := new(LogicalDevices)
682 err := c.cc.Invoke(ctx, "/voltha.VolthaService/ListLogicalDevices", in, out, opts...)
683 if err != nil {
684 return nil, err
685 }
686 return out, nil
687}
688
689func (c *volthaServiceClient) GetLogicalDevice(ctx context.Context, in *common.ID, opts ...grpc.CallOption) (*LogicalDevice, error) {
690 out := new(LogicalDevice)
691 err := c.cc.Invoke(ctx, "/voltha.VolthaService/GetLogicalDevice", in, out, opts...)
692 if err != nil {
693 return nil, err
694 }
695 return out, nil
696}
697
698func (c *volthaServiceClient) ListLogicalDevicePorts(ctx context.Context, in *common.ID, opts ...grpc.CallOption) (*LogicalPorts, error) {
699 out := new(LogicalPorts)
700 err := c.cc.Invoke(ctx, "/voltha.VolthaService/ListLogicalDevicePorts", in, out, opts...)
701 if err != nil {
702 return nil, err
703 }
704 return out, nil
705}
706
707func (c *volthaServiceClient) GetLogicalDevicePort(ctx context.Context, in *LogicalPortId, opts ...grpc.CallOption) (*LogicalPort, error) {
708 out := new(LogicalPort)
709 err := c.cc.Invoke(ctx, "/voltha.VolthaService/GetLogicalDevicePort", in, out, opts...)
710 if err != nil {
711 return nil, err
712 }
713 return out, nil
714}
715
716func (c *volthaServiceClient) EnableLogicalDevicePort(ctx context.Context, in *LogicalPortId, opts ...grpc.CallOption) (*empty.Empty, error) {
717 out := new(empty.Empty)
718 err := c.cc.Invoke(ctx, "/voltha.VolthaService/EnableLogicalDevicePort", in, out, opts...)
719 if err != nil {
720 return nil, err
721 }
722 return out, nil
723}
724
725func (c *volthaServiceClient) DisableLogicalDevicePort(ctx context.Context, in *LogicalPortId, opts ...grpc.CallOption) (*empty.Empty, error) {
726 out := new(empty.Empty)
727 err := c.cc.Invoke(ctx, "/voltha.VolthaService/DisableLogicalDevicePort", in, out, opts...)
728 if err != nil {
729 return nil, err
730 }
731 return out, nil
732}
733
734func (c *volthaServiceClient) ListLogicalDeviceFlows(ctx context.Context, in *common.ID, opts ...grpc.CallOption) (*openflow_13.Flows, error) {
735 out := new(openflow_13.Flows)
736 err := c.cc.Invoke(ctx, "/voltha.VolthaService/ListLogicalDeviceFlows", in, out, opts...)
737 if err != nil {
738 return nil, err
739 }
740 return out, nil
741}
742
743func (c *volthaServiceClient) UpdateLogicalDeviceFlowTable(ctx context.Context, in *openflow_13.FlowTableUpdate, opts ...grpc.CallOption) (*empty.Empty, error) {
744 out := new(empty.Empty)
745 err := c.cc.Invoke(ctx, "/voltha.VolthaService/UpdateLogicalDeviceFlowTable", in, out, opts...)
746 if err != nil {
747 return nil, err
748 }
749 return out, nil
750}
751
752func (c *volthaServiceClient) UpdateLogicalDeviceMeterTable(ctx context.Context, in *openflow_13.MeterModUpdate, opts ...grpc.CallOption) (*empty.Empty, error) {
753 out := new(empty.Empty)
754 err := c.cc.Invoke(ctx, "/voltha.VolthaService/UpdateLogicalDeviceMeterTable", in, out, opts...)
755 if err != nil {
756 return nil, err
757 }
758 return out, nil
759}
760
Abhilash Laxmeshwardfbb74d2019-07-23 08:03:08 -0400761func (c *volthaServiceClient) ListLogicalDeviceMeters(ctx context.Context, in *common.ID, opts ...grpc.CallOption) (*openflow_13.Meters, error) {
762 out := new(openflow_13.Meters)
763 err := c.cc.Invoke(ctx, "/voltha.VolthaService/ListLogicalDeviceMeters", in, out, opts...)
William Kurkian1b363f42019-03-12 15:28:12 -0400764 if err != nil {
765 return nil, err
766 }
767 return out, nil
768}
769
770func (c *volthaServiceClient) ListLogicalDeviceFlowGroups(ctx context.Context, in *common.ID, opts ...grpc.CallOption) (*openflow_13.FlowGroups, error) {
771 out := new(openflow_13.FlowGroups)
772 err := c.cc.Invoke(ctx, "/voltha.VolthaService/ListLogicalDeviceFlowGroups", in, out, opts...)
773 if err != nil {
774 return nil, err
775 }
776 return out, nil
777}
778
779func (c *volthaServiceClient) UpdateLogicalDeviceFlowGroupTable(ctx context.Context, in *openflow_13.FlowGroupTableUpdate, opts ...grpc.CallOption) (*empty.Empty, error) {
780 out := new(empty.Empty)
781 err := c.cc.Invoke(ctx, "/voltha.VolthaService/UpdateLogicalDeviceFlowGroupTable", in, out, opts...)
782 if err != nil {
783 return nil, err
784 }
785 return out, nil
786}
787
788func (c *volthaServiceClient) ListDevices(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*Devices, error) {
789 out := new(Devices)
790 err := c.cc.Invoke(ctx, "/voltha.VolthaService/ListDevices", in, out, opts...)
791 if err != nil {
792 return nil, err
793 }
794 return out, nil
795}
796
797func (c *volthaServiceClient) ListDeviceIds(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*common.IDs, error) {
798 out := new(common.IDs)
799 err := c.cc.Invoke(ctx, "/voltha.VolthaService/ListDeviceIds", in, out, opts...)
800 if err != nil {
801 return nil, err
802 }
803 return out, nil
804}
805
806func (c *volthaServiceClient) ReconcileDevices(ctx context.Context, in *common.IDs, opts ...grpc.CallOption) (*empty.Empty, error) {
807 out := new(empty.Empty)
808 err := c.cc.Invoke(ctx, "/voltha.VolthaService/ReconcileDevices", in, out, opts...)
809 if err != nil {
810 return nil, err
811 }
812 return out, nil
813}
814
815func (c *volthaServiceClient) GetDevice(ctx context.Context, in *common.ID, opts ...grpc.CallOption) (*Device, error) {
816 out := new(Device)
817 err := c.cc.Invoke(ctx, "/voltha.VolthaService/GetDevice", in, out, opts...)
818 if err != nil {
819 return nil, err
820 }
821 return out, nil
822}
823
824func (c *volthaServiceClient) CreateDevice(ctx context.Context, in *Device, opts ...grpc.CallOption) (*Device, error) {
825 out := new(Device)
826 err := c.cc.Invoke(ctx, "/voltha.VolthaService/CreateDevice", in, out, opts...)
827 if err != nil {
828 return nil, err
829 }
830 return out, nil
831}
832
833func (c *volthaServiceClient) EnableDevice(ctx context.Context, in *common.ID, opts ...grpc.CallOption) (*empty.Empty, error) {
834 out := new(empty.Empty)
835 err := c.cc.Invoke(ctx, "/voltha.VolthaService/EnableDevice", in, out, opts...)
836 if err != nil {
837 return nil, err
838 }
839 return out, nil
840}
841
842func (c *volthaServiceClient) DisableDevice(ctx context.Context, in *common.ID, opts ...grpc.CallOption) (*empty.Empty, error) {
843 out := new(empty.Empty)
844 err := c.cc.Invoke(ctx, "/voltha.VolthaService/DisableDevice", in, out, opts...)
845 if err != nil {
846 return nil, err
847 }
848 return out, nil
849}
850
851func (c *volthaServiceClient) RebootDevice(ctx context.Context, in *common.ID, opts ...grpc.CallOption) (*empty.Empty, error) {
852 out := new(empty.Empty)
853 err := c.cc.Invoke(ctx, "/voltha.VolthaService/RebootDevice", in, out, opts...)
854 if err != nil {
855 return nil, err
856 }
857 return out, nil
858}
859
860func (c *volthaServiceClient) DeleteDevice(ctx context.Context, in *common.ID, opts ...grpc.CallOption) (*empty.Empty, error) {
861 out := new(empty.Empty)
862 err := c.cc.Invoke(ctx, "/voltha.VolthaService/DeleteDevice", in, out, opts...)
863 if err != nil {
864 return nil, err
865 }
866 return out, nil
867}
868
Himani Chawla503b7ce2020-10-07 13:20:03 +0530869func (c *volthaServiceClient) ForceDeleteDevice(ctx context.Context, in *common.ID, opts ...grpc.CallOption) (*empty.Empty, error) {
870 out := new(empty.Empty)
871 err := c.cc.Invoke(ctx, "/voltha.VolthaService/ForceDeleteDevice", in, out, opts...)
872 if err != nil {
873 return nil, err
874 }
875 return out, nil
876}
877
khenaidoo4c6543e2021-10-19 17:25:58 -0400878// Deprecated: Do not use.
William Kurkian1b363f42019-03-12 15:28:12 -0400879func (c *volthaServiceClient) DownloadImage(ctx context.Context, in *ImageDownload, opts ...grpc.CallOption) (*common.OperationResp, error) {
880 out := new(common.OperationResp)
881 err := c.cc.Invoke(ctx, "/voltha.VolthaService/DownloadImage", in, out, opts...)
882 if err != nil {
883 return nil, err
884 }
885 return out, nil
886}
887
khenaidoo4c6543e2021-10-19 17:25:58 -0400888// Deprecated: Do not use.
William Kurkian1b363f42019-03-12 15:28:12 -0400889func (c *volthaServiceClient) GetImageDownloadStatus(ctx context.Context, in *ImageDownload, opts ...grpc.CallOption) (*ImageDownload, error) {
890 out := new(ImageDownload)
891 err := c.cc.Invoke(ctx, "/voltha.VolthaService/GetImageDownloadStatus", in, out, opts...)
892 if err != nil {
893 return nil, err
894 }
895 return out, nil
896}
897
khenaidoo4c6543e2021-10-19 17:25:58 -0400898// Deprecated: Do not use.
William Kurkian1b363f42019-03-12 15:28:12 -0400899func (c *volthaServiceClient) GetImageDownload(ctx context.Context, in *ImageDownload, opts ...grpc.CallOption) (*ImageDownload, error) {
900 out := new(ImageDownload)
901 err := c.cc.Invoke(ctx, "/voltha.VolthaService/GetImageDownload", in, out, opts...)
902 if err != nil {
903 return nil, err
904 }
905 return out, nil
906}
907
khenaidoo4c6543e2021-10-19 17:25:58 -0400908// Deprecated: Do not use.
William Kurkian1b363f42019-03-12 15:28:12 -0400909func (c *volthaServiceClient) ListImageDownloads(ctx context.Context, in *common.ID, opts ...grpc.CallOption) (*ImageDownloads, error) {
910 out := new(ImageDownloads)
911 err := c.cc.Invoke(ctx, "/voltha.VolthaService/ListImageDownloads", in, out, opts...)
912 if err != nil {
913 return nil, err
914 }
915 return out, nil
916}
917
khenaidoo4c6543e2021-10-19 17:25:58 -0400918// Deprecated: Do not use.
William Kurkian1b363f42019-03-12 15:28:12 -0400919func (c *volthaServiceClient) CancelImageDownload(ctx context.Context, in *ImageDownload, opts ...grpc.CallOption) (*common.OperationResp, error) {
920 out := new(common.OperationResp)
921 err := c.cc.Invoke(ctx, "/voltha.VolthaService/CancelImageDownload", in, out, opts...)
922 if err != nil {
923 return nil, err
924 }
925 return out, nil
926}
927
khenaidoo4c6543e2021-10-19 17:25:58 -0400928// Deprecated: Do not use.
William Kurkian1b363f42019-03-12 15:28:12 -0400929func (c *volthaServiceClient) ActivateImageUpdate(ctx context.Context, in *ImageDownload, opts ...grpc.CallOption) (*common.OperationResp, error) {
930 out := new(common.OperationResp)
931 err := c.cc.Invoke(ctx, "/voltha.VolthaService/ActivateImageUpdate", in, out, opts...)
932 if err != nil {
933 return nil, err
934 }
935 return out, nil
936}
937
khenaidoo4c6543e2021-10-19 17:25:58 -0400938// Deprecated: Do not use.
William Kurkian1b363f42019-03-12 15:28:12 -0400939func (c *volthaServiceClient) RevertImageUpdate(ctx context.Context, in *ImageDownload, opts ...grpc.CallOption) (*common.OperationResp, error) {
940 out := new(common.OperationResp)
941 err := c.cc.Invoke(ctx, "/voltha.VolthaService/RevertImageUpdate", in, out, opts...)
942 if err != nil {
943 return nil, err
944 }
945 return out, nil
946}
947
Andrea Campanella9e94e8a2021-01-19 15:21:25 +0100948func (c *volthaServiceClient) DownloadImageToDevice(ctx context.Context, in *DeviceImageDownloadRequest, opts ...grpc.CallOption) (*DeviceImageResponse, error) {
949 out := new(DeviceImageResponse)
950 err := c.cc.Invoke(ctx, "/voltha.VolthaService/DownloadImageToDevice", in, out, opts...)
951 if err != nil {
952 return nil, err
953 }
954 return out, nil
955}
956
957func (c *volthaServiceClient) GetImageStatus(ctx context.Context, in *DeviceImageRequest, opts ...grpc.CallOption) (*DeviceImageResponse, error) {
958 out := new(DeviceImageResponse)
959 err := c.cc.Invoke(ctx, "/voltha.VolthaService/GetImageStatus", in, out, opts...)
960 if err != nil {
961 return nil, err
962 }
963 return out, nil
964}
965
966func (c *volthaServiceClient) AbortImageUpgradeToDevice(ctx context.Context, in *DeviceImageRequest, opts ...grpc.CallOption) (*DeviceImageResponse, error) {
967 out := new(DeviceImageResponse)
968 err := c.cc.Invoke(ctx, "/voltha.VolthaService/AbortImageUpgradeToDevice", in, out, opts...)
969 if err != nil {
970 return nil, err
971 }
972 return out, nil
973}
974
975func (c *volthaServiceClient) GetOnuImages(ctx context.Context, in *common.ID, opts ...grpc.CallOption) (*OnuImages, error) {
976 out := new(OnuImages)
977 err := c.cc.Invoke(ctx, "/voltha.VolthaService/GetOnuImages", in, out, opts...)
978 if err != nil {
979 return nil, err
980 }
981 return out, nil
982}
983
984func (c *volthaServiceClient) ActivateImage(ctx context.Context, in *DeviceImageRequest, opts ...grpc.CallOption) (*DeviceImageResponse, error) {
985 out := new(DeviceImageResponse)
986 err := c.cc.Invoke(ctx, "/voltha.VolthaService/ActivateImage", in, out, opts...)
987 if err != nil {
988 return nil, err
989 }
990 return out, nil
991}
992
993func (c *volthaServiceClient) CommitImage(ctx context.Context, in *DeviceImageRequest, opts ...grpc.CallOption) (*DeviceImageResponse, error) {
994 out := new(DeviceImageResponse)
995 err := c.cc.Invoke(ctx, "/voltha.VolthaService/CommitImage", in, out, opts...)
996 if err != nil {
997 return nil, err
998 }
999 return out, nil
1000}
1001
William Kurkian1b363f42019-03-12 15:28:12 -04001002func (c *volthaServiceClient) ListDevicePorts(ctx context.Context, in *common.ID, opts ...grpc.CallOption) (*Ports, error) {
1003 out := new(Ports)
1004 err := c.cc.Invoke(ctx, "/voltha.VolthaService/ListDevicePorts", in, out, opts...)
1005 if err != nil {
1006 return nil, err
1007 }
1008 return out, nil
1009}
1010
1011func (c *volthaServiceClient) ListDevicePmConfigs(ctx context.Context, in *common.ID, opts ...grpc.CallOption) (*PmConfigs, error) {
1012 out := new(PmConfigs)
1013 err := c.cc.Invoke(ctx, "/voltha.VolthaService/ListDevicePmConfigs", in, out, opts...)
1014 if err != nil {
1015 return nil, err
1016 }
1017 return out, nil
1018}
1019
1020func (c *volthaServiceClient) UpdateDevicePmConfigs(ctx context.Context, in *PmConfigs, opts ...grpc.CallOption) (*empty.Empty, error) {
1021 out := new(empty.Empty)
1022 err := c.cc.Invoke(ctx, "/voltha.VolthaService/UpdateDevicePmConfigs", in, out, opts...)
1023 if err != nil {
1024 return nil, err
1025 }
1026 return out, nil
1027}
1028
1029func (c *volthaServiceClient) ListDeviceFlows(ctx context.Context, in *common.ID, opts ...grpc.CallOption) (*openflow_13.Flows, error) {
1030 out := new(openflow_13.Flows)
1031 err := c.cc.Invoke(ctx, "/voltha.VolthaService/ListDeviceFlows", in, out, opts...)
1032 if err != nil {
1033 return nil, err
1034 }
1035 return out, nil
1036}
1037
1038func (c *volthaServiceClient) ListDeviceFlowGroups(ctx context.Context, in *common.ID, opts ...grpc.CallOption) (*openflow_13.FlowGroups, error) {
1039 out := new(openflow_13.FlowGroups)
1040 err := c.cc.Invoke(ctx, "/voltha.VolthaService/ListDeviceFlowGroups", in, out, opts...)
1041 if err != nil {
1042 return nil, err
1043 }
1044 return out, nil
1045}
1046
1047func (c *volthaServiceClient) ListDeviceTypes(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*DeviceTypes, error) {
1048 out := new(DeviceTypes)
1049 err := c.cc.Invoke(ctx, "/voltha.VolthaService/ListDeviceTypes", in, out, opts...)
1050 if err != nil {
1051 return nil, err
1052 }
1053 return out, nil
1054}
1055
1056func (c *volthaServiceClient) GetDeviceType(ctx context.Context, in *common.ID, opts ...grpc.CallOption) (*DeviceType, error) {
1057 out := new(DeviceType)
1058 err := c.cc.Invoke(ctx, "/voltha.VolthaService/GetDeviceType", in, out, opts...)
1059 if err != nil {
1060 return nil, err
1061 }
1062 return out, nil
1063}
1064
William Kurkian1b363f42019-03-12 15:28:12 -04001065func (c *volthaServiceClient) StreamPacketsOut(ctx context.Context, opts ...grpc.CallOption) (VolthaService_StreamPacketsOutClient, error) {
1066 stream, err := c.cc.NewStream(ctx, &_VolthaService_serviceDesc.Streams[0], "/voltha.VolthaService/StreamPacketsOut", opts...)
1067 if err != nil {
1068 return nil, err
1069 }
1070 x := &volthaServiceStreamPacketsOutClient{stream}
1071 return x, nil
1072}
1073
1074type VolthaService_StreamPacketsOutClient interface {
1075 Send(*openflow_13.PacketOut) error
1076 CloseAndRecv() (*empty.Empty, error)
1077 grpc.ClientStream
1078}
1079
1080type volthaServiceStreamPacketsOutClient struct {
1081 grpc.ClientStream
1082}
1083
1084func (x *volthaServiceStreamPacketsOutClient) Send(m *openflow_13.PacketOut) error {
1085 return x.ClientStream.SendMsg(m)
1086}
1087
1088func (x *volthaServiceStreamPacketsOutClient) CloseAndRecv() (*empty.Empty, error) {
1089 if err := x.ClientStream.CloseSend(); err != nil {
1090 return nil, err
1091 }
1092 m := new(empty.Empty)
1093 if err := x.ClientStream.RecvMsg(m); err != nil {
1094 return nil, err
1095 }
1096 return m, nil
1097}
1098
1099func (c *volthaServiceClient) ReceivePacketsIn(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (VolthaService_ReceivePacketsInClient, error) {
1100 stream, err := c.cc.NewStream(ctx, &_VolthaService_serviceDesc.Streams[1], "/voltha.VolthaService/ReceivePacketsIn", opts...)
1101 if err != nil {
1102 return nil, err
1103 }
1104 x := &volthaServiceReceivePacketsInClient{stream}
1105 if err := x.ClientStream.SendMsg(in); err != nil {
1106 return nil, err
1107 }
1108 if err := x.ClientStream.CloseSend(); err != nil {
1109 return nil, err
1110 }
1111 return x, nil
1112}
1113
1114type VolthaService_ReceivePacketsInClient interface {
1115 Recv() (*openflow_13.PacketIn, error)
1116 grpc.ClientStream
1117}
1118
1119type volthaServiceReceivePacketsInClient struct {
1120 grpc.ClientStream
1121}
1122
1123func (x *volthaServiceReceivePacketsInClient) Recv() (*openflow_13.PacketIn, error) {
1124 m := new(openflow_13.PacketIn)
1125 if err := x.ClientStream.RecvMsg(m); err != nil {
1126 return nil, err
1127 }
1128 return m, nil
1129}
1130
1131func (c *volthaServiceClient) ReceiveChangeEvents(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (VolthaService_ReceiveChangeEventsClient, error) {
1132 stream, err := c.cc.NewStream(ctx, &_VolthaService_serviceDesc.Streams[2], "/voltha.VolthaService/ReceiveChangeEvents", opts...)
1133 if err != nil {
1134 return nil, err
1135 }
1136 x := &volthaServiceReceiveChangeEventsClient{stream}
1137 if err := x.ClientStream.SendMsg(in); err != nil {
1138 return nil, err
1139 }
1140 if err := x.ClientStream.CloseSend(); err != nil {
1141 return nil, err
1142 }
1143 return x, nil
1144}
1145
1146type VolthaService_ReceiveChangeEventsClient interface {
1147 Recv() (*openflow_13.ChangeEvent, error)
1148 grpc.ClientStream
1149}
1150
1151type volthaServiceReceiveChangeEventsClient struct {
1152 grpc.ClientStream
1153}
1154
1155func (x *volthaServiceReceiveChangeEventsClient) Recv() (*openflow_13.ChangeEvent, error) {
1156 m := new(openflow_13.ChangeEvent)
1157 if err := x.ClientStream.RecvMsg(m); err != nil {
1158 return nil, err
1159 }
1160 return m, nil
1161}
1162
Devmalya Paul96a2c9e2019-11-06 07:17:44 +00001163func (c *volthaServiceClient) CreateEventFilter(ctx context.Context, in *EventFilter, opts ...grpc.CallOption) (*EventFilter, error) {
1164 out := new(EventFilter)
1165 err := c.cc.Invoke(ctx, "/voltha.VolthaService/CreateEventFilter", in, out, opts...)
William Kurkian1b363f42019-03-12 15:28:12 -04001166 if err != nil {
1167 return nil, err
1168 }
1169 return out, nil
1170}
1171
Devmalya Paul96a2c9e2019-11-06 07:17:44 +00001172func (c *volthaServiceClient) GetEventFilter(ctx context.Context, in *common.ID, opts ...grpc.CallOption) (*EventFilters, error) {
1173 out := new(EventFilters)
1174 err := c.cc.Invoke(ctx, "/voltha.VolthaService/GetEventFilter", in, out, opts...)
William Kurkian1b363f42019-03-12 15:28:12 -04001175 if err != nil {
1176 return nil, err
1177 }
1178 return out, nil
1179}
1180
Devmalya Paul96a2c9e2019-11-06 07:17:44 +00001181func (c *volthaServiceClient) UpdateEventFilter(ctx context.Context, in *EventFilter, opts ...grpc.CallOption) (*EventFilter, error) {
1182 out := new(EventFilter)
1183 err := c.cc.Invoke(ctx, "/voltha.VolthaService/UpdateEventFilter", in, out, opts...)
William Kurkian1b363f42019-03-12 15:28:12 -04001184 if err != nil {
1185 return nil, err
1186 }
1187 return out, nil
1188}
1189
Devmalya Paul96a2c9e2019-11-06 07:17:44 +00001190func (c *volthaServiceClient) DeleteEventFilter(ctx context.Context, in *EventFilter, opts ...grpc.CallOption) (*empty.Empty, error) {
William Kurkian1b363f42019-03-12 15:28:12 -04001191 out := new(empty.Empty)
Devmalya Paul96a2c9e2019-11-06 07:17:44 +00001192 err := c.cc.Invoke(ctx, "/voltha.VolthaService/DeleteEventFilter", in, out, opts...)
William Kurkian1b363f42019-03-12 15:28:12 -04001193 if err != nil {
1194 return nil, err
1195 }
1196 return out, nil
1197}
1198
Devmalya Paul96a2c9e2019-11-06 07:17:44 +00001199func (c *volthaServiceClient) ListEventFilters(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*EventFilters, error) {
1200 out := new(EventFilters)
1201 err := c.cc.Invoke(ctx, "/voltha.VolthaService/ListEventFilters", in, out, opts...)
William Kurkian1b363f42019-03-12 15:28:12 -04001202 if err != nil {
1203 return nil, err
1204 }
1205 return out, nil
1206}
1207
1208func (c *volthaServiceClient) GetImages(ctx context.Context, in *common.ID, opts ...grpc.CallOption) (*Images, error) {
1209 out := new(Images)
1210 err := c.cc.Invoke(ctx, "/voltha.VolthaService/GetImages", in, out, opts...)
1211 if err != nil {
1212 return nil, err
1213 }
1214 return out, nil
1215}
1216
1217func (c *volthaServiceClient) SelfTest(ctx context.Context, in *common.ID, opts ...grpc.CallOption) (*SelfTestResponse, error) {
1218 out := new(SelfTestResponse)
1219 err := c.cc.Invoke(ctx, "/voltha.VolthaService/SelfTest", in, out, opts...)
1220 if err != nil {
1221 return nil, err
1222 }
1223 return out, nil
1224}
1225
1226func (c *volthaServiceClient) GetMibDeviceData(ctx context.Context, in *common.ID, opts ...grpc.CallOption) (*omci.MibDeviceData, error) {
1227 out := new(omci.MibDeviceData)
1228 err := c.cc.Invoke(ctx, "/voltha.VolthaService/GetMibDeviceData", in, out, opts...)
1229 if err != nil {
1230 return nil, err
1231 }
1232 return out, nil
1233}
1234
1235func (c *volthaServiceClient) GetAlarmDeviceData(ctx context.Context, in *common.ID, opts ...grpc.CallOption) (*omci.AlarmDeviceData, error) {
1236 out := new(omci.AlarmDeviceData)
1237 err := c.cc.Invoke(ctx, "/voltha.VolthaService/GetAlarmDeviceData", in, out, opts...)
1238 if err != nil {
1239 return nil, err
1240 }
1241 return out, nil
1242}
1243
1244func (c *volthaServiceClient) SimulateAlarm(ctx context.Context, in *SimulateAlarmRequest, opts ...grpc.CallOption) (*common.OperationResp, error) {
1245 out := new(common.OperationResp)
1246 err := c.cc.Invoke(ctx, "/voltha.VolthaService/SimulateAlarm", in, out, opts...)
1247 if err != nil {
1248 return nil, err
1249 }
1250 return out, nil
1251}
1252
kesavand4a002b02020-01-23 21:29:47 -05001253func (c *volthaServiceClient) EnablePort(ctx context.Context, in *Port, opts ...grpc.CallOption) (*empty.Empty, error) {
1254 out := new(empty.Empty)
1255 err := c.cc.Invoke(ctx, "/voltha.VolthaService/EnablePort", in, out, opts...)
1256 if err != nil {
1257 return nil, err
1258 }
1259 return out, nil
1260}
1261
1262func (c *volthaServiceClient) DisablePort(ctx context.Context, in *Port, opts ...grpc.CallOption) (*empty.Empty, error) {
1263 out := new(empty.Empty)
1264 err := c.cc.Invoke(ctx, "/voltha.VolthaService/DisablePort", in, out, opts...)
1265 if err != nil {
1266 return nil, err
1267 }
1268 return out, nil
1269}
1270
khenaidoo4c6543e2021-10-19 17:25:58 -04001271func (c *volthaServiceClient) GetExtValue(ctx context.Context, in *extension.ValueSpecifier, opts ...grpc.CallOption) (*extension.ReturnValues, error) {
1272 out := new(extension.ReturnValues)
Dinesh Belwalkared6da5e2020-02-25 11:23:57 -08001273 err := c.cc.Invoke(ctx, "/voltha.VolthaService/GetExtValue", in, out, opts...)
1274 if err != nil {
1275 return nil, err
1276 }
1277 return out, nil
1278}
1279
khenaidoo4c6543e2021-10-19 17:25:58 -04001280func (c *volthaServiceClient) SetExtValue(ctx context.Context, in *extension.ValueSet, opts ...grpc.CallOption) (*empty.Empty, error) {
dpaul2b52e712020-06-23 13:02:28 +05301281 out := new(empty.Empty)
1282 err := c.cc.Invoke(ctx, "/voltha.VolthaService/SetExtValue", in, out, opts...)
1283 if err != nil {
1284 return nil, err
1285 }
1286 return out, nil
1287}
1288
khenaidoo4c6543e2021-10-19 17:25:58 -04001289func (c *volthaServiceClient) StartOmciTestAction(ctx context.Context, in *omci.OmciTestRequest, opts ...grpc.CallOption) (*omci.TestResponse, error) {
1290 out := new(omci.TestResponse)
onkar.kundargi7b85fa12020-02-27 13:19:22 +05301291 err := c.cc.Invoke(ctx, "/voltha.VolthaService/StartOmciTestAction", in, out, opts...)
1292 if err != nil {
1293 return nil, err
1294 }
1295 return out, nil
1296}
1297
yasin sapli2bbfbb42021-11-01 14:30:10 +00001298func (c *volthaServiceClient) PutVoipSystemProfile(ctx context.Context, in *voip_system_profile.VoipSystemProfileRequest, opts ...grpc.CallOption) (*empty.Empty, error) {
1299 out := new(empty.Empty)
1300 err := c.cc.Invoke(ctx, "/voltha.VolthaService/PutVoipSystemProfile", in, out, opts...)
1301 if err != nil {
1302 return nil, err
1303 }
1304 return out, nil
1305}
1306
1307func (c *volthaServiceClient) DeleteVoipSystemProfile(ctx context.Context, in *common.Key, opts ...grpc.CallOption) (*empty.Empty, error) {
1308 out := new(empty.Empty)
1309 err := c.cc.Invoke(ctx, "/voltha.VolthaService/DeleteVoipSystemProfile", in, out, opts...)
1310 if err != nil {
1311 return nil, err
1312 }
1313 return out, nil
1314}
1315
1316func (c *volthaServiceClient) PutVoipUserProfile(ctx context.Context, in *voip_user_profile.VoipUserProfileRequest, opts ...grpc.CallOption) (*empty.Empty, error) {
1317 out := new(empty.Empty)
1318 err := c.cc.Invoke(ctx, "/voltha.VolthaService/PutVoipUserProfile", in, out, opts...)
1319 if err != nil {
1320 return nil, err
1321 }
1322 return out, nil
1323}
1324
1325func (c *volthaServiceClient) DeleteVoipUserProfile(ctx context.Context, in *common.Key, opts ...grpc.CallOption) (*empty.Empty, error) {
1326 out := new(empty.Empty)
1327 err := c.cc.Invoke(ctx, "/voltha.VolthaService/DeleteVoipUserProfile", in, out, opts...)
1328 if err != nil {
1329 return nil, err
1330 }
1331 return out, nil
1332}
1333
William Kurkian1b363f42019-03-12 15:28:12 -04001334// VolthaServiceServer is the server API for VolthaService service.
1335type VolthaServiceServer interface {
William Kurkian1b363f42019-03-12 15:28:12 -04001336 // Get high level information on the Voltha cluster
1337 GetVoltha(context.Context, *empty.Empty) (*Voltha, error)
1338 // List all Voltha cluster core instances
1339 ListCoreInstances(context.Context, *empty.Empty) (*CoreInstances, error)
1340 // Get details on a Voltha cluster instance
1341 GetCoreInstance(context.Context, *common.ID) (*CoreInstance, error)
1342 // List all active adapters (plugins) in the Voltha cluster
1343 ListAdapters(context.Context, *empty.Empty) (*Adapters, error)
1344 // List all logical devices managed by the Voltha cluster
1345 ListLogicalDevices(context.Context, *empty.Empty) (*LogicalDevices, error)
1346 // Get additional information on a given logical device
1347 GetLogicalDevice(context.Context, *common.ID) (*LogicalDevice, error)
1348 // List ports of a logical device
1349 ListLogicalDevicePorts(context.Context, *common.ID) (*LogicalPorts, error)
1350 // Gets a logical device port
1351 GetLogicalDevicePort(context.Context, *LogicalPortId) (*LogicalPort, error)
1352 // Enables a logical device port
1353 EnableLogicalDevicePort(context.Context, *LogicalPortId) (*empty.Empty, error)
1354 // Disables a logical device port
1355 DisableLogicalDevicePort(context.Context, *LogicalPortId) (*empty.Empty, error)
1356 // List all flows of a logical device
1357 ListLogicalDeviceFlows(context.Context, *common.ID) (*openflow_13.Flows, error)
1358 // Update flow table for logical device
1359 UpdateLogicalDeviceFlowTable(context.Context, *openflow_13.FlowTableUpdate) (*empty.Empty, error)
1360 // Update meter table for logical device
1361 UpdateLogicalDeviceMeterTable(context.Context, *openflow_13.MeterModUpdate) (*empty.Empty, error)
Abhilash Laxmeshwardfbb74d2019-07-23 08:03:08 -04001362 // List all meters of a logical device
1363 ListLogicalDeviceMeters(context.Context, *common.ID) (*openflow_13.Meters, error)
William Kurkian1b363f42019-03-12 15:28:12 -04001364 // List all flow groups of a logical device
1365 ListLogicalDeviceFlowGroups(context.Context, *common.ID) (*openflow_13.FlowGroups, error)
1366 // Update group table for device
1367 UpdateLogicalDeviceFlowGroupTable(context.Context, *openflow_13.FlowGroupTableUpdate) (*empty.Empty, error)
1368 // List all physical devices controlled by the Voltha cluster
1369 ListDevices(context.Context, *empty.Empty) (*Devices, error)
1370 // List all physical devices IDs controlled by the Voltha cluster
1371 ListDeviceIds(context.Context, *empty.Empty) (*common.IDs, error)
1372 // Request to a voltha Core to reconcile a set of devices based on their IDs
1373 ReconcileDevices(context.Context, *common.IDs) (*empty.Empty, error)
1374 // Get more information on a given physical device
1375 GetDevice(context.Context, *common.ID) (*Device, error)
1376 // Pre-provision a new physical device
1377 CreateDevice(context.Context, *Device) (*Device, error)
1378 // Enable a device. If the device was in pre-provisioned state then it
1379 // will transition to ENABLED state. If it was is DISABLED state then it
1380 // will transition to ENABLED state as well.
1381 EnableDevice(context.Context, *common.ID) (*empty.Empty, error)
1382 // Disable a device
1383 DisableDevice(context.Context, *common.ID) (*empty.Empty, error)
1384 // Reboot a device
1385 RebootDevice(context.Context, *common.ID) (*empty.Empty, error)
1386 // Delete a device
1387 DeleteDevice(context.Context, *common.ID) (*empty.Empty, error)
Himani Chawla503b7ce2020-10-07 13:20:03 +05301388 // Forcefully delete a device
1389 ForceDeleteDevice(context.Context, *common.ID) (*empty.Empty, error)
William Kurkian1b363f42019-03-12 15:28:12 -04001390 // Request an image download to the standby partition
1391 // of a device.
1392 // Note that the call is expected to be non-blocking.
1393 DownloadImage(context.Context, *ImageDownload) (*common.OperationResp, error)
1394 // Get image download status on a device
1395 // The request retrieves progress on device and updates db record
Andrea Campanella9e94e8a2021-01-19 15:21:25 +01001396 // Deprecated in voltha 2.8, will be removed
William Kurkian1b363f42019-03-12 15:28:12 -04001397 GetImageDownloadStatus(context.Context, *ImageDownload) (*ImageDownload, error)
1398 // Get image download db record
Andrea Campanella9e94e8a2021-01-19 15:21:25 +01001399 // Deprecated in voltha 2.8, will be removed
William Kurkian1b363f42019-03-12 15:28:12 -04001400 GetImageDownload(context.Context, *ImageDownload) (*ImageDownload, error)
1401 // List image download db records for a given device
Andrea Campanella9e94e8a2021-01-19 15:21:25 +01001402 // Deprecated in voltha 2.8, will be removed
William Kurkian1b363f42019-03-12 15:28:12 -04001403 ListImageDownloads(context.Context, *common.ID) (*ImageDownloads, error)
1404 // Cancel an existing image download process on a device
Andrea Campanella9e94e8a2021-01-19 15:21:25 +01001405 // Deprecated in voltha 2.8, will be removed
William Kurkian1b363f42019-03-12 15:28:12 -04001406 CancelImageDownload(context.Context, *ImageDownload) (*common.OperationResp, error)
1407 // Activate the specified image at a standby partition
1408 // to active partition.
1409 // Depending on the device implementation, this call
1410 // may or may not cause device reboot.
1411 // If no reboot, then a reboot is required to make the
1412 // activated image running on device
1413 // Note that the call is expected to be non-blocking.
Andrea Campanella9e94e8a2021-01-19 15:21:25 +01001414 // Deprecated in voltha 2.8, will be removed
William Kurkian1b363f42019-03-12 15:28:12 -04001415 ActivateImageUpdate(context.Context, *ImageDownload) (*common.OperationResp, error)
1416 // Revert the specified image at standby partition
1417 // to active partition, and revert to previous image
1418 // Depending on the device implementation, this call
1419 // may or may not cause device reboot.
1420 // If no reboot, then a reboot is required to make the
1421 // previous image running on device
1422 // Note that the call is expected to be non-blocking.
Andrea Campanella9e94e8a2021-01-19 15:21:25 +01001423 // Deprecated in voltha 2.8, will be removed
William Kurkian1b363f42019-03-12 15:28:12 -04001424 RevertImageUpdate(context.Context, *ImageDownload) (*common.OperationResp, error)
Andrea Campanella9e94e8a2021-01-19 15:21:25 +01001425 // Downloads a certain image to the standby partition of the devices
1426 // Note that the call is expected to be non-blocking.
1427 DownloadImageToDevice(context.Context, *DeviceImageDownloadRequest) (*DeviceImageResponse, error)
1428 // Get image status on a number of devices devices
1429 // Polled from northbound systems to get state of download/activate/commit
1430 GetImageStatus(context.Context, *DeviceImageRequest) (*DeviceImageResponse, error)
1431 // Aborts the upgrade of an image on a device
1432 // To be used carefully, stops any further operations for the Image on the given devices
1433 // Might also stop if possible existing work, but no guarantees are given,
1434 // depends on implementation and procedure status.
1435 AbortImageUpgradeToDevice(context.Context, *DeviceImageRequest) (*DeviceImageResponse, error)
1436 // Get Both Active and Standby image for a given device
1437 GetOnuImages(context.Context, *common.ID) (*OnuImages, error)
1438 // Activate the specified image from a standby partition
1439 // to active partition.
1440 // Depending on the device implementation, this call
1441 // may or may not cause device reboot.
1442 // If no reboot, then a reboot is required to make the
1443 // activated image running on device
1444 // Note that the call is expected to be non-blocking.
1445 ActivateImage(context.Context, *DeviceImageRequest) (*DeviceImageResponse, error)
1446 // Commit the specified image to be default.
1447 // Depending on the device implementation, this call
1448 // may or may not cause device reboot.
1449 // If no reboot, then a reboot is required to make the
1450 // activated image running on device upon next reboot
1451 // Note that the call is expected to be non-blocking.
1452 CommitImage(context.Context, *DeviceImageRequest) (*DeviceImageResponse, error)
William Kurkian1b363f42019-03-12 15:28:12 -04001453 // List ports of a device
1454 ListDevicePorts(context.Context, *common.ID) (*Ports, error)
1455 // List pm config of a device
1456 ListDevicePmConfigs(context.Context, *common.ID) (*PmConfigs, error)
1457 // Update the pm config of a device
1458 UpdateDevicePmConfigs(context.Context, *PmConfigs) (*empty.Empty, error)
1459 // List all flows of a device
1460 ListDeviceFlows(context.Context, *common.ID) (*openflow_13.Flows, error)
1461 // List all flow groups of a device
1462 ListDeviceFlowGroups(context.Context, *common.ID) (*openflow_13.FlowGroups, error)
1463 // List device types known to Voltha
1464 ListDeviceTypes(context.Context, *empty.Empty) (*DeviceTypes, error)
1465 // Get additional information on a device type
1466 GetDeviceType(context.Context, *common.ID) (*DeviceType, error)
William Kurkian1b363f42019-03-12 15:28:12 -04001467 // Stream control packets to the dataplane
1468 StreamPacketsOut(VolthaService_StreamPacketsOutServer) error
1469 // Receive control packet stream
1470 ReceivePacketsIn(*empty.Empty, VolthaService_ReceivePacketsInServer) error
1471 ReceiveChangeEvents(*empty.Empty, VolthaService_ReceiveChangeEventsServer) error
Devmalya Paul96a2c9e2019-11-06 07:17:44 +00001472 CreateEventFilter(context.Context, *EventFilter) (*EventFilter, error)
1473 // Get all filters present for a device
1474 GetEventFilter(context.Context, *common.ID) (*EventFilters, error)
1475 UpdateEventFilter(context.Context, *EventFilter) (*EventFilter, error)
1476 DeleteEventFilter(context.Context, *EventFilter) (*empty.Empty, error)
1477 // Get all the filters present
1478 ListEventFilters(context.Context, *empty.Empty) (*EventFilters, error)
William Kurkian1b363f42019-03-12 15:28:12 -04001479 GetImages(context.Context, *common.ID) (*Images, error)
1480 SelfTest(context.Context, *common.ID) (*SelfTestResponse, error)
1481 // OpenOMCI MIB information
1482 GetMibDeviceData(context.Context, *common.ID) (*omci.MibDeviceData, error)
1483 // OpenOMCI ALARM information
1484 GetAlarmDeviceData(context.Context, *common.ID) (*omci.AlarmDeviceData, error)
1485 // Simulate an Alarm
1486 SimulateAlarm(context.Context, *SimulateAlarmRequest) (*common.OperationResp, error)
kesavand4a002b02020-01-23 21:29:47 -05001487 EnablePort(context.Context, *Port) (*empty.Empty, error)
1488 DisablePort(context.Context, *Port) (*empty.Empty, error)
khenaidoo4c6543e2021-10-19 17:25:58 -04001489 GetExtValue(context.Context, *extension.ValueSpecifier) (*extension.ReturnValues, error)
1490 SetExtValue(context.Context, *extension.ValueSet) (*empty.Empty, error)
onkar.kundargi7b85fa12020-02-27 13:19:22 +05301491 // omci start and stop cli implementation
khenaidoo4c6543e2021-10-19 17:25:58 -04001492 StartOmciTestAction(context.Context, *omci.OmciTestRequest) (*omci.TestResponse, error)
yasin sapli2bbfbb42021-11-01 14:30:10 +00001493 // Saves or updates system wide configuration into voltha KV
1494 PutVoipSystemProfile(context.Context, *voip_system_profile.VoipSystemProfileRequest) (*empty.Empty, error)
1495 // Deletes the given profile from voltha KV
1496 DeleteVoipSystemProfile(context.Context, *common.Key) (*empty.Empty, error)
1497 // Saves or updates a profile (VOIP) into voltha KV
1498 PutVoipUserProfile(context.Context, *voip_user_profile.VoipUserProfileRequest) (*empty.Empty, error)
1499 // Deletes the given profile from voltha KV
1500 DeleteVoipUserProfile(context.Context, *common.Key) (*empty.Empty, error)
William Kurkian1b363f42019-03-12 15:28:12 -04001501}
1502
David K. Bainbridgec4bf5382021-04-08 16:06:54 +00001503// UnimplementedVolthaServiceServer can be embedded to have forward compatible implementations.
1504type UnimplementedVolthaServiceServer struct {
1505}
1506
David K. Bainbridgec4bf5382021-04-08 16:06:54 +00001507func (*UnimplementedVolthaServiceServer) GetVoltha(ctx context.Context, req *empty.Empty) (*Voltha, error) {
1508 return nil, status.Errorf(codes.Unimplemented, "method GetVoltha not implemented")
1509}
1510func (*UnimplementedVolthaServiceServer) ListCoreInstances(ctx context.Context, req *empty.Empty) (*CoreInstances, error) {
1511 return nil, status.Errorf(codes.Unimplemented, "method ListCoreInstances not implemented")
1512}
1513func (*UnimplementedVolthaServiceServer) GetCoreInstance(ctx context.Context, req *common.ID) (*CoreInstance, error) {
1514 return nil, status.Errorf(codes.Unimplemented, "method GetCoreInstance not implemented")
1515}
1516func (*UnimplementedVolthaServiceServer) ListAdapters(ctx context.Context, req *empty.Empty) (*Adapters, error) {
1517 return nil, status.Errorf(codes.Unimplemented, "method ListAdapters not implemented")
1518}
1519func (*UnimplementedVolthaServiceServer) ListLogicalDevices(ctx context.Context, req *empty.Empty) (*LogicalDevices, error) {
1520 return nil, status.Errorf(codes.Unimplemented, "method ListLogicalDevices not implemented")
1521}
1522func (*UnimplementedVolthaServiceServer) GetLogicalDevice(ctx context.Context, req *common.ID) (*LogicalDevice, error) {
1523 return nil, status.Errorf(codes.Unimplemented, "method GetLogicalDevice not implemented")
1524}
1525func (*UnimplementedVolthaServiceServer) ListLogicalDevicePorts(ctx context.Context, req *common.ID) (*LogicalPorts, error) {
1526 return nil, status.Errorf(codes.Unimplemented, "method ListLogicalDevicePorts not implemented")
1527}
1528func (*UnimplementedVolthaServiceServer) GetLogicalDevicePort(ctx context.Context, req *LogicalPortId) (*LogicalPort, error) {
1529 return nil, status.Errorf(codes.Unimplemented, "method GetLogicalDevicePort not implemented")
1530}
1531func (*UnimplementedVolthaServiceServer) EnableLogicalDevicePort(ctx context.Context, req *LogicalPortId) (*empty.Empty, error) {
1532 return nil, status.Errorf(codes.Unimplemented, "method EnableLogicalDevicePort not implemented")
1533}
1534func (*UnimplementedVolthaServiceServer) DisableLogicalDevicePort(ctx context.Context, req *LogicalPortId) (*empty.Empty, error) {
1535 return nil, status.Errorf(codes.Unimplemented, "method DisableLogicalDevicePort not implemented")
1536}
1537func (*UnimplementedVolthaServiceServer) ListLogicalDeviceFlows(ctx context.Context, req *common.ID) (*openflow_13.Flows, error) {
1538 return nil, status.Errorf(codes.Unimplemented, "method ListLogicalDeviceFlows not implemented")
1539}
1540func (*UnimplementedVolthaServiceServer) UpdateLogicalDeviceFlowTable(ctx context.Context, req *openflow_13.FlowTableUpdate) (*empty.Empty, error) {
1541 return nil, status.Errorf(codes.Unimplemented, "method UpdateLogicalDeviceFlowTable not implemented")
1542}
1543func (*UnimplementedVolthaServiceServer) UpdateLogicalDeviceMeterTable(ctx context.Context, req *openflow_13.MeterModUpdate) (*empty.Empty, error) {
1544 return nil, status.Errorf(codes.Unimplemented, "method UpdateLogicalDeviceMeterTable not implemented")
1545}
1546func (*UnimplementedVolthaServiceServer) ListLogicalDeviceMeters(ctx context.Context, req *common.ID) (*openflow_13.Meters, error) {
1547 return nil, status.Errorf(codes.Unimplemented, "method ListLogicalDeviceMeters not implemented")
1548}
1549func (*UnimplementedVolthaServiceServer) ListLogicalDeviceFlowGroups(ctx context.Context, req *common.ID) (*openflow_13.FlowGroups, error) {
1550 return nil, status.Errorf(codes.Unimplemented, "method ListLogicalDeviceFlowGroups not implemented")
1551}
1552func (*UnimplementedVolthaServiceServer) UpdateLogicalDeviceFlowGroupTable(ctx context.Context, req *openflow_13.FlowGroupTableUpdate) (*empty.Empty, error) {
1553 return nil, status.Errorf(codes.Unimplemented, "method UpdateLogicalDeviceFlowGroupTable not implemented")
1554}
1555func (*UnimplementedVolthaServiceServer) ListDevices(ctx context.Context, req *empty.Empty) (*Devices, error) {
1556 return nil, status.Errorf(codes.Unimplemented, "method ListDevices not implemented")
1557}
1558func (*UnimplementedVolthaServiceServer) ListDeviceIds(ctx context.Context, req *empty.Empty) (*common.IDs, error) {
1559 return nil, status.Errorf(codes.Unimplemented, "method ListDeviceIds not implemented")
1560}
1561func (*UnimplementedVolthaServiceServer) ReconcileDevices(ctx context.Context, req *common.IDs) (*empty.Empty, error) {
1562 return nil, status.Errorf(codes.Unimplemented, "method ReconcileDevices not implemented")
1563}
1564func (*UnimplementedVolthaServiceServer) GetDevice(ctx context.Context, req *common.ID) (*Device, error) {
1565 return nil, status.Errorf(codes.Unimplemented, "method GetDevice not implemented")
1566}
1567func (*UnimplementedVolthaServiceServer) CreateDevice(ctx context.Context, req *Device) (*Device, error) {
1568 return nil, status.Errorf(codes.Unimplemented, "method CreateDevice not implemented")
1569}
1570func (*UnimplementedVolthaServiceServer) EnableDevice(ctx context.Context, req *common.ID) (*empty.Empty, error) {
1571 return nil, status.Errorf(codes.Unimplemented, "method EnableDevice not implemented")
1572}
1573func (*UnimplementedVolthaServiceServer) DisableDevice(ctx context.Context, req *common.ID) (*empty.Empty, error) {
1574 return nil, status.Errorf(codes.Unimplemented, "method DisableDevice not implemented")
1575}
1576func (*UnimplementedVolthaServiceServer) RebootDevice(ctx context.Context, req *common.ID) (*empty.Empty, error) {
1577 return nil, status.Errorf(codes.Unimplemented, "method RebootDevice not implemented")
1578}
1579func (*UnimplementedVolthaServiceServer) DeleteDevice(ctx context.Context, req *common.ID) (*empty.Empty, error) {
1580 return nil, status.Errorf(codes.Unimplemented, "method DeleteDevice not implemented")
1581}
1582func (*UnimplementedVolthaServiceServer) ForceDeleteDevice(ctx context.Context, req *common.ID) (*empty.Empty, error) {
1583 return nil, status.Errorf(codes.Unimplemented, "method ForceDeleteDevice not implemented")
1584}
1585func (*UnimplementedVolthaServiceServer) DownloadImage(ctx context.Context, req *ImageDownload) (*common.OperationResp, error) {
1586 return nil, status.Errorf(codes.Unimplemented, "method DownloadImage not implemented")
1587}
1588func (*UnimplementedVolthaServiceServer) GetImageDownloadStatus(ctx context.Context, req *ImageDownload) (*ImageDownload, error) {
1589 return nil, status.Errorf(codes.Unimplemented, "method GetImageDownloadStatus not implemented")
1590}
1591func (*UnimplementedVolthaServiceServer) GetImageDownload(ctx context.Context, req *ImageDownload) (*ImageDownload, error) {
1592 return nil, status.Errorf(codes.Unimplemented, "method GetImageDownload not implemented")
1593}
1594func (*UnimplementedVolthaServiceServer) ListImageDownloads(ctx context.Context, req *common.ID) (*ImageDownloads, error) {
1595 return nil, status.Errorf(codes.Unimplemented, "method ListImageDownloads not implemented")
1596}
1597func (*UnimplementedVolthaServiceServer) CancelImageDownload(ctx context.Context, req *ImageDownload) (*common.OperationResp, error) {
1598 return nil, status.Errorf(codes.Unimplemented, "method CancelImageDownload not implemented")
1599}
1600func (*UnimplementedVolthaServiceServer) ActivateImageUpdate(ctx context.Context, req *ImageDownload) (*common.OperationResp, error) {
1601 return nil, status.Errorf(codes.Unimplemented, "method ActivateImageUpdate not implemented")
1602}
1603func (*UnimplementedVolthaServiceServer) RevertImageUpdate(ctx context.Context, req *ImageDownload) (*common.OperationResp, error) {
1604 return nil, status.Errorf(codes.Unimplemented, "method RevertImageUpdate not implemented")
1605}
Andrea Campanella9e94e8a2021-01-19 15:21:25 +01001606func (*UnimplementedVolthaServiceServer) DownloadImageToDevice(ctx context.Context, req *DeviceImageDownloadRequest) (*DeviceImageResponse, error) {
1607 return nil, status.Errorf(codes.Unimplemented, "method DownloadImageToDevice not implemented")
1608}
1609func (*UnimplementedVolthaServiceServer) GetImageStatus(ctx context.Context, req *DeviceImageRequest) (*DeviceImageResponse, error) {
1610 return nil, status.Errorf(codes.Unimplemented, "method GetImageStatus not implemented")
1611}
1612func (*UnimplementedVolthaServiceServer) AbortImageUpgradeToDevice(ctx context.Context, req *DeviceImageRequest) (*DeviceImageResponse, error) {
1613 return nil, status.Errorf(codes.Unimplemented, "method AbortImageUpgradeToDevice not implemented")
1614}
1615func (*UnimplementedVolthaServiceServer) GetOnuImages(ctx context.Context, req *common.ID) (*OnuImages, error) {
1616 return nil, status.Errorf(codes.Unimplemented, "method GetOnuImages not implemented")
1617}
1618func (*UnimplementedVolthaServiceServer) ActivateImage(ctx context.Context, req *DeviceImageRequest) (*DeviceImageResponse, error) {
1619 return nil, status.Errorf(codes.Unimplemented, "method ActivateImage not implemented")
1620}
1621func (*UnimplementedVolthaServiceServer) CommitImage(ctx context.Context, req *DeviceImageRequest) (*DeviceImageResponse, error) {
1622 return nil, status.Errorf(codes.Unimplemented, "method CommitImage not implemented")
1623}
David K. Bainbridgec4bf5382021-04-08 16:06:54 +00001624func (*UnimplementedVolthaServiceServer) ListDevicePorts(ctx context.Context, req *common.ID) (*Ports, error) {
1625 return nil, status.Errorf(codes.Unimplemented, "method ListDevicePorts not implemented")
1626}
1627func (*UnimplementedVolthaServiceServer) ListDevicePmConfigs(ctx context.Context, req *common.ID) (*PmConfigs, error) {
1628 return nil, status.Errorf(codes.Unimplemented, "method ListDevicePmConfigs not implemented")
1629}
1630func (*UnimplementedVolthaServiceServer) UpdateDevicePmConfigs(ctx context.Context, req *PmConfigs) (*empty.Empty, error) {
1631 return nil, status.Errorf(codes.Unimplemented, "method UpdateDevicePmConfigs not implemented")
1632}
1633func (*UnimplementedVolthaServiceServer) ListDeviceFlows(ctx context.Context, req *common.ID) (*openflow_13.Flows, error) {
1634 return nil, status.Errorf(codes.Unimplemented, "method ListDeviceFlows not implemented")
1635}
1636func (*UnimplementedVolthaServiceServer) ListDeviceFlowGroups(ctx context.Context, req *common.ID) (*openflow_13.FlowGroups, error) {
1637 return nil, status.Errorf(codes.Unimplemented, "method ListDeviceFlowGroups not implemented")
1638}
1639func (*UnimplementedVolthaServiceServer) ListDeviceTypes(ctx context.Context, req *empty.Empty) (*DeviceTypes, error) {
1640 return nil, status.Errorf(codes.Unimplemented, "method ListDeviceTypes not implemented")
1641}
1642func (*UnimplementedVolthaServiceServer) GetDeviceType(ctx context.Context, req *common.ID) (*DeviceType, error) {
1643 return nil, status.Errorf(codes.Unimplemented, "method GetDeviceType not implemented")
1644}
David K. Bainbridgec4bf5382021-04-08 16:06:54 +00001645func (*UnimplementedVolthaServiceServer) StreamPacketsOut(srv VolthaService_StreamPacketsOutServer) error {
1646 return status.Errorf(codes.Unimplemented, "method StreamPacketsOut not implemented")
1647}
1648func (*UnimplementedVolthaServiceServer) ReceivePacketsIn(req *empty.Empty, srv VolthaService_ReceivePacketsInServer) error {
1649 return status.Errorf(codes.Unimplemented, "method ReceivePacketsIn not implemented")
1650}
1651func (*UnimplementedVolthaServiceServer) ReceiveChangeEvents(req *empty.Empty, srv VolthaService_ReceiveChangeEventsServer) error {
1652 return status.Errorf(codes.Unimplemented, "method ReceiveChangeEvents not implemented")
1653}
David K. Bainbridgec4bf5382021-04-08 16:06:54 +00001654func (*UnimplementedVolthaServiceServer) CreateEventFilter(ctx context.Context, req *EventFilter) (*EventFilter, error) {
1655 return nil, status.Errorf(codes.Unimplemented, "method CreateEventFilter not implemented")
1656}
1657func (*UnimplementedVolthaServiceServer) GetEventFilter(ctx context.Context, req *common.ID) (*EventFilters, error) {
1658 return nil, status.Errorf(codes.Unimplemented, "method GetEventFilter not implemented")
1659}
1660func (*UnimplementedVolthaServiceServer) UpdateEventFilter(ctx context.Context, req *EventFilter) (*EventFilter, error) {
1661 return nil, status.Errorf(codes.Unimplemented, "method UpdateEventFilter not implemented")
1662}
1663func (*UnimplementedVolthaServiceServer) DeleteEventFilter(ctx context.Context, req *EventFilter) (*empty.Empty, error) {
1664 return nil, status.Errorf(codes.Unimplemented, "method DeleteEventFilter not implemented")
1665}
1666func (*UnimplementedVolthaServiceServer) ListEventFilters(ctx context.Context, req *empty.Empty) (*EventFilters, error) {
1667 return nil, status.Errorf(codes.Unimplemented, "method ListEventFilters not implemented")
1668}
1669func (*UnimplementedVolthaServiceServer) GetImages(ctx context.Context, req *common.ID) (*Images, error) {
1670 return nil, status.Errorf(codes.Unimplemented, "method GetImages not implemented")
1671}
1672func (*UnimplementedVolthaServiceServer) SelfTest(ctx context.Context, req *common.ID) (*SelfTestResponse, error) {
1673 return nil, status.Errorf(codes.Unimplemented, "method SelfTest not implemented")
1674}
1675func (*UnimplementedVolthaServiceServer) GetMibDeviceData(ctx context.Context, req *common.ID) (*omci.MibDeviceData, error) {
1676 return nil, status.Errorf(codes.Unimplemented, "method GetMibDeviceData not implemented")
1677}
1678func (*UnimplementedVolthaServiceServer) GetAlarmDeviceData(ctx context.Context, req *common.ID) (*omci.AlarmDeviceData, error) {
1679 return nil, status.Errorf(codes.Unimplemented, "method GetAlarmDeviceData not implemented")
1680}
1681func (*UnimplementedVolthaServiceServer) SimulateAlarm(ctx context.Context, req *SimulateAlarmRequest) (*common.OperationResp, error) {
1682 return nil, status.Errorf(codes.Unimplemented, "method SimulateAlarm not implemented")
1683}
David K. Bainbridgec4bf5382021-04-08 16:06:54 +00001684func (*UnimplementedVolthaServiceServer) EnablePort(ctx context.Context, req *Port) (*empty.Empty, error) {
1685 return nil, status.Errorf(codes.Unimplemented, "method EnablePort not implemented")
1686}
1687func (*UnimplementedVolthaServiceServer) DisablePort(ctx context.Context, req *Port) (*empty.Empty, error) {
1688 return nil, status.Errorf(codes.Unimplemented, "method DisablePort not implemented")
1689}
khenaidoo4c6543e2021-10-19 17:25:58 -04001690func (*UnimplementedVolthaServiceServer) GetExtValue(ctx context.Context, req *extension.ValueSpecifier) (*extension.ReturnValues, error) {
David K. Bainbridgec4bf5382021-04-08 16:06:54 +00001691 return nil, status.Errorf(codes.Unimplemented, "method GetExtValue not implemented")
1692}
khenaidoo4c6543e2021-10-19 17:25:58 -04001693func (*UnimplementedVolthaServiceServer) SetExtValue(ctx context.Context, req *extension.ValueSet) (*empty.Empty, error) {
David K. Bainbridgec4bf5382021-04-08 16:06:54 +00001694 return nil, status.Errorf(codes.Unimplemented, "method SetExtValue not implemented")
1695}
khenaidoo4c6543e2021-10-19 17:25:58 -04001696func (*UnimplementedVolthaServiceServer) StartOmciTestAction(ctx context.Context, req *omci.OmciTestRequest) (*omci.TestResponse, error) {
David K. Bainbridgec4bf5382021-04-08 16:06:54 +00001697 return nil, status.Errorf(codes.Unimplemented, "method StartOmciTestAction not implemented")
1698}
yasin sapli2bbfbb42021-11-01 14:30:10 +00001699func (*UnimplementedVolthaServiceServer) PutVoipSystemProfile(ctx context.Context, req *voip_system_profile.VoipSystemProfileRequest) (*empty.Empty, error) {
1700 return nil, status.Errorf(codes.Unimplemented, "method PutVoipSystemProfile not implemented")
1701}
1702func (*UnimplementedVolthaServiceServer) DeleteVoipSystemProfile(ctx context.Context, req *common.Key) (*empty.Empty, error) {
1703 return nil, status.Errorf(codes.Unimplemented, "method DeleteVoipSystemProfile not implemented")
1704}
1705func (*UnimplementedVolthaServiceServer) PutVoipUserProfile(ctx context.Context, req *voip_user_profile.VoipUserProfileRequest) (*empty.Empty, error) {
1706 return nil, status.Errorf(codes.Unimplemented, "method PutVoipUserProfile not implemented")
1707}
1708func (*UnimplementedVolthaServiceServer) DeleteVoipUserProfile(ctx context.Context, req *common.Key) (*empty.Empty, error) {
1709 return nil, status.Errorf(codes.Unimplemented, "method DeleteVoipUserProfile not implemented")
1710}
David K. Bainbridgec4bf5382021-04-08 16:06:54 +00001711
William Kurkian1b363f42019-03-12 15:28:12 -04001712func RegisterVolthaServiceServer(s *grpc.Server, srv VolthaServiceServer) {
1713 s.RegisterService(&_VolthaService_serviceDesc, srv)
1714}
1715
William Kurkian1b363f42019-03-12 15:28:12 -04001716func _VolthaService_GetVoltha_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
1717 in := new(empty.Empty)
1718 if err := dec(in); err != nil {
1719 return nil, err
1720 }
1721 if interceptor == nil {
1722 return srv.(VolthaServiceServer).GetVoltha(ctx, in)
1723 }
1724 info := &grpc.UnaryServerInfo{
1725 Server: srv,
1726 FullMethod: "/voltha.VolthaService/GetVoltha",
1727 }
1728 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
1729 return srv.(VolthaServiceServer).GetVoltha(ctx, req.(*empty.Empty))
1730 }
1731 return interceptor(ctx, in, info, handler)
1732}
1733
1734func _VolthaService_ListCoreInstances_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
1735 in := new(empty.Empty)
1736 if err := dec(in); err != nil {
1737 return nil, err
1738 }
1739 if interceptor == nil {
1740 return srv.(VolthaServiceServer).ListCoreInstances(ctx, in)
1741 }
1742 info := &grpc.UnaryServerInfo{
1743 Server: srv,
1744 FullMethod: "/voltha.VolthaService/ListCoreInstances",
1745 }
1746 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
1747 return srv.(VolthaServiceServer).ListCoreInstances(ctx, req.(*empty.Empty))
1748 }
1749 return interceptor(ctx, in, info, handler)
1750}
1751
1752func _VolthaService_GetCoreInstance_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
1753 in := new(common.ID)
1754 if err := dec(in); err != nil {
1755 return nil, err
1756 }
1757 if interceptor == nil {
1758 return srv.(VolthaServiceServer).GetCoreInstance(ctx, in)
1759 }
1760 info := &grpc.UnaryServerInfo{
1761 Server: srv,
1762 FullMethod: "/voltha.VolthaService/GetCoreInstance",
1763 }
1764 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
1765 return srv.(VolthaServiceServer).GetCoreInstance(ctx, req.(*common.ID))
1766 }
1767 return interceptor(ctx, in, info, handler)
1768}
1769
1770func _VolthaService_ListAdapters_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
1771 in := new(empty.Empty)
1772 if err := dec(in); err != nil {
1773 return nil, err
1774 }
1775 if interceptor == nil {
1776 return srv.(VolthaServiceServer).ListAdapters(ctx, in)
1777 }
1778 info := &grpc.UnaryServerInfo{
1779 Server: srv,
1780 FullMethod: "/voltha.VolthaService/ListAdapters",
1781 }
1782 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
1783 return srv.(VolthaServiceServer).ListAdapters(ctx, req.(*empty.Empty))
1784 }
1785 return interceptor(ctx, in, info, handler)
1786}
1787
1788func _VolthaService_ListLogicalDevices_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
1789 in := new(empty.Empty)
1790 if err := dec(in); err != nil {
1791 return nil, err
1792 }
1793 if interceptor == nil {
1794 return srv.(VolthaServiceServer).ListLogicalDevices(ctx, in)
1795 }
1796 info := &grpc.UnaryServerInfo{
1797 Server: srv,
1798 FullMethod: "/voltha.VolthaService/ListLogicalDevices",
1799 }
1800 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
1801 return srv.(VolthaServiceServer).ListLogicalDevices(ctx, req.(*empty.Empty))
1802 }
1803 return interceptor(ctx, in, info, handler)
1804}
1805
1806func _VolthaService_GetLogicalDevice_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
1807 in := new(common.ID)
1808 if err := dec(in); err != nil {
1809 return nil, err
1810 }
1811 if interceptor == nil {
1812 return srv.(VolthaServiceServer).GetLogicalDevice(ctx, in)
1813 }
1814 info := &grpc.UnaryServerInfo{
1815 Server: srv,
1816 FullMethod: "/voltha.VolthaService/GetLogicalDevice",
1817 }
1818 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
1819 return srv.(VolthaServiceServer).GetLogicalDevice(ctx, req.(*common.ID))
1820 }
1821 return interceptor(ctx, in, info, handler)
1822}
1823
1824func _VolthaService_ListLogicalDevicePorts_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
1825 in := new(common.ID)
1826 if err := dec(in); err != nil {
1827 return nil, err
1828 }
1829 if interceptor == nil {
1830 return srv.(VolthaServiceServer).ListLogicalDevicePorts(ctx, in)
1831 }
1832 info := &grpc.UnaryServerInfo{
1833 Server: srv,
1834 FullMethod: "/voltha.VolthaService/ListLogicalDevicePorts",
1835 }
1836 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
1837 return srv.(VolthaServiceServer).ListLogicalDevicePorts(ctx, req.(*common.ID))
1838 }
1839 return interceptor(ctx, in, info, handler)
1840}
1841
1842func _VolthaService_GetLogicalDevicePort_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
1843 in := new(LogicalPortId)
1844 if err := dec(in); err != nil {
1845 return nil, err
1846 }
1847 if interceptor == nil {
1848 return srv.(VolthaServiceServer).GetLogicalDevicePort(ctx, in)
1849 }
1850 info := &grpc.UnaryServerInfo{
1851 Server: srv,
1852 FullMethod: "/voltha.VolthaService/GetLogicalDevicePort",
1853 }
1854 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
1855 return srv.(VolthaServiceServer).GetLogicalDevicePort(ctx, req.(*LogicalPortId))
1856 }
1857 return interceptor(ctx, in, info, handler)
1858}
1859
1860func _VolthaService_EnableLogicalDevicePort_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
1861 in := new(LogicalPortId)
1862 if err := dec(in); err != nil {
1863 return nil, err
1864 }
1865 if interceptor == nil {
1866 return srv.(VolthaServiceServer).EnableLogicalDevicePort(ctx, in)
1867 }
1868 info := &grpc.UnaryServerInfo{
1869 Server: srv,
1870 FullMethod: "/voltha.VolthaService/EnableLogicalDevicePort",
1871 }
1872 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
1873 return srv.(VolthaServiceServer).EnableLogicalDevicePort(ctx, req.(*LogicalPortId))
1874 }
1875 return interceptor(ctx, in, info, handler)
1876}
1877
1878func _VolthaService_DisableLogicalDevicePort_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
1879 in := new(LogicalPortId)
1880 if err := dec(in); err != nil {
1881 return nil, err
1882 }
1883 if interceptor == nil {
1884 return srv.(VolthaServiceServer).DisableLogicalDevicePort(ctx, in)
1885 }
1886 info := &grpc.UnaryServerInfo{
1887 Server: srv,
1888 FullMethod: "/voltha.VolthaService/DisableLogicalDevicePort",
1889 }
1890 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
1891 return srv.(VolthaServiceServer).DisableLogicalDevicePort(ctx, req.(*LogicalPortId))
1892 }
1893 return interceptor(ctx, in, info, handler)
1894}
1895
1896func _VolthaService_ListLogicalDeviceFlows_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
1897 in := new(common.ID)
1898 if err := dec(in); err != nil {
1899 return nil, err
1900 }
1901 if interceptor == nil {
1902 return srv.(VolthaServiceServer).ListLogicalDeviceFlows(ctx, in)
1903 }
1904 info := &grpc.UnaryServerInfo{
1905 Server: srv,
1906 FullMethod: "/voltha.VolthaService/ListLogicalDeviceFlows",
1907 }
1908 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
1909 return srv.(VolthaServiceServer).ListLogicalDeviceFlows(ctx, req.(*common.ID))
1910 }
1911 return interceptor(ctx, in, info, handler)
1912}
1913
1914func _VolthaService_UpdateLogicalDeviceFlowTable_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
1915 in := new(openflow_13.FlowTableUpdate)
1916 if err := dec(in); err != nil {
1917 return nil, err
1918 }
1919 if interceptor == nil {
1920 return srv.(VolthaServiceServer).UpdateLogicalDeviceFlowTable(ctx, in)
1921 }
1922 info := &grpc.UnaryServerInfo{
1923 Server: srv,
1924 FullMethod: "/voltha.VolthaService/UpdateLogicalDeviceFlowTable",
1925 }
1926 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
1927 return srv.(VolthaServiceServer).UpdateLogicalDeviceFlowTable(ctx, req.(*openflow_13.FlowTableUpdate))
1928 }
1929 return interceptor(ctx, in, info, handler)
1930}
1931
1932func _VolthaService_UpdateLogicalDeviceMeterTable_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
1933 in := new(openflow_13.MeterModUpdate)
1934 if err := dec(in); err != nil {
1935 return nil, err
1936 }
1937 if interceptor == nil {
1938 return srv.(VolthaServiceServer).UpdateLogicalDeviceMeterTable(ctx, in)
1939 }
1940 info := &grpc.UnaryServerInfo{
1941 Server: srv,
1942 FullMethod: "/voltha.VolthaService/UpdateLogicalDeviceMeterTable",
1943 }
1944 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
1945 return srv.(VolthaServiceServer).UpdateLogicalDeviceMeterTable(ctx, req.(*openflow_13.MeterModUpdate))
1946 }
1947 return interceptor(ctx, in, info, handler)
1948}
1949
Abhilash Laxmeshwardfbb74d2019-07-23 08:03:08 -04001950func _VolthaService_ListLogicalDeviceMeters_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
William Kurkian1b363f42019-03-12 15:28:12 -04001951 in := new(common.ID)
1952 if err := dec(in); err != nil {
1953 return nil, err
1954 }
1955 if interceptor == nil {
Abhilash Laxmeshwardfbb74d2019-07-23 08:03:08 -04001956 return srv.(VolthaServiceServer).ListLogicalDeviceMeters(ctx, in)
William Kurkian1b363f42019-03-12 15:28:12 -04001957 }
1958 info := &grpc.UnaryServerInfo{
1959 Server: srv,
Abhilash Laxmeshwardfbb74d2019-07-23 08:03:08 -04001960 FullMethod: "/voltha.VolthaService/ListLogicalDeviceMeters",
William Kurkian1b363f42019-03-12 15:28:12 -04001961 }
1962 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
Abhilash Laxmeshwardfbb74d2019-07-23 08:03:08 -04001963 return srv.(VolthaServiceServer).ListLogicalDeviceMeters(ctx, req.(*common.ID))
William Kurkian1b363f42019-03-12 15:28:12 -04001964 }
1965 return interceptor(ctx, in, info, handler)
1966}
1967
1968func _VolthaService_ListLogicalDeviceFlowGroups_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
1969 in := new(common.ID)
1970 if err := dec(in); err != nil {
1971 return nil, err
1972 }
1973 if interceptor == nil {
1974 return srv.(VolthaServiceServer).ListLogicalDeviceFlowGroups(ctx, in)
1975 }
1976 info := &grpc.UnaryServerInfo{
1977 Server: srv,
1978 FullMethod: "/voltha.VolthaService/ListLogicalDeviceFlowGroups",
1979 }
1980 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
1981 return srv.(VolthaServiceServer).ListLogicalDeviceFlowGroups(ctx, req.(*common.ID))
1982 }
1983 return interceptor(ctx, in, info, handler)
1984}
1985
1986func _VolthaService_UpdateLogicalDeviceFlowGroupTable_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
1987 in := new(openflow_13.FlowGroupTableUpdate)
1988 if err := dec(in); err != nil {
1989 return nil, err
1990 }
1991 if interceptor == nil {
1992 return srv.(VolthaServiceServer).UpdateLogicalDeviceFlowGroupTable(ctx, in)
1993 }
1994 info := &grpc.UnaryServerInfo{
1995 Server: srv,
1996 FullMethod: "/voltha.VolthaService/UpdateLogicalDeviceFlowGroupTable",
1997 }
1998 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
1999 return srv.(VolthaServiceServer).UpdateLogicalDeviceFlowGroupTable(ctx, req.(*openflow_13.FlowGroupTableUpdate))
2000 }
2001 return interceptor(ctx, in, info, handler)
2002}
2003
2004func _VolthaService_ListDevices_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
2005 in := new(empty.Empty)
2006 if err := dec(in); err != nil {
2007 return nil, err
2008 }
2009 if interceptor == nil {
2010 return srv.(VolthaServiceServer).ListDevices(ctx, in)
2011 }
2012 info := &grpc.UnaryServerInfo{
2013 Server: srv,
2014 FullMethod: "/voltha.VolthaService/ListDevices",
2015 }
2016 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
2017 return srv.(VolthaServiceServer).ListDevices(ctx, req.(*empty.Empty))
2018 }
2019 return interceptor(ctx, in, info, handler)
2020}
2021
2022func _VolthaService_ListDeviceIds_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
2023 in := new(empty.Empty)
2024 if err := dec(in); err != nil {
2025 return nil, err
2026 }
2027 if interceptor == nil {
2028 return srv.(VolthaServiceServer).ListDeviceIds(ctx, in)
2029 }
2030 info := &grpc.UnaryServerInfo{
2031 Server: srv,
2032 FullMethod: "/voltha.VolthaService/ListDeviceIds",
2033 }
2034 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
2035 return srv.(VolthaServiceServer).ListDeviceIds(ctx, req.(*empty.Empty))
2036 }
2037 return interceptor(ctx, in, info, handler)
2038}
2039
2040func _VolthaService_ReconcileDevices_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
2041 in := new(common.IDs)
2042 if err := dec(in); err != nil {
2043 return nil, err
2044 }
2045 if interceptor == nil {
2046 return srv.(VolthaServiceServer).ReconcileDevices(ctx, in)
2047 }
2048 info := &grpc.UnaryServerInfo{
2049 Server: srv,
2050 FullMethod: "/voltha.VolthaService/ReconcileDevices",
2051 }
2052 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
2053 return srv.(VolthaServiceServer).ReconcileDevices(ctx, req.(*common.IDs))
2054 }
2055 return interceptor(ctx, in, info, handler)
2056}
2057
2058func _VolthaService_GetDevice_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
2059 in := new(common.ID)
2060 if err := dec(in); err != nil {
2061 return nil, err
2062 }
2063 if interceptor == nil {
2064 return srv.(VolthaServiceServer).GetDevice(ctx, in)
2065 }
2066 info := &grpc.UnaryServerInfo{
2067 Server: srv,
2068 FullMethod: "/voltha.VolthaService/GetDevice",
2069 }
2070 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
2071 return srv.(VolthaServiceServer).GetDevice(ctx, req.(*common.ID))
2072 }
2073 return interceptor(ctx, in, info, handler)
2074}
2075
2076func _VolthaService_CreateDevice_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
2077 in := new(Device)
2078 if err := dec(in); err != nil {
2079 return nil, err
2080 }
2081 if interceptor == nil {
2082 return srv.(VolthaServiceServer).CreateDevice(ctx, in)
2083 }
2084 info := &grpc.UnaryServerInfo{
2085 Server: srv,
2086 FullMethod: "/voltha.VolthaService/CreateDevice",
2087 }
2088 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
2089 return srv.(VolthaServiceServer).CreateDevice(ctx, req.(*Device))
2090 }
2091 return interceptor(ctx, in, info, handler)
2092}
2093
2094func _VolthaService_EnableDevice_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
2095 in := new(common.ID)
2096 if err := dec(in); err != nil {
2097 return nil, err
2098 }
2099 if interceptor == nil {
2100 return srv.(VolthaServiceServer).EnableDevice(ctx, in)
2101 }
2102 info := &grpc.UnaryServerInfo{
2103 Server: srv,
2104 FullMethod: "/voltha.VolthaService/EnableDevice",
2105 }
2106 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
2107 return srv.(VolthaServiceServer).EnableDevice(ctx, req.(*common.ID))
2108 }
2109 return interceptor(ctx, in, info, handler)
2110}
2111
2112func _VolthaService_DisableDevice_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
2113 in := new(common.ID)
2114 if err := dec(in); err != nil {
2115 return nil, err
2116 }
2117 if interceptor == nil {
2118 return srv.(VolthaServiceServer).DisableDevice(ctx, in)
2119 }
2120 info := &grpc.UnaryServerInfo{
2121 Server: srv,
2122 FullMethod: "/voltha.VolthaService/DisableDevice",
2123 }
2124 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
2125 return srv.(VolthaServiceServer).DisableDevice(ctx, req.(*common.ID))
2126 }
2127 return interceptor(ctx, in, info, handler)
2128}
2129
2130func _VolthaService_RebootDevice_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
2131 in := new(common.ID)
2132 if err := dec(in); err != nil {
2133 return nil, err
2134 }
2135 if interceptor == nil {
2136 return srv.(VolthaServiceServer).RebootDevice(ctx, in)
2137 }
2138 info := &grpc.UnaryServerInfo{
2139 Server: srv,
2140 FullMethod: "/voltha.VolthaService/RebootDevice",
2141 }
2142 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
2143 return srv.(VolthaServiceServer).RebootDevice(ctx, req.(*common.ID))
2144 }
2145 return interceptor(ctx, in, info, handler)
2146}
2147
2148func _VolthaService_DeleteDevice_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
2149 in := new(common.ID)
2150 if err := dec(in); err != nil {
2151 return nil, err
2152 }
2153 if interceptor == nil {
2154 return srv.(VolthaServiceServer).DeleteDevice(ctx, in)
2155 }
2156 info := &grpc.UnaryServerInfo{
2157 Server: srv,
2158 FullMethod: "/voltha.VolthaService/DeleteDevice",
2159 }
2160 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
2161 return srv.(VolthaServiceServer).DeleteDevice(ctx, req.(*common.ID))
2162 }
2163 return interceptor(ctx, in, info, handler)
2164}
2165
Himani Chawla503b7ce2020-10-07 13:20:03 +05302166func _VolthaService_ForceDeleteDevice_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
2167 in := new(common.ID)
2168 if err := dec(in); err != nil {
2169 return nil, err
2170 }
2171 if interceptor == nil {
2172 return srv.(VolthaServiceServer).ForceDeleteDevice(ctx, in)
2173 }
2174 info := &grpc.UnaryServerInfo{
2175 Server: srv,
2176 FullMethod: "/voltha.VolthaService/ForceDeleteDevice",
2177 }
2178 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
2179 return srv.(VolthaServiceServer).ForceDeleteDevice(ctx, req.(*common.ID))
2180 }
2181 return interceptor(ctx, in, info, handler)
2182}
2183
William Kurkian1b363f42019-03-12 15:28:12 -04002184func _VolthaService_DownloadImage_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
2185 in := new(ImageDownload)
2186 if err := dec(in); err != nil {
2187 return nil, err
2188 }
2189 if interceptor == nil {
2190 return srv.(VolthaServiceServer).DownloadImage(ctx, in)
2191 }
2192 info := &grpc.UnaryServerInfo{
2193 Server: srv,
2194 FullMethod: "/voltha.VolthaService/DownloadImage",
2195 }
2196 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
2197 return srv.(VolthaServiceServer).DownloadImage(ctx, req.(*ImageDownload))
2198 }
2199 return interceptor(ctx, in, info, handler)
2200}
2201
2202func _VolthaService_GetImageDownloadStatus_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
2203 in := new(ImageDownload)
2204 if err := dec(in); err != nil {
2205 return nil, err
2206 }
2207 if interceptor == nil {
2208 return srv.(VolthaServiceServer).GetImageDownloadStatus(ctx, in)
2209 }
2210 info := &grpc.UnaryServerInfo{
2211 Server: srv,
2212 FullMethod: "/voltha.VolthaService/GetImageDownloadStatus",
2213 }
2214 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
2215 return srv.(VolthaServiceServer).GetImageDownloadStatus(ctx, req.(*ImageDownload))
2216 }
2217 return interceptor(ctx, in, info, handler)
2218}
2219
2220func _VolthaService_GetImageDownload_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
2221 in := new(ImageDownload)
2222 if err := dec(in); err != nil {
2223 return nil, err
2224 }
2225 if interceptor == nil {
2226 return srv.(VolthaServiceServer).GetImageDownload(ctx, in)
2227 }
2228 info := &grpc.UnaryServerInfo{
2229 Server: srv,
2230 FullMethod: "/voltha.VolthaService/GetImageDownload",
2231 }
2232 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
2233 return srv.(VolthaServiceServer).GetImageDownload(ctx, req.(*ImageDownload))
2234 }
2235 return interceptor(ctx, in, info, handler)
2236}
2237
2238func _VolthaService_ListImageDownloads_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
2239 in := new(common.ID)
2240 if err := dec(in); err != nil {
2241 return nil, err
2242 }
2243 if interceptor == nil {
2244 return srv.(VolthaServiceServer).ListImageDownloads(ctx, in)
2245 }
2246 info := &grpc.UnaryServerInfo{
2247 Server: srv,
2248 FullMethod: "/voltha.VolthaService/ListImageDownloads",
2249 }
2250 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
2251 return srv.(VolthaServiceServer).ListImageDownloads(ctx, req.(*common.ID))
2252 }
2253 return interceptor(ctx, in, info, handler)
2254}
2255
2256func _VolthaService_CancelImageDownload_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
2257 in := new(ImageDownload)
2258 if err := dec(in); err != nil {
2259 return nil, err
2260 }
2261 if interceptor == nil {
2262 return srv.(VolthaServiceServer).CancelImageDownload(ctx, in)
2263 }
2264 info := &grpc.UnaryServerInfo{
2265 Server: srv,
2266 FullMethod: "/voltha.VolthaService/CancelImageDownload",
2267 }
2268 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
2269 return srv.(VolthaServiceServer).CancelImageDownload(ctx, req.(*ImageDownload))
2270 }
2271 return interceptor(ctx, in, info, handler)
2272}
2273
2274func _VolthaService_ActivateImageUpdate_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
2275 in := new(ImageDownload)
2276 if err := dec(in); err != nil {
2277 return nil, err
2278 }
2279 if interceptor == nil {
2280 return srv.(VolthaServiceServer).ActivateImageUpdate(ctx, in)
2281 }
2282 info := &grpc.UnaryServerInfo{
2283 Server: srv,
2284 FullMethod: "/voltha.VolthaService/ActivateImageUpdate",
2285 }
2286 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
2287 return srv.(VolthaServiceServer).ActivateImageUpdate(ctx, req.(*ImageDownload))
2288 }
2289 return interceptor(ctx, in, info, handler)
2290}
2291
2292func _VolthaService_RevertImageUpdate_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
2293 in := new(ImageDownload)
2294 if err := dec(in); err != nil {
2295 return nil, err
2296 }
2297 if interceptor == nil {
2298 return srv.(VolthaServiceServer).RevertImageUpdate(ctx, in)
2299 }
2300 info := &grpc.UnaryServerInfo{
2301 Server: srv,
2302 FullMethod: "/voltha.VolthaService/RevertImageUpdate",
2303 }
2304 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
2305 return srv.(VolthaServiceServer).RevertImageUpdate(ctx, req.(*ImageDownload))
2306 }
2307 return interceptor(ctx, in, info, handler)
2308}
2309
Andrea Campanella9e94e8a2021-01-19 15:21:25 +01002310func _VolthaService_DownloadImageToDevice_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
2311 in := new(DeviceImageDownloadRequest)
2312 if err := dec(in); err != nil {
2313 return nil, err
2314 }
2315 if interceptor == nil {
2316 return srv.(VolthaServiceServer).DownloadImageToDevice(ctx, in)
2317 }
2318 info := &grpc.UnaryServerInfo{
2319 Server: srv,
2320 FullMethod: "/voltha.VolthaService/DownloadImageToDevice",
2321 }
2322 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
2323 return srv.(VolthaServiceServer).DownloadImageToDevice(ctx, req.(*DeviceImageDownloadRequest))
2324 }
2325 return interceptor(ctx, in, info, handler)
2326}
2327
2328func _VolthaService_GetImageStatus_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
2329 in := new(DeviceImageRequest)
2330 if err := dec(in); err != nil {
2331 return nil, err
2332 }
2333 if interceptor == nil {
2334 return srv.(VolthaServiceServer).GetImageStatus(ctx, in)
2335 }
2336 info := &grpc.UnaryServerInfo{
2337 Server: srv,
2338 FullMethod: "/voltha.VolthaService/GetImageStatus",
2339 }
2340 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
2341 return srv.(VolthaServiceServer).GetImageStatus(ctx, req.(*DeviceImageRequest))
2342 }
2343 return interceptor(ctx, in, info, handler)
2344}
2345
2346func _VolthaService_AbortImageUpgradeToDevice_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
2347 in := new(DeviceImageRequest)
2348 if err := dec(in); err != nil {
2349 return nil, err
2350 }
2351 if interceptor == nil {
2352 return srv.(VolthaServiceServer).AbortImageUpgradeToDevice(ctx, in)
2353 }
2354 info := &grpc.UnaryServerInfo{
2355 Server: srv,
2356 FullMethod: "/voltha.VolthaService/AbortImageUpgradeToDevice",
2357 }
2358 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
2359 return srv.(VolthaServiceServer).AbortImageUpgradeToDevice(ctx, req.(*DeviceImageRequest))
2360 }
2361 return interceptor(ctx, in, info, handler)
2362}
2363
2364func _VolthaService_GetOnuImages_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
2365 in := new(common.ID)
2366 if err := dec(in); err != nil {
2367 return nil, err
2368 }
2369 if interceptor == nil {
2370 return srv.(VolthaServiceServer).GetOnuImages(ctx, in)
2371 }
2372 info := &grpc.UnaryServerInfo{
2373 Server: srv,
2374 FullMethod: "/voltha.VolthaService/GetOnuImages",
2375 }
2376 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
2377 return srv.(VolthaServiceServer).GetOnuImages(ctx, req.(*common.ID))
2378 }
2379 return interceptor(ctx, in, info, handler)
2380}
2381
2382func _VolthaService_ActivateImage_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
2383 in := new(DeviceImageRequest)
2384 if err := dec(in); err != nil {
2385 return nil, err
2386 }
2387 if interceptor == nil {
2388 return srv.(VolthaServiceServer).ActivateImage(ctx, in)
2389 }
2390 info := &grpc.UnaryServerInfo{
2391 Server: srv,
2392 FullMethod: "/voltha.VolthaService/ActivateImage",
2393 }
2394 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
2395 return srv.(VolthaServiceServer).ActivateImage(ctx, req.(*DeviceImageRequest))
2396 }
2397 return interceptor(ctx, in, info, handler)
2398}
2399
2400func _VolthaService_CommitImage_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
2401 in := new(DeviceImageRequest)
2402 if err := dec(in); err != nil {
2403 return nil, err
2404 }
2405 if interceptor == nil {
2406 return srv.(VolthaServiceServer).CommitImage(ctx, in)
2407 }
2408 info := &grpc.UnaryServerInfo{
2409 Server: srv,
2410 FullMethod: "/voltha.VolthaService/CommitImage",
2411 }
2412 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
2413 return srv.(VolthaServiceServer).CommitImage(ctx, req.(*DeviceImageRequest))
2414 }
2415 return interceptor(ctx, in, info, handler)
2416}
2417
William Kurkian1b363f42019-03-12 15:28:12 -04002418func _VolthaService_ListDevicePorts_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
2419 in := new(common.ID)
2420 if err := dec(in); err != nil {
2421 return nil, err
2422 }
2423 if interceptor == nil {
2424 return srv.(VolthaServiceServer).ListDevicePorts(ctx, in)
2425 }
2426 info := &grpc.UnaryServerInfo{
2427 Server: srv,
2428 FullMethod: "/voltha.VolthaService/ListDevicePorts",
2429 }
2430 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
2431 return srv.(VolthaServiceServer).ListDevicePorts(ctx, req.(*common.ID))
2432 }
2433 return interceptor(ctx, in, info, handler)
2434}
2435
2436func _VolthaService_ListDevicePmConfigs_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
2437 in := new(common.ID)
2438 if err := dec(in); err != nil {
2439 return nil, err
2440 }
2441 if interceptor == nil {
2442 return srv.(VolthaServiceServer).ListDevicePmConfigs(ctx, in)
2443 }
2444 info := &grpc.UnaryServerInfo{
2445 Server: srv,
2446 FullMethod: "/voltha.VolthaService/ListDevicePmConfigs",
2447 }
2448 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
2449 return srv.(VolthaServiceServer).ListDevicePmConfigs(ctx, req.(*common.ID))
2450 }
2451 return interceptor(ctx, in, info, handler)
2452}
2453
2454func _VolthaService_UpdateDevicePmConfigs_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
2455 in := new(PmConfigs)
2456 if err := dec(in); err != nil {
2457 return nil, err
2458 }
2459 if interceptor == nil {
2460 return srv.(VolthaServiceServer).UpdateDevicePmConfigs(ctx, in)
2461 }
2462 info := &grpc.UnaryServerInfo{
2463 Server: srv,
2464 FullMethod: "/voltha.VolthaService/UpdateDevicePmConfigs",
2465 }
2466 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
2467 return srv.(VolthaServiceServer).UpdateDevicePmConfigs(ctx, req.(*PmConfigs))
2468 }
2469 return interceptor(ctx, in, info, handler)
2470}
2471
2472func _VolthaService_ListDeviceFlows_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
2473 in := new(common.ID)
2474 if err := dec(in); err != nil {
2475 return nil, err
2476 }
2477 if interceptor == nil {
2478 return srv.(VolthaServiceServer).ListDeviceFlows(ctx, in)
2479 }
2480 info := &grpc.UnaryServerInfo{
2481 Server: srv,
2482 FullMethod: "/voltha.VolthaService/ListDeviceFlows",
2483 }
2484 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
2485 return srv.(VolthaServiceServer).ListDeviceFlows(ctx, req.(*common.ID))
2486 }
2487 return interceptor(ctx, in, info, handler)
2488}
2489
2490func _VolthaService_ListDeviceFlowGroups_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
2491 in := new(common.ID)
2492 if err := dec(in); err != nil {
2493 return nil, err
2494 }
2495 if interceptor == nil {
2496 return srv.(VolthaServiceServer).ListDeviceFlowGroups(ctx, in)
2497 }
2498 info := &grpc.UnaryServerInfo{
2499 Server: srv,
2500 FullMethod: "/voltha.VolthaService/ListDeviceFlowGroups",
2501 }
2502 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
2503 return srv.(VolthaServiceServer).ListDeviceFlowGroups(ctx, req.(*common.ID))
2504 }
2505 return interceptor(ctx, in, info, handler)
2506}
2507
2508func _VolthaService_ListDeviceTypes_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
2509 in := new(empty.Empty)
2510 if err := dec(in); err != nil {
2511 return nil, err
2512 }
2513 if interceptor == nil {
2514 return srv.(VolthaServiceServer).ListDeviceTypes(ctx, in)
2515 }
2516 info := &grpc.UnaryServerInfo{
2517 Server: srv,
2518 FullMethod: "/voltha.VolthaService/ListDeviceTypes",
2519 }
2520 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
2521 return srv.(VolthaServiceServer).ListDeviceTypes(ctx, req.(*empty.Empty))
2522 }
2523 return interceptor(ctx, in, info, handler)
2524}
2525
2526func _VolthaService_GetDeviceType_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
2527 in := new(common.ID)
2528 if err := dec(in); err != nil {
2529 return nil, err
2530 }
2531 if interceptor == nil {
2532 return srv.(VolthaServiceServer).GetDeviceType(ctx, in)
2533 }
2534 info := &grpc.UnaryServerInfo{
2535 Server: srv,
2536 FullMethod: "/voltha.VolthaService/GetDeviceType",
2537 }
2538 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
2539 return srv.(VolthaServiceServer).GetDeviceType(ctx, req.(*common.ID))
2540 }
2541 return interceptor(ctx, in, info, handler)
2542}
2543
William Kurkian1b363f42019-03-12 15:28:12 -04002544func _VolthaService_StreamPacketsOut_Handler(srv interface{}, stream grpc.ServerStream) error {
2545 return srv.(VolthaServiceServer).StreamPacketsOut(&volthaServiceStreamPacketsOutServer{stream})
2546}
2547
2548type VolthaService_StreamPacketsOutServer interface {
2549 SendAndClose(*empty.Empty) error
2550 Recv() (*openflow_13.PacketOut, error)
2551 grpc.ServerStream
2552}
2553
2554type volthaServiceStreamPacketsOutServer struct {
2555 grpc.ServerStream
2556}
2557
2558func (x *volthaServiceStreamPacketsOutServer) SendAndClose(m *empty.Empty) error {
2559 return x.ServerStream.SendMsg(m)
2560}
2561
2562func (x *volthaServiceStreamPacketsOutServer) Recv() (*openflow_13.PacketOut, error) {
2563 m := new(openflow_13.PacketOut)
2564 if err := x.ServerStream.RecvMsg(m); err != nil {
2565 return nil, err
2566 }
2567 return m, nil
2568}
2569
2570func _VolthaService_ReceivePacketsIn_Handler(srv interface{}, stream grpc.ServerStream) error {
2571 m := new(empty.Empty)
2572 if err := stream.RecvMsg(m); err != nil {
2573 return err
2574 }
2575 return srv.(VolthaServiceServer).ReceivePacketsIn(m, &volthaServiceReceivePacketsInServer{stream})
2576}
2577
2578type VolthaService_ReceivePacketsInServer interface {
2579 Send(*openflow_13.PacketIn) error
2580 grpc.ServerStream
2581}
2582
2583type volthaServiceReceivePacketsInServer struct {
2584 grpc.ServerStream
2585}
2586
2587func (x *volthaServiceReceivePacketsInServer) Send(m *openflow_13.PacketIn) error {
2588 return x.ServerStream.SendMsg(m)
2589}
2590
2591func _VolthaService_ReceiveChangeEvents_Handler(srv interface{}, stream grpc.ServerStream) error {
2592 m := new(empty.Empty)
2593 if err := stream.RecvMsg(m); err != nil {
2594 return err
2595 }
2596 return srv.(VolthaServiceServer).ReceiveChangeEvents(m, &volthaServiceReceiveChangeEventsServer{stream})
2597}
2598
2599type VolthaService_ReceiveChangeEventsServer interface {
2600 Send(*openflow_13.ChangeEvent) error
2601 grpc.ServerStream
2602}
2603
2604type volthaServiceReceiveChangeEventsServer struct {
2605 grpc.ServerStream
2606}
2607
2608func (x *volthaServiceReceiveChangeEventsServer) Send(m *openflow_13.ChangeEvent) error {
2609 return x.ServerStream.SendMsg(m)
2610}
2611
Devmalya Paul96a2c9e2019-11-06 07:17:44 +00002612func _VolthaService_CreateEventFilter_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
2613 in := new(EventFilter)
William Kurkian1b363f42019-03-12 15:28:12 -04002614 if err := dec(in); err != nil {
2615 return nil, err
2616 }
2617 if interceptor == nil {
Devmalya Paul96a2c9e2019-11-06 07:17:44 +00002618 return srv.(VolthaServiceServer).CreateEventFilter(ctx, in)
William Kurkian1b363f42019-03-12 15:28:12 -04002619 }
2620 info := &grpc.UnaryServerInfo{
2621 Server: srv,
Devmalya Paul96a2c9e2019-11-06 07:17:44 +00002622 FullMethod: "/voltha.VolthaService/CreateEventFilter",
William Kurkian1b363f42019-03-12 15:28:12 -04002623 }
2624 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
Devmalya Paul96a2c9e2019-11-06 07:17:44 +00002625 return srv.(VolthaServiceServer).CreateEventFilter(ctx, req.(*EventFilter))
William Kurkian1b363f42019-03-12 15:28:12 -04002626 }
2627 return interceptor(ctx, in, info, handler)
2628}
2629
Devmalya Paul96a2c9e2019-11-06 07:17:44 +00002630func _VolthaService_GetEventFilter_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
William Kurkian1b363f42019-03-12 15:28:12 -04002631 in := new(common.ID)
2632 if err := dec(in); err != nil {
2633 return nil, err
2634 }
2635 if interceptor == nil {
Devmalya Paul96a2c9e2019-11-06 07:17:44 +00002636 return srv.(VolthaServiceServer).GetEventFilter(ctx, in)
William Kurkian1b363f42019-03-12 15:28:12 -04002637 }
2638 info := &grpc.UnaryServerInfo{
2639 Server: srv,
Devmalya Paul96a2c9e2019-11-06 07:17:44 +00002640 FullMethod: "/voltha.VolthaService/GetEventFilter",
William Kurkian1b363f42019-03-12 15:28:12 -04002641 }
2642 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
Devmalya Paul96a2c9e2019-11-06 07:17:44 +00002643 return srv.(VolthaServiceServer).GetEventFilter(ctx, req.(*common.ID))
William Kurkian1b363f42019-03-12 15:28:12 -04002644 }
2645 return interceptor(ctx, in, info, handler)
2646}
2647
Devmalya Paul96a2c9e2019-11-06 07:17:44 +00002648func _VolthaService_UpdateEventFilter_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
2649 in := new(EventFilter)
William Kurkian1b363f42019-03-12 15:28:12 -04002650 if err := dec(in); err != nil {
2651 return nil, err
2652 }
2653 if interceptor == nil {
Devmalya Paul96a2c9e2019-11-06 07:17:44 +00002654 return srv.(VolthaServiceServer).UpdateEventFilter(ctx, in)
William Kurkian1b363f42019-03-12 15:28:12 -04002655 }
2656 info := &grpc.UnaryServerInfo{
2657 Server: srv,
Devmalya Paul96a2c9e2019-11-06 07:17:44 +00002658 FullMethod: "/voltha.VolthaService/UpdateEventFilter",
William Kurkian1b363f42019-03-12 15:28:12 -04002659 }
2660 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
Devmalya Paul96a2c9e2019-11-06 07:17:44 +00002661 return srv.(VolthaServiceServer).UpdateEventFilter(ctx, req.(*EventFilter))
William Kurkian1b363f42019-03-12 15:28:12 -04002662 }
2663 return interceptor(ctx, in, info, handler)
2664}
2665
Devmalya Paul96a2c9e2019-11-06 07:17:44 +00002666func _VolthaService_DeleteEventFilter_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
2667 in := new(EventFilter)
William Kurkian1b363f42019-03-12 15:28:12 -04002668 if err := dec(in); err != nil {
2669 return nil, err
2670 }
2671 if interceptor == nil {
Devmalya Paul96a2c9e2019-11-06 07:17:44 +00002672 return srv.(VolthaServiceServer).DeleteEventFilter(ctx, in)
William Kurkian1b363f42019-03-12 15:28:12 -04002673 }
2674 info := &grpc.UnaryServerInfo{
2675 Server: srv,
Devmalya Paul96a2c9e2019-11-06 07:17:44 +00002676 FullMethod: "/voltha.VolthaService/DeleteEventFilter",
William Kurkian1b363f42019-03-12 15:28:12 -04002677 }
2678 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
Devmalya Paul96a2c9e2019-11-06 07:17:44 +00002679 return srv.(VolthaServiceServer).DeleteEventFilter(ctx, req.(*EventFilter))
William Kurkian1b363f42019-03-12 15:28:12 -04002680 }
2681 return interceptor(ctx, in, info, handler)
2682}
2683
Devmalya Paul96a2c9e2019-11-06 07:17:44 +00002684func _VolthaService_ListEventFilters_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
William Kurkian1b363f42019-03-12 15:28:12 -04002685 in := new(empty.Empty)
2686 if err := dec(in); err != nil {
2687 return nil, err
2688 }
2689 if interceptor == nil {
Devmalya Paul96a2c9e2019-11-06 07:17:44 +00002690 return srv.(VolthaServiceServer).ListEventFilters(ctx, in)
William Kurkian1b363f42019-03-12 15:28:12 -04002691 }
2692 info := &grpc.UnaryServerInfo{
2693 Server: srv,
Devmalya Paul96a2c9e2019-11-06 07:17:44 +00002694 FullMethod: "/voltha.VolthaService/ListEventFilters",
William Kurkian1b363f42019-03-12 15:28:12 -04002695 }
2696 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
Devmalya Paul96a2c9e2019-11-06 07:17:44 +00002697 return srv.(VolthaServiceServer).ListEventFilters(ctx, req.(*empty.Empty))
William Kurkian1b363f42019-03-12 15:28:12 -04002698 }
2699 return interceptor(ctx, in, info, handler)
2700}
2701
2702func _VolthaService_GetImages_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
2703 in := new(common.ID)
2704 if err := dec(in); err != nil {
2705 return nil, err
2706 }
2707 if interceptor == nil {
2708 return srv.(VolthaServiceServer).GetImages(ctx, in)
2709 }
2710 info := &grpc.UnaryServerInfo{
2711 Server: srv,
2712 FullMethod: "/voltha.VolthaService/GetImages",
2713 }
2714 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
2715 return srv.(VolthaServiceServer).GetImages(ctx, req.(*common.ID))
2716 }
2717 return interceptor(ctx, in, info, handler)
2718}
2719
2720func _VolthaService_SelfTest_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
2721 in := new(common.ID)
2722 if err := dec(in); err != nil {
2723 return nil, err
2724 }
2725 if interceptor == nil {
2726 return srv.(VolthaServiceServer).SelfTest(ctx, in)
2727 }
2728 info := &grpc.UnaryServerInfo{
2729 Server: srv,
2730 FullMethod: "/voltha.VolthaService/SelfTest",
2731 }
2732 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
2733 return srv.(VolthaServiceServer).SelfTest(ctx, req.(*common.ID))
2734 }
2735 return interceptor(ctx, in, info, handler)
2736}
2737
2738func _VolthaService_GetMibDeviceData_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
2739 in := new(common.ID)
2740 if err := dec(in); err != nil {
2741 return nil, err
2742 }
2743 if interceptor == nil {
2744 return srv.(VolthaServiceServer).GetMibDeviceData(ctx, in)
2745 }
2746 info := &grpc.UnaryServerInfo{
2747 Server: srv,
2748 FullMethod: "/voltha.VolthaService/GetMibDeviceData",
2749 }
2750 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
2751 return srv.(VolthaServiceServer).GetMibDeviceData(ctx, req.(*common.ID))
2752 }
2753 return interceptor(ctx, in, info, handler)
2754}
2755
2756func _VolthaService_GetAlarmDeviceData_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
2757 in := new(common.ID)
2758 if err := dec(in); err != nil {
2759 return nil, err
2760 }
2761 if interceptor == nil {
2762 return srv.(VolthaServiceServer).GetAlarmDeviceData(ctx, in)
2763 }
2764 info := &grpc.UnaryServerInfo{
2765 Server: srv,
2766 FullMethod: "/voltha.VolthaService/GetAlarmDeviceData",
2767 }
2768 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
2769 return srv.(VolthaServiceServer).GetAlarmDeviceData(ctx, req.(*common.ID))
2770 }
2771 return interceptor(ctx, in, info, handler)
2772}
2773
2774func _VolthaService_SimulateAlarm_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
2775 in := new(SimulateAlarmRequest)
2776 if err := dec(in); err != nil {
2777 return nil, err
2778 }
2779 if interceptor == nil {
2780 return srv.(VolthaServiceServer).SimulateAlarm(ctx, in)
2781 }
2782 info := &grpc.UnaryServerInfo{
2783 Server: srv,
2784 FullMethod: "/voltha.VolthaService/SimulateAlarm",
2785 }
2786 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
2787 return srv.(VolthaServiceServer).SimulateAlarm(ctx, req.(*SimulateAlarmRequest))
2788 }
2789 return interceptor(ctx, in, info, handler)
2790}
2791
kesavand4a002b02020-01-23 21:29:47 -05002792func _VolthaService_EnablePort_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
2793 in := new(Port)
2794 if err := dec(in); err != nil {
2795 return nil, err
2796 }
2797 if interceptor == nil {
2798 return srv.(VolthaServiceServer).EnablePort(ctx, in)
2799 }
2800 info := &grpc.UnaryServerInfo{
2801 Server: srv,
2802 FullMethod: "/voltha.VolthaService/EnablePort",
2803 }
2804 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
2805 return srv.(VolthaServiceServer).EnablePort(ctx, req.(*Port))
2806 }
2807 return interceptor(ctx, in, info, handler)
2808}
2809
2810func _VolthaService_DisablePort_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
2811 in := new(Port)
2812 if err := dec(in); err != nil {
2813 return nil, err
2814 }
2815 if interceptor == nil {
2816 return srv.(VolthaServiceServer).DisablePort(ctx, in)
2817 }
2818 info := &grpc.UnaryServerInfo{
2819 Server: srv,
2820 FullMethod: "/voltha.VolthaService/DisablePort",
2821 }
2822 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
2823 return srv.(VolthaServiceServer).DisablePort(ctx, req.(*Port))
2824 }
2825 return interceptor(ctx, in, info, handler)
2826}
2827
Dinesh Belwalkared6da5e2020-02-25 11:23:57 -08002828func _VolthaService_GetExtValue_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
khenaidoo4c6543e2021-10-19 17:25:58 -04002829 in := new(extension.ValueSpecifier)
Dinesh Belwalkared6da5e2020-02-25 11:23:57 -08002830 if err := dec(in); err != nil {
2831 return nil, err
2832 }
2833 if interceptor == nil {
2834 return srv.(VolthaServiceServer).GetExtValue(ctx, in)
2835 }
2836 info := &grpc.UnaryServerInfo{
2837 Server: srv,
2838 FullMethod: "/voltha.VolthaService/GetExtValue",
2839 }
2840 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
khenaidoo4c6543e2021-10-19 17:25:58 -04002841 return srv.(VolthaServiceServer).GetExtValue(ctx, req.(*extension.ValueSpecifier))
Dinesh Belwalkared6da5e2020-02-25 11:23:57 -08002842 }
2843 return interceptor(ctx, in, info, handler)
2844}
2845
dpaul2b52e712020-06-23 13:02:28 +05302846func _VolthaService_SetExtValue_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
khenaidoo4c6543e2021-10-19 17:25:58 -04002847 in := new(extension.ValueSet)
dpaul2b52e712020-06-23 13:02:28 +05302848 if err := dec(in); err != nil {
2849 return nil, err
2850 }
2851 if interceptor == nil {
2852 return srv.(VolthaServiceServer).SetExtValue(ctx, in)
2853 }
2854 info := &grpc.UnaryServerInfo{
2855 Server: srv,
2856 FullMethod: "/voltha.VolthaService/SetExtValue",
2857 }
2858 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
khenaidoo4c6543e2021-10-19 17:25:58 -04002859 return srv.(VolthaServiceServer).SetExtValue(ctx, req.(*extension.ValueSet))
dpaul2b52e712020-06-23 13:02:28 +05302860 }
2861 return interceptor(ctx, in, info, handler)
2862}
2863
onkar.kundargi7b85fa12020-02-27 13:19:22 +05302864func _VolthaService_StartOmciTestAction_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
khenaidoo4c6543e2021-10-19 17:25:58 -04002865 in := new(omci.OmciTestRequest)
onkar.kundargi7b85fa12020-02-27 13:19:22 +05302866 if err := dec(in); err != nil {
2867 return nil, err
2868 }
2869 if interceptor == nil {
2870 return srv.(VolthaServiceServer).StartOmciTestAction(ctx, in)
2871 }
2872 info := &grpc.UnaryServerInfo{
2873 Server: srv,
2874 FullMethod: "/voltha.VolthaService/StartOmciTestAction",
2875 }
2876 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
khenaidoo4c6543e2021-10-19 17:25:58 -04002877 return srv.(VolthaServiceServer).StartOmciTestAction(ctx, req.(*omci.OmciTestRequest))
onkar.kundargi7b85fa12020-02-27 13:19:22 +05302878 }
2879 return interceptor(ctx, in, info, handler)
2880}
2881
yasin sapli2bbfbb42021-11-01 14:30:10 +00002882func _VolthaService_PutVoipSystemProfile_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
2883 in := new(voip_system_profile.VoipSystemProfileRequest)
2884 if err := dec(in); err != nil {
2885 return nil, err
2886 }
2887 if interceptor == nil {
2888 return srv.(VolthaServiceServer).PutVoipSystemProfile(ctx, in)
2889 }
2890 info := &grpc.UnaryServerInfo{
2891 Server: srv,
2892 FullMethod: "/voltha.VolthaService/PutVoipSystemProfile",
2893 }
2894 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
2895 return srv.(VolthaServiceServer).PutVoipSystemProfile(ctx, req.(*voip_system_profile.VoipSystemProfileRequest))
2896 }
2897 return interceptor(ctx, in, info, handler)
2898}
2899
2900func _VolthaService_DeleteVoipSystemProfile_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
2901 in := new(common.Key)
2902 if err := dec(in); err != nil {
2903 return nil, err
2904 }
2905 if interceptor == nil {
2906 return srv.(VolthaServiceServer).DeleteVoipSystemProfile(ctx, in)
2907 }
2908 info := &grpc.UnaryServerInfo{
2909 Server: srv,
2910 FullMethod: "/voltha.VolthaService/DeleteVoipSystemProfile",
2911 }
2912 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
2913 return srv.(VolthaServiceServer).DeleteVoipSystemProfile(ctx, req.(*common.Key))
2914 }
2915 return interceptor(ctx, in, info, handler)
2916}
2917
2918func _VolthaService_PutVoipUserProfile_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
2919 in := new(voip_user_profile.VoipUserProfileRequest)
2920 if err := dec(in); err != nil {
2921 return nil, err
2922 }
2923 if interceptor == nil {
2924 return srv.(VolthaServiceServer).PutVoipUserProfile(ctx, in)
2925 }
2926 info := &grpc.UnaryServerInfo{
2927 Server: srv,
2928 FullMethod: "/voltha.VolthaService/PutVoipUserProfile",
2929 }
2930 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
2931 return srv.(VolthaServiceServer).PutVoipUserProfile(ctx, req.(*voip_user_profile.VoipUserProfileRequest))
2932 }
2933 return interceptor(ctx, in, info, handler)
2934}
2935
2936func _VolthaService_DeleteVoipUserProfile_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
2937 in := new(common.Key)
2938 if err := dec(in); err != nil {
2939 return nil, err
2940 }
2941 if interceptor == nil {
2942 return srv.(VolthaServiceServer).DeleteVoipUserProfile(ctx, in)
2943 }
2944 info := &grpc.UnaryServerInfo{
2945 Server: srv,
2946 FullMethod: "/voltha.VolthaService/DeleteVoipUserProfile",
2947 }
2948 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
2949 return srv.(VolthaServiceServer).DeleteVoipUserProfile(ctx, req.(*common.Key))
2950 }
2951 return interceptor(ctx, in, info, handler)
2952}
2953
William Kurkian1b363f42019-03-12 15:28:12 -04002954var _VolthaService_serviceDesc = grpc.ServiceDesc{
2955 ServiceName: "voltha.VolthaService",
2956 HandlerType: (*VolthaServiceServer)(nil),
2957 Methods: []grpc.MethodDesc{
2958 {
William Kurkian1b363f42019-03-12 15:28:12 -04002959 MethodName: "GetVoltha",
2960 Handler: _VolthaService_GetVoltha_Handler,
2961 },
2962 {
2963 MethodName: "ListCoreInstances",
2964 Handler: _VolthaService_ListCoreInstances_Handler,
2965 },
2966 {
2967 MethodName: "GetCoreInstance",
2968 Handler: _VolthaService_GetCoreInstance_Handler,
2969 },
2970 {
2971 MethodName: "ListAdapters",
2972 Handler: _VolthaService_ListAdapters_Handler,
2973 },
2974 {
2975 MethodName: "ListLogicalDevices",
2976 Handler: _VolthaService_ListLogicalDevices_Handler,
2977 },
2978 {
2979 MethodName: "GetLogicalDevice",
2980 Handler: _VolthaService_GetLogicalDevice_Handler,
2981 },
2982 {
2983 MethodName: "ListLogicalDevicePorts",
2984 Handler: _VolthaService_ListLogicalDevicePorts_Handler,
2985 },
2986 {
2987 MethodName: "GetLogicalDevicePort",
2988 Handler: _VolthaService_GetLogicalDevicePort_Handler,
2989 },
2990 {
2991 MethodName: "EnableLogicalDevicePort",
2992 Handler: _VolthaService_EnableLogicalDevicePort_Handler,
2993 },
2994 {
2995 MethodName: "DisableLogicalDevicePort",
2996 Handler: _VolthaService_DisableLogicalDevicePort_Handler,
2997 },
2998 {
2999 MethodName: "ListLogicalDeviceFlows",
3000 Handler: _VolthaService_ListLogicalDeviceFlows_Handler,
3001 },
3002 {
3003 MethodName: "UpdateLogicalDeviceFlowTable",
3004 Handler: _VolthaService_UpdateLogicalDeviceFlowTable_Handler,
3005 },
3006 {
3007 MethodName: "UpdateLogicalDeviceMeterTable",
3008 Handler: _VolthaService_UpdateLogicalDeviceMeterTable_Handler,
3009 },
3010 {
Abhilash Laxmeshwardfbb74d2019-07-23 08:03:08 -04003011 MethodName: "ListLogicalDeviceMeters",
3012 Handler: _VolthaService_ListLogicalDeviceMeters_Handler,
William Kurkian1b363f42019-03-12 15:28:12 -04003013 },
3014 {
3015 MethodName: "ListLogicalDeviceFlowGroups",
3016 Handler: _VolthaService_ListLogicalDeviceFlowGroups_Handler,
3017 },
3018 {
3019 MethodName: "UpdateLogicalDeviceFlowGroupTable",
3020 Handler: _VolthaService_UpdateLogicalDeviceFlowGroupTable_Handler,
3021 },
3022 {
3023 MethodName: "ListDevices",
3024 Handler: _VolthaService_ListDevices_Handler,
3025 },
3026 {
3027 MethodName: "ListDeviceIds",
3028 Handler: _VolthaService_ListDeviceIds_Handler,
3029 },
3030 {
3031 MethodName: "ReconcileDevices",
3032 Handler: _VolthaService_ReconcileDevices_Handler,
3033 },
3034 {
3035 MethodName: "GetDevice",
3036 Handler: _VolthaService_GetDevice_Handler,
3037 },
3038 {
3039 MethodName: "CreateDevice",
3040 Handler: _VolthaService_CreateDevice_Handler,
3041 },
3042 {
3043 MethodName: "EnableDevice",
3044 Handler: _VolthaService_EnableDevice_Handler,
3045 },
3046 {
3047 MethodName: "DisableDevice",
3048 Handler: _VolthaService_DisableDevice_Handler,
3049 },
3050 {
3051 MethodName: "RebootDevice",
3052 Handler: _VolthaService_RebootDevice_Handler,
3053 },
3054 {
3055 MethodName: "DeleteDevice",
3056 Handler: _VolthaService_DeleteDevice_Handler,
3057 },
3058 {
Himani Chawla503b7ce2020-10-07 13:20:03 +05303059 MethodName: "ForceDeleteDevice",
3060 Handler: _VolthaService_ForceDeleteDevice_Handler,
3061 },
3062 {
William Kurkian1b363f42019-03-12 15:28:12 -04003063 MethodName: "DownloadImage",
3064 Handler: _VolthaService_DownloadImage_Handler,
3065 },
3066 {
3067 MethodName: "GetImageDownloadStatus",
3068 Handler: _VolthaService_GetImageDownloadStatus_Handler,
3069 },
3070 {
3071 MethodName: "GetImageDownload",
3072 Handler: _VolthaService_GetImageDownload_Handler,
3073 },
3074 {
3075 MethodName: "ListImageDownloads",
3076 Handler: _VolthaService_ListImageDownloads_Handler,
3077 },
3078 {
3079 MethodName: "CancelImageDownload",
3080 Handler: _VolthaService_CancelImageDownload_Handler,
3081 },
3082 {
3083 MethodName: "ActivateImageUpdate",
3084 Handler: _VolthaService_ActivateImageUpdate_Handler,
3085 },
3086 {
3087 MethodName: "RevertImageUpdate",
3088 Handler: _VolthaService_RevertImageUpdate_Handler,
3089 },
3090 {
Andrea Campanella9e94e8a2021-01-19 15:21:25 +01003091 MethodName: "DownloadImageToDevice",
3092 Handler: _VolthaService_DownloadImageToDevice_Handler,
3093 },
3094 {
3095 MethodName: "GetImageStatus",
3096 Handler: _VolthaService_GetImageStatus_Handler,
3097 },
3098 {
3099 MethodName: "AbortImageUpgradeToDevice",
3100 Handler: _VolthaService_AbortImageUpgradeToDevice_Handler,
3101 },
3102 {
3103 MethodName: "GetOnuImages",
3104 Handler: _VolthaService_GetOnuImages_Handler,
3105 },
3106 {
3107 MethodName: "ActivateImage",
3108 Handler: _VolthaService_ActivateImage_Handler,
3109 },
3110 {
3111 MethodName: "CommitImage",
3112 Handler: _VolthaService_CommitImage_Handler,
3113 },
3114 {
William Kurkian1b363f42019-03-12 15:28:12 -04003115 MethodName: "ListDevicePorts",
3116 Handler: _VolthaService_ListDevicePorts_Handler,
3117 },
3118 {
3119 MethodName: "ListDevicePmConfigs",
3120 Handler: _VolthaService_ListDevicePmConfigs_Handler,
3121 },
3122 {
3123 MethodName: "UpdateDevicePmConfigs",
3124 Handler: _VolthaService_UpdateDevicePmConfigs_Handler,
3125 },
3126 {
3127 MethodName: "ListDeviceFlows",
3128 Handler: _VolthaService_ListDeviceFlows_Handler,
3129 },
3130 {
3131 MethodName: "ListDeviceFlowGroups",
3132 Handler: _VolthaService_ListDeviceFlowGroups_Handler,
3133 },
3134 {
3135 MethodName: "ListDeviceTypes",
3136 Handler: _VolthaService_ListDeviceTypes_Handler,
3137 },
3138 {
3139 MethodName: "GetDeviceType",
3140 Handler: _VolthaService_GetDeviceType_Handler,
3141 },
3142 {
Devmalya Paul96a2c9e2019-11-06 07:17:44 +00003143 MethodName: "CreateEventFilter",
3144 Handler: _VolthaService_CreateEventFilter_Handler,
William Kurkian1b363f42019-03-12 15:28:12 -04003145 },
3146 {
Devmalya Paul96a2c9e2019-11-06 07:17:44 +00003147 MethodName: "GetEventFilter",
3148 Handler: _VolthaService_GetEventFilter_Handler,
William Kurkian1b363f42019-03-12 15:28:12 -04003149 },
3150 {
Devmalya Paul96a2c9e2019-11-06 07:17:44 +00003151 MethodName: "UpdateEventFilter",
3152 Handler: _VolthaService_UpdateEventFilter_Handler,
William Kurkian1b363f42019-03-12 15:28:12 -04003153 },
3154 {
Devmalya Paul96a2c9e2019-11-06 07:17:44 +00003155 MethodName: "DeleteEventFilter",
3156 Handler: _VolthaService_DeleteEventFilter_Handler,
William Kurkian1b363f42019-03-12 15:28:12 -04003157 },
3158 {
Devmalya Paul96a2c9e2019-11-06 07:17:44 +00003159 MethodName: "ListEventFilters",
3160 Handler: _VolthaService_ListEventFilters_Handler,
William Kurkian1b363f42019-03-12 15:28:12 -04003161 },
3162 {
3163 MethodName: "GetImages",
3164 Handler: _VolthaService_GetImages_Handler,
3165 },
3166 {
3167 MethodName: "SelfTest",
3168 Handler: _VolthaService_SelfTest_Handler,
3169 },
3170 {
3171 MethodName: "GetMibDeviceData",
3172 Handler: _VolthaService_GetMibDeviceData_Handler,
3173 },
3174 {
3175 MethodName: "GetAlarmDeviceData",
3176 Handler: _VolthaService_GetAlarmDeviceData_Handler,
3177 },
3178 {
3179 MethodName: "SimulateAlarm",
3180 Handler: _VolthaService_SimulateAlarm_Handler,
3181 },
3182 {
kesavand4a002b02020-01-23 21:29:47 -05003183 MethodName: "EnablePort",
3184 Handler: _VolthaService_EnablePort_Handler,
3185 },
3186 {
3187 MethodName: "DisablePort",
3188 Handler: _VolthaService_DisablePort_Handler,
3189 },
onkar.kundargi7b85fa12020-02-27 13:19:22 +05303190 {
Dinesh Belwalkared6da5e2020-02-25 11:23:57 -08003191 MethodName: "GetExtValue",
3192 Handler: _VolthaService_GetExtValue_Handler,
3193 },
3194 {
dpaul2b52e712020-06-23 13:02:28 +05303195 MethodName: "SetExtValue",
3196 Handler: _VolthaService_SetExtValue_Handler,
3197 },
3198 {
onkar.kundargi7b85fa12020-02-27 13:19:22 +05303199 MethodName: "StartOmciTestAction",
3200 Handler: _VolthaService_StartOmciTestAction_Handler,
3201 },
yasin sapli2bbfbb42021-11-01 14:30:10 +00003202 {
3203 MethodName: "PutVoipSystemProfile",
3204 Handler: _VolthaService_PutVoipSystemProfile_Handler,
3205 },
3206 {
3207 MethodName: "DeleteVoipSystemProfile",
3208 Handler: _VolthaService_DeleteVoipSystemProfile_Handler,
3209 },
3210 {
3211 MethodName: "PutVoipUserProfile",
3212 Handler: _VolthaService_PutVoipUserProfile_Handler,
3213 },
3214 {
3215 MethodName: "DeleteVoipUserProfile",
3216 Handler: _VolthaService_DeleteVoipUserProfile_Handler,
3217 },
William Kurkian1b363f42019-03-12 15:28:12 -04003218 },
3219 Streams: []grpc.StreamDesc{
3220 {
3221 StreamName: "StreamPacketsOut",
3222 Handler: _VolthaService_StreamPacketsOut_Handler,
3223 ClientStreams: true,
3224 },
3225 {
3226 StreamName: "ReceivePacketsIn",
3227 Handler: _VolthaService_ReceivePacketsIn_Handler,
3228 ServerStreams: true,
3229 },
3230 {
3231 StreamName: "ReceiveChangeEvents",
3232 Handler: _VolthaService_ReceiveChangeEvents_Handler,
3233 ServerStreams: true,
3234 },
3235 },
3236 Metadata: "voltha_protos/voltha.proto",
3237}