Gitiles
Code Review Sign In
gerrit.opencord.org / voltha-go / d948f7701638cccadb9a514f722927f8131b0a46 / . / vendor / github.com / opencord / voltha-protos / v5 / go / adapter_services / adapter_services.pb.go
blob: 3f2ca0c4fa3a3e16c0bf0f42c4718ddba2c492e4 [file] [log] [blame]
khenaidood948f772021-08-11 17:49:24 -0400[diff] [blame^]1// Code generated by protoc-gen-go. DO NOT EDIT.
2// source: voltha_protos/adapter_services.proto
3
4package adapter_services
5
6import (
7 context "context"
8 fmt "fmt"
9 proto "github.com/golang/protobuf/proto"
10 empty "github.com/golang/protobuf/ptypes/empty"
11 common "github.com/opencord/voltha-protos/v5/go/common"
12 extension "github.com/opencord/voltha-protos/v5/go/extension"
13 inter_container "github.com/opencord/voltha-protos/v5/go/inter_container"
14 _ "github.com/opencord/voltha-protos/v5/go/openolt"
15 voltha "github.com/opencord/voltha-protos/v5/go/voltha"
16 grpc "google.golang.org/grpc"
17 codes "google.golang.org/grpc/codes"
18 status "google.golang.org/grpc/status"
19 math "math"
20)
21
22// Reference imports to suppress errors if they are not otherwise used.
23var _ = proto.Marshal
24var _ = fmt.Errorf
25var _ = math.Inf
26
27// This is a compile-time assertion to ensure that this generated file
28// is compatible with the proto package it is being compiled against.
29// A compilation error at this line likely means your copy of the
30// proto package needs to be updated.
31const _ = proto.ProtoPackageIsVersion3 // please upgrade the proto package
32
33func init() {
34 proto.RegisterFile("voltha_protos/adapter_services.proto", fileDescriptor_5826bd5d7bb77df1)
35}
36
37var fileDescriptor_5826bd5d7bb77df1 = []byte{
38 // 965 bytes of a gzipped FileDescriptorProto
39 0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0xb4, 0x97, 0x4b, 0x6f, 0xe3, 0x36,
40 0x10, 0xc7, 0x81, 0x16, 0xd8, 0xc3, 0x24, 0x76, 0x12, 0xe5, 0x81, 0x85, 0xb2, 0x2d, 0xfa, 0xba,
41 0xf4, 0xb0, 0x0a, 0x90, 0xc5, 0x3e, 0x5a, 0xa4, 0x0d, 0x1c, 0xdb, 0xeb, 0x75, 0x9b, 0xc0, 0xa9,
42 0x95, 0xec, 0xa1, 0x97, 0x05, 0x2d, 0x8d, 0x65, 0x62, 0x29, 0x52, 0x15, 0x47, 0x79, 0x9c, 0xfb,
43 0x75, 0xfa, 0x11, 0xfa, 0xe1, 0x0a, 0xea, 0x65, 0x29, 0xb1, 0xd7, 0xb1, 0xd3, 0x3d, 0xf2, 0x3f,
44 0x33, 0x3f, 0x52, 0x33, 0x43, 0x8a, 0x84, 0x1f, 0xae, 0x94, 0xa0, 0x09, 0xfb, 0x10, 0xc5, 0x8a,
45 0x94, 0x3e, 0x60, 0x3e, 0x8b, 0x08, 0xe3, 0x0f, 0x1a, 0xe3, 0x2b, 0xee, 0xa1, 0x76, 0x52, 0xdd,
46 0x7a, 0x92, 0x79, 0xd9, 0xfb, 0x81, 0x52, 0x81, 0xc0, 0x83, 0x54, 0x1d, 0x25, 0xe3, 0x03, 0x0c,
47 0x23, 0xba, 0xcd, 0x9c, 0x6c, 0xbb, 0x8e, 0xf2, 0x54, 0x18, 0x2a, 0x99, 0xdb, 0xbe, 0xaf, 0xdb,
48 0xb8, 0x34, 0x93, 0x78, 0x4a, 0x12, 0xe3, 0x12, 0xe3, 0xd9, 0x00, 0x1f, 0xcd, 0x12, 0x72, 0xdb,
49 0xd7, 0x75, 0x1b, 0xde, 0x10, 0x4a, 0xcd, 0x95, 0xcc, 0x57, 0x68, 0xef, 0xd7, 0xed, 0x2a, 0x42,
50 0xa9, 0x04, 0xcd, 0x06, 0x4f, 0x90, 0x09, 0x9a, 0xcc, 0xb6, 0x65, 0xa3, 0xcc, 0x76, 0xf8, 0x8f,
51 0x05, 0xcd, 0x56, 0x96, 0x11, 0x37, 0x4b, 0x88, 0x75, 0x0c, 0x1b, 0x3d, 0xa4, 0x77, 0x29, 0xc1,
52 0x25, 0x46, 0x89, 0xb6, 0xf6, 0x9c, 0x2c, 0x2b, 0x4e, 0x91, 0x15, 0xa7, 0x6b, 0xb2, 0x62, 0xef,
53 0x38, 0x39, 0xac, 0xe6, 0xfd, 0x12, 0xd6, 0x5a, 0xbe, 0x8a, 0xa8, 0x93, 0x7e, 0x9d, 0xd5, 0x2c,
54 0x9c, 0xb2, 0xb1, 0x3d, 0x07, 0x66, 0xfd, 0x04, 0x1b, 0x43, 0xf4, 0x94, 0xf4, 0xb8, 0xc0, 0x25,
55 0x43, 0x5f, 0xc1, 0x7a, 0x07, 0x05, 0xd2, 0xb2, 0x71, 0xaf, 0xa1, 0xd1, 0xe1, 0x9a, 0x8d, 0x96,
56 0x9e, 0xf0, 0x0d, 0x34, 0x87, 0xd8, 0x95, 0x2b, 0x44, 0xbe, 0x82, 0xf5, 0x21, 0x8e, 0x94, 0xa2,
57 0xe5, 0x67, 0x74, 0x51, 0x8c, 0x2f, 0x50, 0x2f, 0x1b, 0x79, 0x04, 0x9b, 0x3d, 0xa4, 0xc1, 0x38,
58 0xca, 0xfc, 0xfa, 0x72, 0xac, 0xee, 0xc5, 0x3e, 0x2d, 0xc6, 0xee, 0x35, 0x27, 0x6f, 0xd2, 0x66,
59 0x11, 0x1b, 0x71, 0xc1, 0xb3, 0xaa, 0xb4, 0x27, 0x5c, 0xf8, 0x99, 0xe3, 0xa9, 0xd2, 0xf4, 0xe0,
60 0x89, 0x0f, 0x01, 0xb2, 0x14, 0x9d, 0xab, 0x98, 0xac, 0xf5, 0x22, 0xca, 0x8c, 0xe6, 0xc6, 0xbc,
61 0x80, 0xb5, 0xbc, 0x22, 0x4b, 0x04, 0x1d, 0xc1, 0xc6, 0x65, 0xe4, 0x33, 0xc2, 0xb7, 0x42, 0x5d,
62 0xeb, 0x93, 0x44, 0x7c, 0xb4, 0xb6, 0x8a, 0x40, 0x33, 0x4a, 0xe5, 0xb9, 0xd1, 0xa7, 0xf0, 0xb4,
63 0x12, 0xdd, 0x97, 0x5e, 0x8c, 0x21, 0x4a, 0x62, 0x42, 0xdc, 0x5a, 0x65, 0x5e, 0x2a, 0xf2, 0xa7,
64 0x69, 0x3f, 0x43, 0xc3, 0x45, 0xe9, 0x9f, 0x33, 0xef, 0x23, 0xd2, 0x20, 0xa1, 0xe9, 0x4a, 0x4a,
65 0x69, 0x6e, 0xec, 0x31, 0x34, 0xb3, 0x95, 0x9c, 0x87, 0x6d, 0x25, 0xc7, 0x3c, 0xb0, 0x76, 0xcb,
66 0xe0, 0x5c, 0xd1, 0xa6, 0x7c, 0x73, 0x01, 0x2e, 0x6c, 0x76, 0xd4, 0xb5, 0x14, 0x8a, 0xf9, 0x03,
67 0x99, 0xf4, 0x43, 0x16, 0xa0, 0xf5, 0x5d, 0xbd, 0x5a, 0xa9, 0x58, 0x38, 0x0d, 0xf1, 0xaf, 0x04,
68 0x35, 0xd9, 0xfb, 0x33, 0x7c, 0x86, 0xa8, 0x23, 0x25, 0x35, 0x5a, 0xa7, 0xb0, 0x65, 0xfa, 0x27,
69 0xe7, 0xe5, 0x7b, 0xdc, 0x9e, 0x19, 0xf1, 0x00, 0xda, 0x00, 0x76, 0x5a, 0x23, 0x15, 0x97, 0xbc,
70 0xcb, 0x28, 0x88, 0x99, 0x8f, 0xab, 0x03, 0x9f, 0xc3, 0x7a, 0x65, 0x79, 0xda, 0x02, 0x27, 0x3f,
71 0x96, 0xfb, 0x1d, 0xbb, 0xcc, 0xfd, 0xd4, 0xfc, 0x3b, 0x6c, 0xb6, 0x3c, 0xe2, 0x57, 0x8c, 0xb0,
72 0x4c, 0xd1, 0xca, 0x73, 0xf7, 0xa1, 0xd9, 0x56, 0x61, 0xc8, 0xe9, 0xf1, 0xa8, 0x0e, 0x34, 0x8a,
73 0xaa, 0x64, 0xa4, 0x67, 0x65, 0xeb, 0x55, 0x2b, 0x76, 0x86, 0x5a, 0xb3, 0x00, 0xed, 0xdd, 0x99,
74 0x56, 0xeb, 0x0c, 0xf6, 0x7a, 0x48, 0x35, 0x2d, 0x2f, 0xd8, 0x4a, 0xb8, 0xdf, 0x60, 0xbb, 0xcd,
75 0xa4, 0x87, 0xa2, 0x2e, 0xaf, 0xca, 0x2a, 0x12, 0x9f, 0x17, 0xde, 0x74, 0xfa, 0x6a, 0xac, 0x77,
76 0xb0, 0x35, 0xc4, 0x2b, 0x8c, 0xe9, 0xd1, 0xa4, 0xd7, 0xd0, 0x70, 0x89, 0xc5, 0x34, 0x08, 0x3d,
77 0x6e, 0xce, 0x56, 0x6b, 0xb3, 0x6c, 0x99, 0xb3, 0x76, 0xdf, 0x28, 0xd3, 0x9f, 0x9c, 0x19, 0x55,
78 0xeb, 0xe5, 0xf2, 0x30, 0x11, 0x8c, 0xb0, 0x25, 0x58, 0x1c, 0x4e, 0xa7, 0xaf, 0xc9, 0xd3, 0xe9,
79 0xf3, 0xae, 0x1c, 0x44, 0x18, 0x33, 0xe2, 0x4a, 0x1a, 0x92, 0x75, 0x04, 0x0d, 0x37, 0x89, 0xa2,
80 0x18, 0xb5, 0xee, 0x5e, 0xa1, 0x24, 0x6b, 0xbb, 0xa0, 0xa4, 0xc3, 0xb7, 0x5c, 0x10, 0xc6, 0x73,
81 0xb7, 0xfb, 0xaf, 0xb0, 0x71, 0x29, 0x1f, 0x11, 0x7f, 0x0c, 0x6b, 0x3d, 0xa4, 0xee, 0x0d, 0xbd,
82 0x67, 0x22, 0xa9, 0xf4, 0x6e, 0x45, 0x2c, 0xd6, 0xbf, 0x53, 0xac, 0x7f, 0x88, 0x94, 0xc4, 0x32,
83 0xb5, 0x69, 0xab, 0x05, 0x6b, 0xee, 0x2c, 0x80, 0x7b, 0x1f, 0x30, 0x6f, 0x0d, 0x97, 0xd0, 0xec,
84 0x21, 0xb9, 0x5c, 0x06, 0x02, 0x33, 0xca, 0x37, 0x4e, 0x79, 0xf5, 0x71, 0x32, 0xbd, 0x87, 0x19,
85 0xab, 0xd8, 0x48, 0xdf, 0x7e, 0xc2, 0x23, 0x2f, 0xcf, 0xa5, 0xf9, 0x5d, 0x2e, 0xc0, 0xba, 0x0b,
86 0xb1, 0xee, 0x1d, 0xec, 0xe1, 0xbf, 0x5f, 0xc2, 0x9e, 0xd9, 0xeb, 0xe6, 0x72, 0xf7, 0x7f, 0x5f,
87 0x9b, 0xba, 0xd0, 0x48, 0xd1, 0x3e, 0xf7, 0xd2, 0x06, 0x99, 0x76, 0x54, 0x4d, 0x5e, 0x94, 0xd0,
88 0x5f, 0xa0, 0x69, 0x9a, 0xb9, 0xc2, 0x29, 0x7b, 0xc2, 0xe8, 0x8b, 0xc2, 0xff, 0x80, 0xed, 0x62,
89 0x73, 0x5c, 0xa0, 0x37, 0x39, 0x8f, 0xd5, 0x98, 0x8b, 0xca, 0x5f, 0xa4, 0x22, 0xde, 0xdd, 0x62,
90 0xf3, 0x90, 0x5d, 0x68, 0x64, 0xb7, 0xb3, 0x1e, 0x86, 0xe9, 0x5f, 0xfd, 0xd9, 0xf4, 0x20, 0xac,
91 0xc8, 0x8b, 0x30, 0x2d, 0x58, 0xcb, 0xfc, 0x2f, 0xda, 0x4a, 0x52, 0xf5, 0xa4, 0x4d, 0x45, 0x73,
92 0xd5, 0x5e, 0x80, 0x38, 0xfc, 0xfb, 0x0b, 0xd8, 0x1b, 0x08, 0xfa, 0x2c, 0xe5, 0x3b, 0x86, 0xcd,
93 0xf3, 0x58, 0xdd, 0xdc, 0x9a, 0x24, 0xe7, 0x1d, 0xb5, 0x5c, 0xe6, 0x83, 0xf4, 0xec, 0xae, 0xe4,
94 0xb7, 0x2f, 0x35, 0x99, 0xd3, 0xd7, 0xfa, 0x71, 0x46, 0xf2, 0x0b, 0x63, 0x3e, 0x55, 0x01, 0x7f,
95 0x40, 0x9d, 0x4e, 0x22, 0xf8, 0x4a, 0xc5, 0x81, 0x63, 0x1e, 0x10, 0x9e, 0x8a, 0x7d, 0xe7, 0xee,
96 0x8b, 0xe8, 0x64, 0xf7, 0x7d, 0xca, 0xa8, 0x67, 0x48, 0xff, 0xf9, 0x26, 0xe0, 0x34, 0x49, 0x46,
97 0xe6, 0x24, 0x38, 0x28, 0x82, 0xf3, 0xd7, 0xc4, 0xf3, 0xe2, 0x6d, 0xf1, 0xf2, 0x20, 0x50, 0xf7,
98 0x9e, 0x58, 0xa3, 0x27, 0xa9, 0xf9, 0xc5, 0x7f, 0x01, 0x00, 0x00, 0xff, 0xff, 0x62, 0xe3, 0x4e,
99 0xd4, 0x8b, 0x0d, 0x00, 0x00,
100}
101
102// Reference imports to suppress errors if they are not otherwise used.
103var _ context.Context
104var _ grpc.ClientConn
105
106// This is a compile-time assertion to ensure that this generated file
107// is compatible with the grpc package it is being compiled against.
108const _ = grpc.SupportPackageIsVersion4
109
110// AdapterServiceClient is the client API for AdapterService service.
111//
112// For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
113type AdapterServiceClient interface {
114 // GetHealthStatus is used by an AdapterService client to verify connectivity
115 // to the gRPC server hosting the AdapterService service
116 GetHealthStatus(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*voltha.HealthStatus, error)
117 // Device
118 AdoptDevice(ctx context.Context, in *voltha.Device, opts ...grpc.CallOption) (*empty.Empty, error)
119 ReconcileDevice(ctx context.Context, in *voltha.Device, opts ...grpc.CallOption) (*empty.Empty, error)
120 DeleteDevice(ctx context.Context, in *voltha.Device, opts ...grpc.CallOption) (*empty.Empty, error)
121 DisableDevice(ctx context.Context, in *voltha.Device, opts ...grpc.CallOption) (*empty.Empty, error)
122 ReEnableDevice(ctx context.Context, in *voltha.Device, opts ...grpc.CallOption) (*empty.Empty, error)
123 RebootDevice(ctx context.Context, in *voltha.Device, opts ...grpc.CallOption) (*empty.Empty, error)
124 SelfTestDevice(ctx context.Context, in *voltha.Device, opts ...grpc.CallOption) (*empty.Empty, error)
125 GetOfpDeviceInfo(ctx context.Context, in *voltha.Device, opts ...grpc.CallOption) (*inter_container.SwitchCapability, error)
126 ChildDeviceLost(ctx context.Context, in *voltha.Device, opts ...grpc.CallOption) (*empty.Empty, error)
127 // Ports
128 EnablePort(ctx context.Context, in *voltha.Port, opts ...grpc.CallOption) (*empty.Empty, error)
129 DisablePort(ctx context.Context, in *voltha.Port, opts ...grpc.CallOption) (*empty.Empty, error)
130 // Flows
131 UpdateFlowsBulk(ctx context.Context, in *inter_container.BulkFlows, opts ...grpc.CallOption) (*empty.Empty, error)
132 UpdateFlowsIncrementally(ctx context.Context, in *inter_container.IncrementalFlows, opts ...grpc.CallOption) (*empty.Empty, error)
133 //Packets
134 SendPacketOut(ctx context.Context, in *inter_container.PacketOut, opts ...grpc.CallOption) (*empty.Empty, error)
135 // PM
136 UpdatePmConfig(ctx context.Context, in *inter_container.PmConfigsInfo, opts ...grpc.CallOption) (*empty.Empty, error)
137 // Image
138 DownloadOnuImage(ctx context.Context, in *voltha.DeviceImageDownloadRequest, opts ...grpc.CallOption) (*voltha.DeviceImageResponse, error)
139 GetOnuImageStatus(ctx context.Context, in *voltha.DeviceImageRequest, opts ...grpc.CallOption) (*voltha.DeviceImageResponse, error)
140 AbortOnuImageUpgrade(ctx context.Context, in *voltha.DeviceImageRequest, opts ...grpc.CallOption) (*voltha.DeviceImageResponse, error)
141 GetOnuImages(ctx context.Context, in *common.ID, opts ...grpc.CallOption) (*voltha.OnuImages, error)
142 ActivateOnuImage(ctx context.Context, in *voltha.DeviceImageRequest, opts ...grpc.CallOption) (*voltha.DeviceImageResponse, error)
143 CommitOnuImage(ctx context.Context, in *voltha.DeviceImageRequest, opts ...grpc.CallOption) (*voltha.DeviceImageResponse, error)
144 // Deprecated Image APIs
145 DownloadImage(ctx context.Context, in *inter_container.ImageDownloadMessage, opts ...grpc.CallOption) (*voltha.ImageDownload, error)
146 GetImageDownloadStatus(ctx context.Context, in *inter_container.ImageDownloadMessage, opts ...grpc.CallOption) (*voltha.ImageDownload, error)
147 CancelImageDownload(ctx context.Context, in *inter_container.ImageDownloadMessage, opts ...grpc.CallOption) (*voltha.ImageDownload, error)
148 ActivateImageUpdate(ctx context.Context, in *inter_container.ImageDownloadMessage, opts ...grpc.CallOption) (*voltha.ImageDownload, error)
149 RevertImageUpdate(ctx context.Context, in *inter_container.ImageDownloadMessage, opts ...grpc.CallOption) (*voltha.ImageDownload, error)
150 // Tests
151 StartOmciTest(ctx context.Context, in *inter_container.OMCITest, opts ...grpc.CallOption) (*voltha.TestResponse, error)
152 SimulateAlarm(ctx context.Context, in *inter_container.SimulateAlarmMessage, opts ...grpc.CallOption) (*common.OperationResp, error)
153 // Events
154 SuppressEvent(ctx context.Context, in *voltha.EventFilter, opts ...grpc.CallOption) (*empty.Empty, error)
155 UnSuppressEvent(ctx context.Context, in *voltha.EventFilter, opts ...grpc.CallOption) (*empty.Empty, error)
156 // Get/Set
157 GetExtValue(ctx context.Context, in *inter_container.GetExtValueMessage, opts ...grpc.CallOption) (*common.ReturnValues, error)
158 SetExtValue(ctx context.Context, in *inter_container.SetExtValueMessage, opts ...grpc.CallOption) (*empty.Empty, error)
159 GetSingleValue(ctx context.Context, in *extension.SingleGetValueRequest, opts ...grpc.CallOption) (*extension.SingleGetValueResponse, error)
160 SetSingleValue(ctx context.Context, in *extension.SingleSetValueRequest, opts ...grpc.CallOption) (*extension.SingleSetValueResponse, error)
161}
162
163type adapterServiceClient struct {
164 cc *grpc.ClientConn
165}
166
167func NewAdapterServiceClient(cc *grpc.ClientConn) AdapterServiceClient {
168 return &adapterServiceClient{cc}
169}
170
171func (c *adapterServiceClient) GetHealthStatus(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*voltha.HealthStatus, error) {
172 out := new(voltha.HealthStatus)
173 err := c.cc.Invoke(ctx, "/voltha.AdapterService/GetHealthStatus", in, out, opts...)
174 if err != nil {
175 return nil, err
176 }
177 return out, nil
178}
179
180func (c *adapterServiceClient) AdoptDevice(ctx context.Context, in *voltha.Device, opts ...grpc.CallOption) (*empty.Empty, error) {
181 out := new(empty.Empty)
182 err := c.cc.Invoke(ctx, "/voltha.AdapterService/AdoptDevice", in, out, opts...)
183 if err != nil {
184 return nil, err
185 }
186 return out, nil
187}
188
189func (c *adapterServiceClient) ReconcileDevice(ctx context.Context, in *voltha.Device, opts ...grpc.CallOption) (*empty.Empty, error) {
190 out := new(empty.Empty)
191 err := c.cc.Invoke(ctx, "/voltha.AdapterService/ReconcileDevice", in, out, opts...)
192 if err != nil {
193 return nil, err
194 }
195 return out, nil
196}
197
198func (c *adapterServiceClient) DeleteDevice(ctx context.Context, in *voltha.Device, opts ...grpc.CallOption) (*empty.Empty, error) {
199 out := new(empty.Empty)
200 err := c.cc.Invoke(ctx, "/voltha.AdapterService/DeleteDevice", in, out, opts...)
201 if err != nil {
202 return nil, err
203 }
204 return out, nil
205}
206
207func (c *adapterServiceClient) DisableDevice(ctx context.Context, in *voltha.Device, opts ...grpc.CallOption) (*empty.Empty, error) {
208 out := new(empty.Empty)
209 err := c.cc.Invoke(ctx, "/voltha.AdapterService/DisableDevice", in, out, opts...)
210 if err != nil {
211 return nil, err
212 }
213 return out, nil
214}
215
216func (c *adapterServiceClient) ReEnableDevice(ctx context.Context, in *voltha.Device, opts ...grpc.CallOption) (*empty.Empty, error) {
217 out := new(empty.Empty)
218 err := c.cc.Invoke(ctx, "/voltha.AdapterService/ReEnableDevice", in, out, opts...)
219 if err != nil {
220 return nil, err
221 }
222 return out, nil
223}
224
225func (c *adapterServiceClient) RebootDevice(ctx context.Context, in *voltha.Device, opts ...grpc.CallOption) (*empty.Empty, error) {
226 out := new(empty.Empty)
227 err := c.cc.Invoke(ctx, "/voltha.AdapterService/RebootDevice", in, out, opts...)
228 if err != nil {
229 return nil, err
230 }
231 return out, nil
232}
233
234func (c *adapterServiceClient) SelfTestDevice(ctx context.Context, in *voltha.Device, opts ...grpc.CallOption) (*empty.Empty, error) {
235 out := new(empty.Empty)
236 err := c.cc.Invoke(ctx, "/voltha.AdapterService/SelfTestDevice", in, out, opts...)
237 if err != nil {
238 return nil, err
239 }
240 return out, nil
241}
242
243func (c *adapterServiceClient) GetOfpDeviceInfo(ctx context.Context, in *voltha.Device, opts ...grpc.CallOption) (*inter_container.SwitchCapability, error) {
244 out := new(inter_container.SwitchCapability)
245 err := c.cc.Invoke(ctx, "/voltha.AdapterService/GetOfpDeviceInfo", in, out, opts...)
246 if err != nil {
247 return nil, err
248 }
249 return out, nil
250}
251
252func (c *adapterServiceClient) ChildDeviceLost(ctx context.Context, in *voltha.Device, opts ...grpc.CallOption) (*empty.Empty, error) {
253 out := new(empty.Empty)
254 err := c.cc.Invoke(ctx, "/voltha.AdapterService/ChildDeviceLost", in, out, opts...)
255 if err != nil {
256 return nil, err
257 }
258 return out, nil
259}
260
261func (c *adapterServiceClient) EnablePort(ctx context.Context, in *voltha.Port, opts ...grpc.CallOption) (*empty.Empty, error) {
262 out := new(empty.Empty)
263 err := c.cc.Invoke(ctx, "/voltha.AdapterService/EnablePort", in, out, opts...)
264 if err != nil {
265 return nil, err
266 }
267 return out, nil
268}
269
270func (c *adapterServiceClient) DisablePort(ctx context.Context, in *voltha.Port, opts ...grpc.CallOption) (*empty.Empty, error) {
271 out := new(empty.Empty)
272 err := c.cc.Invoke(ctx, "/voltha.AdapterService/DisablePort", in, out, opts...)
273 if err != nil {
274 return nil, err
275 }
276 return out, nil
277}
278
279func (c *adapterServiceClient) UpdateFlowsBulk(ctx context.Context, in *inter_container.BulkFlows, opts ...grpc.CallOption) (*empty.Empty, error) {
280 out := new(empty.Empty)
281 err := c.cc.Invoke(ctx, "/voltha.AdapterService/UpdateFlowsBulk", in, out, opts...)
282 if err != nil {
283 return nil, err
284 }
285 return out, nil
286}
287
288func (c *adapterServiceClient) UpdateFlowsIncrementally(ctx context.Context, in *inter_container.IncrementalFlows, opts ...grpc.CallOption) (*empty.Empty, error) {
289 out := new(empty.Empty)
290 err := c.cc.Invoke(ctx, "/voltha.AdapterService/UpdateFlowsIncrementally", in, out, opts...)
291 if err != nil {
292 return nil, err
293 }
294 return out, nil
295}
296
297func (c *adapterServiceClient) SendPacketOut(ctx context.Context, in *inter_container.PacketOut, opts ...grpc.CallOption) (*empty.Empty, error) {
298 out := new(empty.Empty)
299 err := c.cc.Invoke(ctx, "/voltha.AdapterService/SendPacketOut", in, out, opts...)
300 if err != nil {
301 return nil, err
302 }
303 return out, nil
304}
305
306func (c *adapterServiceClient) UpdatePmConfig(ctx context.Context, in *inter_container.PmConfigsInfo, opts ...grpc.CallOption) (*empty.Empty, error) {
307 out := new(empty.Empty)
308 err := c.cc.Invoke(ctx, "/voltha.AdapterService/UpdatePmConfig", in, out, opts...)
309 if err != nil {
310 return nil, err
311 }
312 return out, nil
313}
314
315func (c *adapterServiceClient) DownloadOnuImage(ctx context.Context, in *voltha.DeviceImageDownloadRequest, opts ...grpc.CallOption) (*voltha.DeviceImageResponse, error) {
316 out := new(voltha.DeviceImageResponse)
317 err := c.cc.Invoke(ctx, "/voltha.AdapterService/DownloadOnuImage", in, out, opts...)
318 if err != nil {
319 return nil, err
320 }
321 return out, nil
322}
323
324func (c *adapterServiceClient) GetOnuImageStatus(ctx context.Context, in *voltha.DeviceImageRequest, opts ...grpc.CallOption) (*voltha.DeviceImageResponse, error) {
325 out := new(voltha.DeviceImageResponse)
326 err := c.cc.Invoke(ctx, "/voltha.AdapterService/GetOnuImageStatus", in, out, opts...)
327 if err != nil {
328 return nil, err
329 }
330 return out, nil
331}
332
333func (c *adapterServiceClient) AbortOnuImageUpgrade(ctx context.Context, in *voltha.DeviceImageRequest, opts ...grpc.CallOption) (*voltha.DeviceImageResponse, error) {
334 out := new(voltha.DeviceImageResponse)
335 err := c.cc.Invoke(ctx, "/voltha.AdapterService/AbortOnuImageUpgrade", in, out, opts...)
336 if err != nil {
337 return nil, err
338 }
339 return out, nil
340}
341
342func (c *adapterServiceClient) GetOnuImages(ctx context.Context, in *common.ID, opts ...grpc.CallOption) (*voltha.OnuImages, error) {
343 out := new(voltha.OnuImages)
344 err := c.cc.Invoke(ctx, "/voltha.AdapterService/GetOnuImages", in, out, opts...)
345 if err != nil {
346 return nil, err
347 }
348 return out, nil
349}
350
351func (c *adapterServiceClient) ActivateOnuImage(ctx context.Context, in *voltha.DeviceImageRequest, opts ...grpc.CallOption) (*voltha.DeviceImageResponse, error) {
352 out := new(voltha.DeviceImageResponse)
353 err := c.cc.Invoke(ctx, "/voltha.AdapterService/ActivateOnuImage", in, out, opts...)
354 if err != nil {
355 return nil, err
356 }
357 return out, nil
358}
359
360func (c *adapterServiceClient) CommitOnuImage(ctx context.Context, in *voltha.DeviceImageRequest, opts ...grpc.CallOption) (*voltha.DeviceImageResponse, error) {
361 out := new(voltha.DeviceImageResponse)
362 err := c.cc.Invoke(ctx, "/voltha.AdapterService/CommitOnuImage", in, out, opts...)
363 if err != nil {
364 return nil, err
365 }
366 return out, nil
367}
368
369func (c *adapterServiceClient) DownloadImage(ctx context.Context, in *inter_container.ImageDownloadMessage, opts ...grpc.CallOption) (*voltha.ImageDownload, error) {
370 out := new(voltha.ImageDownload)
371 err := c.cc.Invoke(ctx, "/voltha.AdapterService/DownloadImage", in, out, opts...)
372 if err != nil {
373 return nil, err
374 }
375 return out, nil
376}
377
378func (c *adapterServiceClient) GetImageDownloadStatus(ctx context.Context, in *inter_container.ImageDownloadMessage, opts ...grpc.CallOption) (*voltha.ImageDownload, error) {
379 out := new(voltha.ImageDownload)
380 err := c.cc.Invoke(ctx, "/voltha.AdapterService/GetImageDownloadStatus", in, out, opts...)
381 if err != nil {
382 return nil, err
383 }
384 return out, nil
385}
386
387func (c *adapterServiceClient) CancelImageDownload(ctx context.Context, in *inter_container.ImageDownloadMessage, opts ...grpc.CallOption) (*voltha.ImageDownload, error) {
388 out := new(voltha.ImageDownload)
389 err := c.cc.Invoke(ctx, "/voltha.AdapterService/CancelImageDownload", in, out, opts...)
390 if err != nil {
391 return nil, err
392 }
393 return out, nil
394}
395
396func (c *adapterServiceClient) ActivateImageUpdate(ctx context.Context, in *inter_container.ImageDownloadMessage, opts ...grpc.CallOption) (*voltha.ImageDownload, error) {
397 out := new(voltha.ImageDownload)
398 err := c.cc.Invoke(ctx, "/voltha.AdapterService/ActivateImageUpdate", in, out, opts...)
399 if err != nil {
400 return nil, err
401 }
402 return out, nil
403}
404
405func (c *adapterServiceClient) RevertImageUpdate(ctx context.Context, in *inter_container.ImageDownloadMessage, opts ...grpc.CallOption) (*voltha.ImageDownload, error) {
406 out := new(voltha.ImageDownload)
407 err := c.cc.Invoke(ctx, "/voltha.AdapterService/RevertImageUpdate", in, out, opts...)
408 if err != nil {
409 return nil, err
410 }
411 return out, nil
412}
413
414func (c *adapterServiceClient) StartOmciTest(ctx context.Context, in *inter_container.OMCITest, opts ...grpc.CallOption) (*voltha.TestResponse, error) {
415 out := new(voltha.TestResponse)
416 err := c.cc.Invoke(ctx, "/voltha.AdapterService/StartOmciTest", in, out, opts...)
417 if err != nil {
418 return nil, err
419 }
420 return out, nil
421}
422
423func (c *adapterServiceClient) SimulateAlarm(ctx context.Context, in *inter_container.SimulateAlarmMessage, opts ...grpc.CallOption) (*common.OperationResp, error) {
424 out := new(common.OperationResp)
425 err := c.cc.Invoke(ctx, "/voltha.AdapterService/SimulateAlarm", in, out, opts...)
426 if err != nil {
427 return nil, err
428 }
429 return out, nil
430}
431
432func (c *adapterServiceClient) SuppressEvent(ctx context.Context, in *voltha.EventFilter, opts ...grpc.CallOption) (*empty.Empty, error) {
433 out := new(empty.Empty)
434 err := c.cc.Invoke(ctx, "/voltha.AdapterService/SuppressEvent", in, out, opts...)
435 if err != nil {
436 return nil, err
437 }
438 return out, nil
439}
440
441func (c *adapterServiceClient) UnSuppressEvent(ctx context.Context, in *voltha.EventFilter, opts ...grpc.CallOption) (*empty.Empty, error) {
442 out := new(empty.Empty)
443 err := c.cc.Invoke(ctx, "/voltha.AdapterService/UnSuppressEvent", in, out, opts...)
444 if err != nil {
445 return nil, err
446 }
447 return out, nil
448}
449
450func (c *adapterServiceClient) GetExtValue(ctx context.Context, in *inter_container.GetExtValueMessage, opts ...grpc.CallOption) (*common.ReturnValues, error) {
451 out := new(common.ReturnValues)
452 err := c.cc.Invoke(ctx, "/voltha.AdapterService/GetExtValue", in, out, opts...)
453 if err != nil {
454 return nil, err
455 }
456 return out, nil
457}
458
459func (c *adapterServiceClient) SetExtValue(ctx context.Context, in *inter_container.SetExtValueMessage, opts ...grpc.CallOption) (*empty.Empty, error) {
460 out := new(empty.Empty)
461 err := c.cc.Invoke(ctx, "/voltha.AdapterService/SetExtValue", in, out, opts...)
462 if err != nil {
463 return nil, err
464 }
465 return out, nil
466}
467
468func (c *adapterServiceClient) GetSingleValue(ctx context.Context, in *extension.SingleGetValueRequest, opts ...grpc.CallOption) (*extension.SingleGetValueResponse, error) {
469 out := new(extension.SingleGetValueResponse)
470 err := c.cc.Invoke(ctx, "/voltha.AdapterService/GetSingleValue", in, out, opts...)
471 if err != nil {
472 return nil, err
473 }
474 return out, nil
475}
476
477func (c *adapterServiceClient) SetSingleValue(ctx context.Context, in *extension.SingleSetValueRequest, opts ...grpc.CallOption) (*extension.SingleSetValueResponse, error) {
478 out := new(extension.SingleSetValueResponse)
479 err := c.cc.Invoke(ctx, "/voltha.AdapterService/SetSingleValue", in, out, opts...)
480 if err != nil {
481 return nil, err
482 }
483 return out, nil
484}
485
486// AdapterServiceServer is the server API for AdapterService service.
487type AdapterServiceServer interface {
488 // GetHealthStatus is used by an AdapterService client to verify connectivity
489 // to the gRPC server hosting the AdapterService service
490 GetHealthStatus(context.Context, *empty.Empty) (*voltha.HealthStatus, error)
491 // Device
492 AdoptDevice(context.Context, *voltha.Device) (*empty.Empty, error)
493 ReconcileDevice(context.Context, *voltha.Device) (*empty.Empty, error)
494 DeleteDevice(context.Context, *voltha.Device) (*empty.Empty, error)
495 DisableDevice(context.Context, *voltha.Device) (*empty.Empty, error)
496 ReEnableDevice(context.Context, *voltha.Device) (*empty.Empty, error)
497 RebootDevice(context.Context, *voltha.Device) (*empty.Empty, error)
498 SelfTestDevice(context.Context, *voltha.Device) (*empty.Empty, error)
499 GetOfpDeviceInfo(context.Context, *voltha.Device) (*inter_container.SwitchCapability, error)
500 ChildDeviceLost(context.Context, *voltha.Device) (*empty.Empty, error)
501 // Ports
502 EnablePort(context.Context, *voltha.Port) (*empty.Empty, error)
503 DisablePort(context.Context, *voltha.Port) (*empty.Empty, error)
504 // Flows
505 UpdateFlowsBulk(context.Context, *inter_container.BulkFlows) (*empty.Empty, error)
506 UpdateFlowsIncrementally(context.Context, *inter_container.IncrementalFlows) (*empty.Empty, error)
507 //Packets
508 SendPacketOut(context.Context, *inter_container.PacketOut) (*empty.Empty, error)
509 // PM
510 UpdatePmConfig(context.Context, *inter_container.PmConfigsInfo) (*empty.Empty, error)
511 // Image
512 DownloadOnuImage(context.Context, *voltha.DeviceImageDownloadRequest) (*voltha.DeviceImageResponse, error)
513 GetOnuImageStatus(context.Context, *voltha.DeviceImageRequest) (*voltha.DeviceImageResponse, error)
514 AbortOnuImageUpgrade(context.Context, *voltha.DeviceImageRequest) (*voltha.DeviceImageResponse, error)
515 GetOnuImages(context.Context, *common.ID) (*voltha.OnuImages, error)
516 ActivateOnuImage(context.Context, *voltha.DeviceImageRequest) (*voltha.DeviceImageResponse, error)
517 CommitOnuImage(context.Context, *voltha.DeviceImageRequest) (*voltha.DeviceImageResponse, error)
518 // Deprecated Image APIs
519 DownloadImage(context.Context, *inter_container.ImageDownloadMessage) (*voltha.ImageDownload, error)
520 GetImageDownloadStatus(context.Context, *inter_container.ImageDownloadMessage) (*voltha.ImageDownload, error)
521 CancelImageDownload(context.Context, *inter_container.ImageDownloadMessage) (*voltha.ImageDownload, error)
522 ActivateImageUpdate(context.Context, *inter_container.ImageDownloadMessage) (*voltha.ImageDownload, error)
523 RevertImageUpdate(context.Context, *inter_container.ImageDownloadMessage) (*voltha.ImageDownload, error)
524 // Tests
525 StartOmciTest(context.Context, *inter_container.OMCITest) (*voltha.TestResponse, error)
526 SimulateAlarm(context.Context, *inter_container.SimulateAlarmMessage) (*common.OperationResp, error)
527 // Events
528 SuppressEvent(context.Context, *voltha.EventFilter) (*empty.Empty, error)
529 UnSuppressEvent(context.Context, *voltha.EventFilter) (*empty.Empty, error)
530 // Get/Set
531 GetExtValue(context.Context, *inter_container.GetExtValueMessage) (*common.ReturnValues, error)
532 SetExtValue(context.Context, *inter_container.SetExtValueMessage) (*empty.Empty, error)
533 GetSingleValue(context.Context, *extension.SingleGetValueRequest) (*extension.SingleGetValueResponse, error)
534 SetSingleValue(context.Context, *extension.SingleSetValueRequest) (*extension.SingleSetValueResponse, error)
535}
536
537// UnimplementedAdapterServiceServer can be embedded to have forward compatible implementations.
538type UnimplementedAdapterServiceServer struct {
539}
540
541func (*UnimplementedAdapterServiceServer) GetHealthStatus(ctx context.Context, req *empty.Empty) (*voltha.HealthStatus, error) {
542 return nil, status.Errorf(codes.Unimplemented, "method GetHealthStatus not implemented")
543}
544func (*UnimplementedAdapterServiceServer) AdoptDevice(ctx context.Context, req *voltha.Device) (*empty.Empty, error) {
545 return nil, status.Errorf(codes.Unimplemented, "method AdoptDevice not implemented")
546}
547func (*UnimplementedAdapterServiceServer) ReconcileDevice(ctx context.Context, req *voltha.Device) (*empty.Empty, error) {
548 return nil, status.Errorf(codes.Unimplemented, "method ReconcileDevice not implemented")
549}
550func (*UnimplementedAdapterServiceServer) DeleteDevice(ctx context.Context, req *voltha.Device) (*empty.Empty, error) {
551 return nil, status.Errorf(codes.Unimplemented, "method DeleteDevice not implemented")
552}
553func (*UnimplementedAdapterServiceServer) DisableDevice(ctx context.Context, req *voltha.Device) (*empty.Empty, error) {
554 return nil, status.Errorf(codes.Unimplemented, "method DisableDevice not implemented")
555}
556func (*UnimplementedAdapterServiceServer) ReEnableDevice(ctx context.Context, req *voltha.Device) (*empty.Empty, error) {
557 return nil, status.Errorf(codes.Unimplemented, "method ReEnableDevice not implemented")
558}
559func (*UnimplementedAdapterServiceServer) RebootDevice(ctx context.Context, req *voltha.Device) (*empty.Empty, error) {
560 return nil, status.Errorf(codes.Unimplemented, "method RebootDevice not implemented")
561}
562func (*UnimplementedAdapterServiceServer) SelfTestDevice(ctx context.Context, req *voltha.Device) (*empty.Empty, error) {
563 return nil, status.Errorf(codes.Unimplemented, "method SelfTestDevice not implemented")
564}
565func (*UnimplementedAdapterServiceServer) GetOfpDeviceInfo(ctx context.Context, req *voltha.Device) (*inter_container.SwitchCapability, error) {
566 return nil, status.Errorf(codes.Unimplemented, "method GetOfpDeviceInfo not implemented")
567}
568func (*UnimplementedAdapterServiceServer) ChildDeviceLost(ctx context.Context, req *voltha.Device) (*empty.Empty, error) {
569 return nil, status.Errorf(codes.Unimplemented, "method ChildDeviceLost not implemented")
570}
571func (*UnimplementedAdapterServiceServer) EnablePort(ctx context.Context, req *voltha.Port) (*empty.Empty, error) {
572 return nil, status.Errorf(codes.Unimplemented, "method EnablePort not implemented")
573}
574func (*UnimplementedAdapterServiceServer) DisablePort(ctx context.Context, req *voltha.Port) (*empty.Empty, error) {
575 return nil, status.Errorf(codes.Unimplemented, "method DisablePort not implemented")
576}
577func (*UnimplementedAdapterServiceServer) UpdateFlowsBulk(ctx context.Context, req *inter_container.BulkFlows) (*empty.Empty, error) {
578 return nil, status.Errorf(codes.Unimplemented, "method UpdateFlowsBulk not implemented")
579}
580func (*UnimplementedAdapterServiceServer) UpdateFlowsIncrementally(ctx context.Context, req *inter_container.IncrementalFlows) (*empty.Empty, error) {
581 return nil, status.Errorf(codes.Unimplemented, "method UpdateFlowsIncrementally not implemented")
582}
583func (*UnimplementedAdapterServiceServer) SendPacketOut(ctx context.Context, req *inter_container.PacketOut) (*empty.Empty, error) {
584 return nil, status.Errorf(codes.Unimplemented, "method SendPacketOut not implemented")
585}
586func (*UnimplementedAdapterServiceServer) UpdatePmConfig(ctx context.Context, req *inter_container.PmConfigsInfo) (*empty.Empty, error) {
587 return nil, status.Errorf(codes.Unimplemented, "method UpdatePmConfig not implemented")
588}
589func (*UnimplementedAdapterServiceServer) DownloadOnuImage(ctx context.Context, req *voltha.DeviceImageDownloadRequest) (*voltha.DeviceImageResponse, error) {
590 return nil, status.Errorf(codes.Unimplemented, "method DownloadOnuImage not implemented")
591}
592func (*UnimplementedAdapterServiceServer) GetOnuImageStatus(ctx context.Context, req *voltha.DeviceImageRequest) (*voltha.DeviceImageResponse, error) {
593 return nil, status.Errorf(codes.Unimplemented, "method GetOnuImageStatus not implemented")
594}
595func (*UnimplementedAdapterServiceServer) AbortOnuImageUpgrade(ctx context.Context, req *voltha.DeviceImageRequest) (*voltha.DeviceImageResponse, error) {
596 return nil, status.Errorf(codes.Unimplemented, "method AbortOnuImageUpgrade not implemented")
597}
598func (*UnimplementedAdapterServiceServer) GetOnuImages(ctx context.Context, req *common.ID) (*voltha.OnuImages, error) {
599 return nil, status.Errorf(codes.Unimplemented, "method GetOnuImages not implemented")
600}
601func (*UnimplementedAdapterServiceServer) ActivateOnuImage(ctx context.Context, req *voltha.DeviceImageRequest) (*voltha.DeviceImageResponse, error) {
602 return nil, status.Errorf(codes.Unimplemented, "method ActivateOnuImage not implemented")
603}
604func (*UnimplementedAdapterServiceServer) CommitOnuImage(ctx context.Context, req *voltha.DeviceImageRequest) (*voltha.DeviceImageResponse, error) {
605 return nil, status.Errorf(codes.Unimplemented, "method CommitOnuImage not implemented")
606}
607func (*UnimplementedAdapterServiceServer) DownloadImage(ctx context.Context, req *inter_container.ImageDownloadMessage) (*voltha.ImageDownload, error) {
608 return nil, status.Errorf(codes.Unimplemented, "method DownloadImage not implemented")
609}
610func (*UnimplementedAdapterServiceServer) GetImageDownloadStatus(ctx context.Context, req *inter_container.ImageDownloadMessage) (*voltha.ImageDownload, error) {
611 return nil, status.Errorf(codes.Unimplemented, "method GetImageDownloadStatus not implemented")
612}
613func (*UnimplementedAdapterServiceServer) CancelImageDownload(ctx context.Context, req *inter_container.ImageDownloadMessage) (*voltha.ImageDownload, error) {
614 return nil, status.Errorf(codes.Unimplemented, "method CancelImageDownload not implemented")
615}
616func (*UnimplementedAdapterServiceServer) ActivateImageUpdate(ctx context.Context, req *inter_container.ImageDownloadMessage) (*voltha.ImageDownload, error) {
617 return nil, status.Errorf(codes.Unimplemented, "method ActivateImageUpdate not implemented")
618}
619func (*UnimplementedAdapterServiceServer) RevertImageUpdate(ctx context.Context, req *inter_container.ImageDownloadMessage) (*voltha.ImageDownload, error) {
620 return nil, status.Errorf(codes.Unimplemented, "method RevertImageUpdate not implemented")
621}
622func (*UnimplementedAdapterServiceServer) StartOmciTest(ctx context.Context, req *inter_container.OMCITest) (*voltha.TestResponse, error) {
623 return nil, status.Errorf(codes.Unimplemented, "method StartOmciTest not implemented")
624}
625func (*UnimplementedAdapterServiceServer) SimulateAlarm(ctx context.Context, req *inter_container.SimulateAlarmMessage) (*common.OperationResp, error) {
626 return nil, status.Errorf(codes.Unimplemented, "method SimulateAlarm not implemented")
627}
628func (*UnimplementedAdapterServiceServer) SuppressEvent(ctx context.Context, req *voltha.EventFilter) (*empty.Empty, error) {
629 return nil, status.Errorf(codes.Unimplemented, "method SuppressEvent not implemented")
630}
631func (*UnimplementedAdapterServiceServer) UnSuppressEvent(ctx context.Context, req *voltha.EventFilter) (*empty.Empty, error) {
632 return nil, status.Errorf(codes.Unimplemented, "method UnSuppressEvent not implemented")
633}
634func (*UnimplementedAdapterServiceServer) GetExtValue(ctx context.Context, req *inter_container.GetExtValueMessage) (*common.ReturnValues, error) {
635 return nil, status.Errorf(codes.Unimplemented, "method GetExtValue not implemented")
636}
637func (*UnimplementedAdapterServiceServer) SetExtValue(ctx context.Context, req *inter_container.SetExtValueMessage) (*empty.Empty, error) {
638 return nil, status.Errorf(codes.Unimplemented, "method SetExtValue not implemented")
639}
640func (*UnimplementedAdapterServiceServer) GetSingleValue(ctx context.Context, req *extension.SingleGetValueRequest) (*extension.SingleGetValueResponse, error) {
641 return nil, status.Errorf(codes.Unimplemented, "method GetSingleValue not implemented")
642}
643func (*UnimplementedAdapterServiceServer) SetSingleValue(ctx context.Context, req *extension.SingleSetValueRequest) (*extension.SingleSetValueResponse, error) {
644 return nil, status.Errorf(codes.Unimplemented, "method SetSingleValue not implemented")
645}
646
647func RegisterAdapterServiceServer(s *grpc.Server, srv AdapterServiceServer) {
648 s.RegisterService(&_AdapterService_serviceDesc, srv)
649}
650
651func _AdapterService_GetHealthStatus_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
652 in := new(empty.Empty)
653 if err := dec(in); err != nil {
654 return nil, err
655 }
656 if interceptor == nil {
657 return srv.(AdapterServiceServer).GetHealthStatus(ctx, in)
658 }
659 info := &grpc.UnaryServerInfo{
660 Server: srv,
661 FullMethod: "/voltha.AdapterService/GetHealthStatus",
662 }
663 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
664 return srv.(AdapterServiceServer).GetHealthStatus(ctx, req.(*empty.Empty))
665 }
666 return interceptor(ctx, in, info, handler)
667}
668
669func _AdapterService_AdoptDevice_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
670 in := new(voltha.Device)
671 if err := dec(in); err != nil {
672 return nil, err
673 }
674 if interceptor == nil {
675 return srv.(AdapterServiceServer).AdoptDevice(ctx, in)
676 }
677 info := &grpc.UnaryServerInfo{
678 Server: srv,
679 FullMethod: "/voltha.AdapterService/AdoptDevice",
680 }
681 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
682 return srv.(AdapterServiceServer).AdoptDevice(ctx, req.(*voltha.Device))
683 }
684 return interceptor(ctx, in, info, handler)
685}
686
687func _AdapterService_ReconcileDevice_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
688 in := new(voltha.Device)
689 if err := dec(in); err != nil {
690 return nil, err
691 }
692 if interceptor == nil {
693 return srv.(AdapterServiceServer).ReconcileDevice(ctx, in)
694 }
695 info := &grpc.UnaryServerInfo{
696 Server: srv,
697 FullMethod: "/voltha.AdapterService/ReconcileDevice",
698 }
699 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
700 return srv.(AdapterServiceServer).ReconcileDevice(ctx, req.(*voltha.Device))
701 }
702 return interceptor(ctx, in, info, handler)
703}
704
705func _AdapterService_DeleteDevice_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
706 in := new(voltha.Device)
707 if err := dec(in); err != nil {
708 return nil, err
709 }
710 if interceptor == nil {
711 return srv.(AdapterServiceServer).DeleteDevice(ctx, in)
712 }
713 info := &grpc.UnaryServerInfo{
714 Server: srv,
715 FullMethod: "/voltha.AdapterService/DeleteDevice",
716 }
717 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
718 return srv.(AdapterServiceServer).DeleteDevice(ctx, req.(*voltha.Device))
719 }
720 return interceptor(ctx, in, info, handler)
721}
722
723func _AdapterService_DisableDevice_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
724 in := new(voltha.Device)
725 if err := dec(in); err != nil {
726 return nil, err
727 }
728 if interceptor == nil {
729 return srv.(AdapterServiceServer).DisableDevice(ctx, in)
730 }
731 info := &grpc.UnaryServerInfo{
732 Server: srv,
733 FullMethod: "/voltha.AdapterService/DisableDevice",
734 }
735 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
736 return srv.(AdapterServiceServer).DisableDevice(ctx, req.(*voltha.Device))
737 }
738 return interceptor(ctx, in, info, handler)
739}
740
741func _AdapterService_ReEnableDevice_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
742 in := new(voltha.Device)
743 if err := dec(in); err != nil {
744 return nil, err
745 }
746 if interceptor == nil {
747 return srv.(AdapterServiceServer).ReEnableDevice(ctx, in)
748 }
749 info := &grpc.UnaryServerInfo{
750 Server: srv,
751 FullMethod: "/voltha.AdapterService/ReEnableDevice",
752 }
753 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
754 return srv.(AdapterServiceServer).ReEnableDevice(ctx, req.(*voltha.Device))
755 }
756 return interceptor(ctx, in, info, handler)
757}
758
759func _AdapterService_RebootDevice_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
760 in := new(voltha.Device)
761 if err := dec(in); err != nil {
762 return nil, err
763 }
764 if interceptor == nil {
765 return srv.(AdapterServiceServer).RebootDevice(ctx, in)
766 }
767 info := &grpc.UnaryServerInfo{
768 Server: srv,
769 FullMethod: "/voltha.AdapterService/RebootDevice",
770 }
771 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
772 return srv.(AdapterServiceServer).RebootDevice(ctx, req.(*voltha.Device))
773 }
774 return interceptor(ctx, in, info, handler)
775}
776
777func _AdapterService_SelfTestDevice_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
778 in := new(voltha.Device)
779 if err := dec(in); err != nil {
780 return nil, err
781 }
782 if interceptor == nil {
783 return srv.(AdapterServiceServer).SelfTestDevice(ctx, in)
784 }
785 info := &grpc.UnaryServerInfo{
786 Server: srv,
787 FullMethod: "/voltha.AdapterService/SelfTestDevice",
788 }
789 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
790 return srv.(AdapterServiceServer).SelfTestDevice(ctx, req.(*voltha.Device))
791 }
792 return interceptor(ctx, in, info, handler)
793}
794
795func _AdapterService_GetOfpDeviceInfo_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
796 in := new(voltha.Device)
797 if err := dec(in); err != nil {
798 return nil, err
799 }
800 if interceptor == nil {
801 return srv.(AdapterServiceServer).GetOfpDeviceInfo(ctx, in)
802 }
803 info := &grpc.UnaryServerInfo{
804 Server: srv,
805 FullMethod: "/voltha.AdapterService/GetOfpDeviceInfo",
806 }
807 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
808 return srv.(AdapterServiceServer).GetOfpDeviceInfo(ctx, req.(*voltha.Device))
809 }
810 return interceptor(ctx, in, info, handler)
811}
812
813func _AdapterService_ChildDeviceLost_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
814 in := new(voltha.Device)
815 if err := dec(in); err != nil {
816 return nil, err
817 }
818 if interceptor == nil {
819 return srv.(AdapterServiceServer).ChildDeviceLost(ctx, in)
820 }
821 info := &grpc.UnaryServerInfo{
822 Server: srv,
823 FullMethod: "/voltha.AdapterService/ChildDeviceLost",
824 }
825 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
826 return srv.(AdapterServiceServer).ChildDeviceLost(ctx, req.(*voltha.Device))
827 }
828 return interceptor(ctx, in, info, handler)
829}
830
831func _AdapterService_EnablePort_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
832 in := new(voltha.Port)
833 if err := dec(in); err != nil {
834 return nil, err
835 }
836 if interceptor == nil {
837 return srv.(AdapterServiceServer).EnablePort(ctx, in)
838 }
839 info := &grpc.UnaryServerInfo{
840 Server: srv,
841 FullMethod: "/voltha.AdapterService/EnablePort",
842 }
843 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
844 return srv.(AdapterServiceServer).EnablePort(ctx, req.(*voltha.Port))
845 }
846 return interceptor(ctx, in, info, handler)
847}
848
849func _AdapterService_DisablePort_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
850 in := new(voltha.Port)
851 if err := dec(in); err != nil {
852 return nil, err
853 }
854 if interceptor == nil {
855 return srv.(AdapterServiceServer).DisablePort(ctx, in)
856 }
857 info := &grpc.UnaryServerInfo{
858 Server: srv,
859 FullMethod: "/voltha.AdapterService/DisablePort",
860 }
861 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
862 return srv.(AdapterServiceServer).DisablePort(ctx, req.(*voltha.Port))
863 }
864 return interceptor(ctx, in, info, handler)
865}
866
867func _AdapterService_UpdateFlowsBulk_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
868 in := new(inter_container.BulkFlows)
869 if err := dec(in); err != nil {
870 return nil, err
871 }
872 if interceptor == nil {
873 return srv.(AdapterServiceServer).UpdateFlowsBulk(ctx, in)
874 }
875 info := &grpc.UnaryServerInfo{
876 Server: srv,
877 FullMethod: "/voltha.AdapterService/UpdateFlowsBulk",
878 }
879 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
880 return srv.(AdapterServiceServer).UpdateFlowsBulk(ctx, req.(*inter_container.BulkFlows))
881 }
882 return interceptor(ctx, in, info, handler)
883}
884
885func _AdapterService_UpdateFlowsIncrementally_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
886 in := new(inter_container.IncrementalFlows)
887 if err := dec(in); err != nil {
888 return nil, err
889 }
890 if interceptor == nil {
891 return srv.(AdapterServiceServer).UpdateFlowsIncrementally(ctx, in)
892 }
893 info := &grpc.UnaryServerInfo{
894 Server: srv,
895 FullMethod: "/voltha.AdapterService/UpdateFlowsIncrementally",
896 }
897 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
898 return srv.(AdapterServiceServer).UpdateFlowsIncrementally(ctx, req.(*inter_container.IncrementalFlows))
899 }
900 return interceptor(ctx, in, info, handler)
901}
902
903func _AdapterService_SendPacketOut_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
904 in := new(inter_container.PacketOut)
905 if err := dec(in); err != nil {
906 return nil, err
907 }
908 if interceptor == nil {
909 return srv.(AdapterServiceServer).SendPacketOut(ctx, in)
910 }
911 info := &grpc.UnaryServerInfo{
912 Server: srv,
913 FullMethod: "/voltha.AdapterService/SendPacketOut",
914 }
915 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
916 return srv.(AdapterServiceServer).SendPacketOut(ctx, req.(*inter_container.PacketOut))
917 }
918 return interceptor(ctx, in, info, handler)
919}
920
921func _AdapterService_UpdatePmConfig_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
922 in := new(inter_container.PmConfigsInfo)
923 if err := dec(in); err != nil {
924 return nil, err
925 }
926 if interceptor == nil {
927 return srv.(AdapterServiceServer).UpdatePmConfig(ctx, in)
928 }
929 info := &grpc.UnaryServerInfo{
930 Server: srv,
931 FullMethod: "/voltha.AdapterService/UpdatePmConfig",
932 }
933 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
934 return srv.(AdapterServiceServer).UpdatePmConfig(ctx, req.(*inter_container.PmConfigsInfo))
935 }
936 return interceptor(ctx, in, info, handler)
937}
938
939func _AdapterService_DownloadOnuImage_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
940 in := new(voltha.DeviceImageDownloadRequest)
941 if err := dec(in); err != nil {
942 return nil, err
943 }
944 if interceptor == nil {
945 return srv.(AdapterServiceServer).DownloadOnuImage(ctx, in)
946 }
947 info := &grpc.UnaryServerInfo{
948 Server: srv,
949 FullMethod: "/voltha.AdapterService/DownloadOnuImage",
950 }
951 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
952 return srv.(AdapterServiceServer).DownloadOnuImage(ctx, req.(*voltha.DeviceImageDownloadRequest))
953 }
954 return interceptor(ctx, in, info, handler)
955}
956
957func _AdapterService_GetOnuImageStatus_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
958 in := new(voltha.DeviceImageRequest)
959 if err := dec(in); err != nil {
960 return nil, err
961 }
962 if interceptor == nil {
963 return srv.(AdapterServiceServer).GetOnuImageStatus(ctx, in)
964 }
965 info := &grpc.UnaryServerInfo{
966 Server: srv,
967 FullMethod: "/voltha.AdapterService/GetOnuImageStatus",
968 }
969 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
970 return srv.(AdapterServiceServer).GetOnuImageStatus(ctx, req.(*voltha.DeviceImageRequest))
971 }
972 return interceptor(ctx, in, info, handler)
973}
974
975func _AdapterService_AbortOnuImageUpgrade_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
976 in := new(voltha.DeviceImageRequest)
977 if err := dec(in); err != nil {
978 return nil, err
979 }
980 if interceptor == nil {
981 return srv.(AdapterServiceServer).AbortOnuImageUpgrade(ctx, in)
982 }
983 info := &grpc.UnaryServerInfo{
984 Server: srv,
985 FullMethod: "/voltha.AdapterService/AbortOnuImageUpgrade",
986 }
987 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
988 return srv.(AdapterServiceServer).AbortOnuImageUpgrade(ctx, req.(*voltha.DeviceImageRequest))
989 }
990 return interceptor(ctx, in, info, handler)
991}
992
993func _AdapterService_GetOnuImages_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
994 in := new(common.ID)
995 if err := dec(in); err != nil {
996 return nil, err
997 }
998 if interceptor == nil {
999 return srv.(AdapterServiceServer).GetOnuImages(ctx, in)
1000 }
1001 info := &grpc.UnaryServerInfo{
1002 Server: srv,
1003 FullMethod: "/voltha.AdapterService/GetOnuImages",
1004 }
1005 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
1006 return srv.(AdapterServiceServer).GetOnuImages(ctx, req.(*common.ID))
1007 }
1008 return interceptor(ctx, in, info, handler)
1009}
1010
1011func _AdapterService_ActivateOnuImage_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
1012 in := new(voltha.DeviceImageRequest)
1013 if err := dec(in); err != nil {
1014 return nil, err
1015 }
1016 if interceptor == nil {
1017 return srv.(AdapterServiceServer).ActivateOnuImage(ctx, in)
1018 }
1019 info := &grpc.UnaryServerInfo{
1020 Server: srv,
1021 FullMethod: "/voltha.AdapterService/ActivateOnuImage",
1022 }
1023 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
1024 return srv.(AdapterServiceServer).ActivateOnuImage(ctx, req.(*voltha.DeviceImageRequest))
1025 }
1026 return interceptor(ctx, in, info, handler)
1027}
1028
1029func _AdapterService_CommitOnuImage_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
1030 in := new(voltha.DeviceImageRequest)
1031 if err := dec(in); err != nil {
1032 return nil, err
1033 }
1034 if interceptor == nil {
1035 return srv.(AdapterServiceServer).CommitOnuImage(ctx, in)
1036 }
1037 info := &grpc.UnaryServerInfo{
1038 Server: srv,
1039 FullMethod: "/voltha.AdapterService/CommitOnuImage",
1040 }
1041 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
1042 return srv.(AdapterServiceServer).CommitOnuImage(ctx, req.(*voltha.DeviceImageRequest))
1043 }
1044 return interceptor(ctx, in, info, handler)
1045}
1046
1047func _AdapterService_DownloadImage_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
1048 in := new(inter_container.ImageDownloadMessage)
1049 if err := dec(in); err != nil {
1050 return nil, err
1051 }
1052 if interceptor == nil {
1053 return srv.(AdapterServiceServer).DownloadImage(ctx, in)
1054 }
1055 info := &grpc.UnaryServerInfo{
1056 Server: srv,
1057 FullMethod: "/voltha.AdapterService/DownloadImage",
1058 }
1059 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
1060 return srv.(AdapterServiceServer).DownloadImage(ctx, req.(*inter_container.ImageDownloadMessage))
1061 }
1062 return interceptor(ctx, in, info, handler)
1063}
1064
1065func _AdapterService_GetImageDownloadStatus_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
1066 in := new(inter_container.ImageDownloadMessage)
1067 if err := dec(in); err != nil {
1068 return nil, err
1069 }
1070 if interceptor == nil {
1071 return srv.(AdapterServiceServer).GetImageDownloadStatus(ctx, in)
1072 }
1073 info := &grpc.UnaryServerInfo{
1074 Server: srv,
1075 FullMethod: "/voltha.AdapterService/GetImageDownloadStatus",
1076 }
1077 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
1078 return srv.(AdapterServiceServer).GetImageDownloadStatus(ctx, req.(*inter_container.ImageDownloadMessage))
1079 }
1080 return interceptor(ctx, in, info, handler)
1081}
1082
1083func _AdapterService_CancelImageDownload_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
1084 in := new(inter_container.ImageDownloadMessage)
1085 if err := dec(in); err != nil {
1086 return nil, err
1087 }
1088 if interceptor == nil {
1089 return srv.(AdapterServiceServer).CancelImageDownload(ctx, in)
1090 }
1091 info := &grpc.UnaryServerInfo{
1092 Server: srv,
1093 FullMethod: "/voltha.AdapterService/CancelImageDownload",
1094 }
1095 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
1096 return srv.(AdapterServiceServer).CancelImageDownload(ctx, req.(*inter_container.ImageDownloadMessage))
1097 }
1098 return interceptor(ctx, in, info, handler)
1099}
1100
1101func _AdapterService_ActivateImageUpdate_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
1102 in := new(inter_container.ImageDownloadMessage)
1103 if err := dec(in); err != nil {
1104 return nil, err
1105 }
1106 if interceptor == nil {
1107 return srv.(AdapterServiceServer).ActivateImageUpdate(ctx, in)
1108 }
1109 info := &grpc.UnaryServerInfo{
1110 Server: srv,
1111 FullMethod: "/voltha.AdapterService/ActivateImageUpdate",
1112 }
1113 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
1114 return srv.(AdapterServiceServer).ActivateImageUpdate(ctx, req.(*inter_container.ImageDownloadMessage))
1115 }
1116 return interceptor(ctx, in, info, handler)
1117}
1118
1119func _AdapterService_RevertImageUpdate_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
1120 in := new(inter_container.ImageDownloadMessage)
1121 if err := dec(in); err != nil {
1122 return nil, err
1123 }
1124 if interceptor == nil {
1125 return srv.(AdapterServiceServer).RevertImageUpdate(ctx, in)
1126 }
1127 info := &grpc.UnaryServerInfo{
1128 Server: srv,
1129 FullMethod: "/voltha.AdapterService/RevertImageUpdate",
1130 }
1131 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
1132 return srv.(AdapterServiceServer).RevertImageUpdate(ctx, req.(*inter_container.ImageDownloadMessage))
1133 }
1134 return interceptor(ctx, in, info, handler)
1135}
1136
1137func _AdapterService_StartOmciTest_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
1138 in := new(inter_container.OMCITest)
1139 if err := dec(in); err != nil {
1140 return nil, err
1141 }
1142 if interceptor == nil {
1143 return srv.(AdapterServiceServer).StartOmciTest(ctx, in)
1144 }
1145 info := &grpc.UnaryServerInfo{
1146 Server: srv,
1147 FullMethod: "/voltha.AdapterService/StartOmciTest",
1148 }
1149 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
1150 return srv.(AdapterServiceServer).StartOmciTest(ctx, req.(*inter_container.OMCITest))
1151 }
1152 return interceptor(ctx, in, info, handler)
1153}
1154
1155func _AdapterService_SimulateAlarm_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
1156 in := new(inter_container.SimulateAlarmMessage)
1157 if err := dec(in); err != nil {
1158 return nil, err
1159 }
1160 if interceptor == nil {
1161 return srv.(AdapterServiceServer).SimulateAlarm(ctx, in)
1162 }
1163 info := &grpc.UnaryServerInfo{
1164 Server: srv,
1165 FullMethod: "/voltha.AdapterService/SimulateAlarm",
1166 }
1167 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
1168 return srv.(AdapterServiceServer).SimulateAlarm(ctx, req.(*inter_container.SimulateAlarmMessage))
1169 }
1170 return interceptor(ctx, in, info, handler)
1171}
1172
1173func _AdapterService_SuppressEvent_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
1174 in := new(voltha.EventFilter)
1175 if err := dec(in); err != nil {
1176 return nil, err
1177 }
1178 if interceptor == nil {
1179 return srv.(AdapterServiceServer).SuppressEvent(ctx, in)
1180 }
1181 info := &grpc.UnaryServerInfo{
1182 Server: srv,
1183 FullMethod: "/voltha.AdapterService/SuppressEvent",
1184 }
1185 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
1186 return srv.(AdapterServiceServer).SuppressEvent(ctx, req.(*voltha.EventFilter))
1187 }
1188 return interceptor(ctx, in, info, handler)
1189}
1190
1191func _AdapterService_UnSuppressEvent_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
1192 in := new(voltha.EventFilter)
1193 if err := dec(in); err != nil {
1194 return nil, err
1195 }
1196 if interceptor == nil {
1197 return srv.(AdapterServiceServer).UnSuppressEvent(ctx, in)
1198 }
1199 info := &grpc.UnaryServerInfo{
1200 Server: srv,
1201 FullMethod: "/voltha.AdapterService/UnSuppressEvent",
1202 }
1203 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
1204 return srv.(AdapterServiceServer).UnSuppressEvent(ctx, req.(*voltha.EventFilter))
1205 }
1206 return interceptor(ctx, in, info, handler)
1207}
1208
1209func _AdapterService_GetExtValue_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
1210 in := new(inter_container.GetExtValueMessage)
1211 if err := dec(in); err != nil {
1212 return nil, err
1213 }
1214 if interceptor == nil {
1215 return srv.(AdapterServiceServer).GetExtValue(ctx, in)
1216 }
1217 info := &grpc.UnaryServerInfo{
1218 Server: srv,
1219 FullMethod: "/voltha.AdapterService/GetExtValue",
1220 }
1221 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
1222 return srv.(AdapterServiceServer).GetExtValue(ctx, req.(*inter_container.GetExtValueMessage))
1223 }
1224 return interceptor(ctx, in, info, handler)
1225}
1226
1227func _AdapterService_SetExtValue_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
1228 in := new(inter_container.SetExtValueMessage)
1229 if err := dec(in); err != nil {
1230 return nil, err
1231 }
1232 if interceptor == nil {
1233 return srv.(AdapterServiceServer).SetExtValue(ctx, in)
1234 }
1235 info := &grpc.UnaryServerInfo{
1236 Server: srv,
1237 FullMethod: "/voltha.AdapterService/SetExtValue",
1238 }
1239 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
1240 return srv.(AdapterServiceServer).SetExtValue(ctx, req.(*inter_container.SetExtValueMessage))
1241 }
1242 return interceptor(ctx, in, info, handler)
1243}
1244
1245func _AdapterService_GetSingleValue_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
1246 in := new(extension.SingleGetValueRequest)
1247 if err := dec(in); err != nil {
1248 return nil, err
1249 }
1250 if interceptor == nil {
1251 return srv.(AdapterServiceServer).GetSingleValue(ctx, in)
1252 }
1253 info := &grpc.UnaryServerInfo{
1254 Server: srv,
1255 FullMethod: "/voltha.AdapterService/GetSingleValue",
1256 }
1257 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
1258 return srv.(AdapterServiceServer).GetSingleValue(ctx, req.(*extension.SingleGetValueRequest))
1259 }
1260 return interceptor(ctx, in, info, handler)
1261}
1262
1263func _AdapterService_SetSingleValue_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
1264 in := new(extension.SingleSetValueRequest)
1265 if err := dec(in); err != nil {
1266 return nil, err
1267 }
1268 if interceptor == nil {
1269 return srv.(AdapterServiceServer).SetSingleValue(ctx, in)
1270 }
1271 info := &grpc.UnaryServerInfo{
1272 Server: srv,
1273 FullMethod: "/voltha.AdapterService/SetSingleValue",
1274 }
1275 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
1276 return srv.(AdapterServiceServer).SetSingleValue(ctx, req.(*extension.SingleSetValueRequest))
1277 }
1278 return interceptor(ctx, in, info, handler)
1279}
1280
1281var _AdapterService_serviceDesc = grpc.ServiceDesc{
1282 ServiceName: "voltha.AdapterService",
1283 HandlerType: (*AdapterServiceServer)(nil),
1284 Methods: []grpc.MethodDesc{
1285 {
1286 MethodName: "GetHealthStatus",
1287 Handler: _AdapterService_GetHealthStatus_Handler,
1288 },
1289 {
1290 MethodName: "AdoptDevice",
1291 Handler: _AdapterService_AdoptDevice_Handler,
1292 },
1293 {
1294 MethodName: "ReconcileDevice",
1295 Handler: _AdapterService_ReconcileDevice_Handler,
1296 },
1297 {
1298 MethodName: "DeleteDevice",
1299 Handler: _AdapterService_DeleteDevice_Handler,
1300 },
1301 {
1302 MethodName: "DisableDevice",
1303 Handler: _AdapterService_DisableDevice_Handler,
1304 },
1305 {
1306 MethodName: "ReEnableDevice",
1307 Handler: _AdapterService_ReEnableDevice_Handler,
1308 },
1309 {
1310 MethodName: "RebootDevice",
1311 Handler: _AdapterService_RebootDevice_Handler,
1312 },
1313 {
1314 MethodName: "SelfTestDevice",
1315 Handler: _AdapterService_SelfTestDevice_Handler,
1316 },
1317 {
1318 MethodName: "GetOfpDeviceInfo",
1319 Handler: _AdapterService_GetOfpDeviceInfo_Handler,
1320 },
1321 {
1322 MethodName: "ChildDeviceLost",
1323 Handler: _AdapterService_ChildDeviceLost_Handler,
1324 },
1325 {
1326 MethodName: "EnablePort",
1327 Handler: _AdapterService_EnablePort_Handler,
1328 },
1329 {
1330 MethodName: "DisablePort",
1331 Handler: _AdapterService_DisablePort_Handler,
1332 },
1333 {
1334 MethodName: "UpdateFlowsBulk",
1335 Handler: _AdapterService_UpdateFlowsBulk_Handler,
1336 },
1337 {
1338 MethodName: "UpdateFlowsIncrementally",
1339 Handler: _AdapterService_UpdateFlowsIncrementally_Handler,
1340 },
1341 {
1342 MethodName: "SendPacketOut",
1343 Handler: _AdapterService_SendPacketOut_Handler,
1344 },
1345 {
1346 MethodName: "UpdatePmConfig",
1347 Handler: _AdapterService_UpdatePmConfig_Handler,
1348 },
1349 {
1350 MethodName: "DownloadOnuImage",
1351 Handler: _AdapterService_DownloadOnuImage_Handler,
1352 },
1353 {
1354 MethodName: "GetOnuImageStatus",
1355 Handler: _AdapterService_GetOnuImageStatus_Handler,
1356 },
1357 {
1358 MethodName: "AbortOnuImageUpgrade",
1359 Handler: _AdapterService_AbortOnuImageUpgrade_Handler,
1360 },
1361 {
1362 MethodName: "GetOnuImages",
1363 Handler: _AdapterService_GetOnuImages_Handler,
1364 },
1365 {
1366 MethodName: "ActivateOnuImage",
1367 Handler: _AdapterService_ActivateOnuImage_Handler,
1368 },
1369 {
1370 MethodName: "CommitOnuImage",
1371 Handler: _AdapterService_CommitOnuImage_Handler,
1372 },
1373 {
1374 MethodName: "DownloadImage",
1375 Handler: _AdapterService_DownloadImage_Handler,
1376 },
1377 {
1378 MethodName: "GetImageDownloadStatus",
1379 Handler: _AdapterService_GetImageDownloadStatus_Handler,
1380 },
1381 {
1382 MethodName: "CancelImageDownload",
1383 Handler: _AdapterService_CancelImageDownload_Handler,
1384 },
1385 {
1386 MethodName: "ActivateImageUpdate",
1387 Handler: _AdapterService_ActivateImageUpdate_Handler,
1388 },
1389 {
1390 MethodName: "RevertImageUpdate",
1391 Handler: _AdapterService_RevertImageUpdate_Handler,
1392 },
1393 {
1394 MethodName: "StartOmciTest",
1395 Handler: _AdapterService_StartOmciTest_Handler,
1396 },
1397 {
1398 MethodName: "SimulateAlarm",
1399 Handler: _AdapterService_SimulateAlarm_Handler,
1400 },
1401 {
1402 MethodName: "SuppressEvent",
1403 Handler: _AdapterService_SuppressEvent_Handler,
1404 },
1405 {
1406 MethodName: "UnSuppressEvent",
1407 Handler: _AdapterService_UnSuppressEvent_Handler,
1408 },
1409 {
1410 MethodName: "GetExtValue",
1411 Handler: _AdapterService_GetExtValue_Handler,
1412 },
1413 {
1414 MethodName: "SetExtValue",
1415 Handler: _AdapterService_SetExtValue_Handler,
1416 },
1417 {
1418 MethodName: "GetSingleValue",
1419 Handler: _AdapterService_GetSingleValue_Handler,
1420 },
1421 {
1422 MethodName: "SetSingleValue",
1423 Handler: _AdapterService_SetSingleValue_Handler,
1424 },
1425 },
1426 Streams: []grpc.StreamDesc{},
1427 Metadata: "voltha_protos/adapter_services.proto",
1428}
1429
1430// OnuInterAdapterServiceClient is the client API for OnuInterAdapterService service.
1431//
1432// For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
1433type OnuInterAdapterServiceClient interface {
1434 // GetHealthStatus is used by an OnuInterAdapterService client to verify connectivity
1435 // to the gRPC server hosting the OnuInterAdapterService service
1436 GetHealthStatus(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*voltha.HealthStatus, error)
1437 OnuIndication(ctx context.Context, in *inter_container.OnuIndicationMessage, opts ...grpc.CallOption) (*empty.Empty, error)
1438 OmciIndication(ctx context.Context, in *inter_container.OmciMessage, opts ...grpc.CallOption) (*empty.Empty, error)
1439 DownloadTechProfile(ctx context.Context, in *inter_container.TechProfileDownloadMessage, opts ...grpc.CallOption) (*empty.Empty, error)
1440 DeleteGemPort(ctx context.Context, in *inter_container.DeleteGemPortMessage, opts ...grpc.CallOption) (*empty.Empty, error)
1441 DeleteTCont(ctx context.Context, in *inter_container.DeleteTcontMessage, opts ...grpc.CallOption) (*empty.Empty, error)
1442}
1443
1444type onuInterAdapterServiceClient struct {
1445 cc *grpc.ClientConn
1446}
1447
1448func NewOnuInterAdapterServiceClient(cc *grpc.ClientConn) OnuInterAdapterServiceClient {
1449 return &onuInterAdapterServiceClient{cc}
1450}
1451
1452func (c *onuInterAdapterServiceClient) GetHealthStatus(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*voltha.HealthStatus, error) {
1453 out := new(voltha.HealthStatus)
1454 err := c.cc.Invoke(ctx, "/voltha.OnuInterAdapterService/GetHealthStatus", in, out, opts...)
1455 if err != nil {
1456 return nil, err
1457 }
1458 return out, nil
1459}
1460
1461func (c *onuInterAdapterServiceClient) OnuIndication(ctx context.Context, in *inter_container.OnuIndicationMessage, opts ...grpc.CallOption) (*empty.Empty, error) {
1462 out := new(empty.Empty)
1463 err := c.cc.Invoke(ctx, "/voltha.OnuInterAdapterService/OnuIndication", in, out, opts...)
1464 if err != nil {
1465 return nil, err
1466 }
1467 return out, nil
1468}
1469
1470func (c *onuInterAdapterServiceClient) OmciIndication(ctx context.Context, in *inter_container.OmciMessage, opts ...grpc.CallOption) (*empty.Empty, error) {
1471 out := new(empty.Empty)
1472 err := c.cc.Invoke(ctx, "/voltha.OnuInterAdapterService/OmciIndication", in, out, opts...)
1473 if err != nil {
1474 return nil, err
1475 }
1476 return out, nil
1477}
1478
1479func (c *onuInterAdapterServiceClient) DownloadTechProfile(ctx context.Context, in *inter_container.TechProfileDownloadMessage, opts ...grpc.CallOption) (*empty.Empty, error) {
1480 out := new(empty.Empty)
1481 err := c.cc.Invoke(ctx, "/voltha.OnuInterAdapterService/DownloadTechProfile", in, out, opts...)
1482 if err != nil {
1483 return nil, err
1484 }
1485 return out, nil
1486}
1487
1488func (c *onuInterAdapterServiceClient) DeleteGemPort(ctx context.Context, in *inter_container.DeleteGemPortMessage, opts ...grpc.CallOption) (*empty.Empty, error) {
1489 out := new(empty.Empty)
1490 err := c.cc.Invoke(ctx, "/voltha.OnuInterAdapterService/DeleteGemPort", in, out, opts...)
1491 if err != nil {
1492 return nil, err
1493 }
1494 return out, nil
1495}
1496
1497func (c *onuInterAdapterServiceClient) DeleteTCont(ctx context.Context, in *inter_container.DeleteTcontMessage, opts ...grpc.CallOption) (*empty.Empty, error) {
1498 out := new(empty.Empty)
1499 err := c.cc.Invoke(ctx, "/voltha.OnuInterAdapterService/DeleteTCont", in, out, opts...)
1500 if err != nil {
1501 return nil, err
1502 }
1503 return out, nil
1504}
1505
1506// OnuInterAdapterServiceServer is the server API for OnuInterAdapterService service.
1507type OnuInterAdapterServiceServer interface {
1508 // GetHealthStatus is used by an OnuInterAdapterService client to verify connectivity
1509 // to the gRPC server hosting the OnuInterAdapterService service
1510 GetHealthStatus(context.Context, *empty.Empty) (*voltha.HealthStatus, error)
1511 OnuIndication(context.Context, *inter_container.OnuIndicationMessage) (*empty.Empty, error)
1512 OmciIndication(context.Context, *inter_container.OmciMessage) (*empty.Empty, error)
1513 DownloadTechProfile(context.Context, *inter_container.TechProfileDownloadMessage) (*empty.Empty, error)
1514 DeleteGemPort(context.Context, *inter_container.DeleteGemPortMessage) (*empty.Empty, error)
1515 DeleteTCont(context.Context, *inter_container.DeleteTcontMessage) (*empty.Empty, error)
1516}
1517
1518// UnimplementedOnuInterAdapterServiceServer can be embedded to have forward compatible implementations.
1519type UnimplementedOnuInterAdapterServiceServer struct {
1520}
1521
1522func (*UnimplementedOnuInterAdapterServiceServer) GetHealthStatus(ctx context.Context, req *empty.Empty) (*voltha.HealthStatus, error) {
1523 return nil, status.Errorf(codes.Unimplemented, "method GetHealthStatus not implemented")
1524}
1525func (*UnimplementedOnuInterAdapterServiceServer) OnuIndication(ctx context.Context, req *inter_container.OnuIndicationMessage) (*empty.Empty, error) {
1526 return nil, status.Errorf(codes.Unimplemented, "method OnuIndication not implemented")
1527}
1528func (*UnimplementedOnuInterAdapterServiceServer) OmciIndication(ctx context.Context, req *inter_container.OmciMessage) (*empty.Empty, error) {
1529 return nil, status.Errorf(codes.Unimplemented, "method OmciIndication not implemented")
1530}
1531func (*UnimplementedOnuInterAdapterServiceServer) DownloadTechProfile(ctx context.Context, req *inter_container.TechProfileDownloadMessage) (*empty.Empty, error) {
1532 return nil, status.Errorf(codes.Unimplemented, "method DownloadTechProfile not implemented")
1533}
1534func (*UnimplementedOnuInterAdapterServiceServer) DeleteGemPort(ctx context.Context, req *inter_container.DeleteGemPortMessage) (*empty.Empty, error) {
1535 return nil, status.Errorf(codes.Unimplemented, "method DeleteGemPort not implemented")
1536}
1537func (*UnimplementedOnuInterAdapterServiceServer) DeleteTCont(ctx context.Context, req *inter_container.DeleteTcontMessage) (*empty.Empty, error) {
1538 return nil, status.Errorf(codes.Unimplemented, "method DeleteTCont not implemented")
1539}
1540
1541func RegisterOnuInterAdapterServiceServer(s *grpc.Server, srv OnuInterAdapterServiceServer) {
1542 s.RegisterService(&_OnuInterAdapterService_serviceDesc, srv)
1543}
1544
1545func _OnuInterAdapterService_GetHealthStatus_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
1546 in := new(empty.Empty)
1547 if err := dec(in); err != nil {
1548 return nil, err
1549 }
1550 if interceptor == nil {
1551 return srv.(OnuInterAdapterServiceServer).GetHealthStatus(ctx, in)
1552 }
1553 info := &grpc.UnaryServerInfo{
1554 Server: srv,
1555 FullMethod: "/voltha.OnuInterAdapterService/GetHealthStatus",
1556 }
1557 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
1558 return srv.(OnuInterAdapterServiceServer).GetHealthStatus(ctx, req.(*empty.Empty))
1559 }
1560 return interceptor(ctx, in, info, handler)
1561}
1562
1563func _OnuInterAdapterService_OnuIndication_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
1564 in := new(inter_container.OnuIndicationMessage)
1565 if err := dec(in); err != nil {
1566 return nil, err
1567 }
1568 if interceptor == nil {
1569 return srv.(OnuInterAdapterServiceServer).OnuIndication(ctx, in)
1570 }
1571 info := &grpc.UnaryServerInfo{
1572 Server: srv,
1573 FullMethod: "/voltha.OnuInterAdapterService/OnuIndication",
1574 }
1575 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
1576 return srv.(OnuInterAdapterServiceServer).OnuIndication(ctx, req.(*inter_container.OnuIndicationMessage))
1577 }
1578 return interceptor(ctx, in, info, handler)
1579}
1580
1581func _OnuInterAdapterService_OmciIndication_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
1582 in := new(inter_container.OmciMessage)
1583 if err := dec(in); err != nil {
1584 return nil, err
1585 }
1586 if interceptor == nil {
1587 return srv.(OnuInterAdapterServiceServer).OmciIndication(ctx, in)
1588 }
1589 info := &grpc.UnaryServerInfo{
1590 Server: srv,
1591 FullMethod: "/voltha.OnuInterAdapterService/OmciIndication",
1592 }
1593 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
1594 return srv.(OnuInterAdapterServiceServer).OmciIndication(ctx, req.(*inter_container.OmciMessage))
1595 }
1596 return interceptor(ctx, in, info, handler)
1597}
1598
1599func _OnuInterAdapterService_DownloadTechProfile_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
1600 in := new(inter_container.TechProfileDownloadMessage)
1601 if err := dec(in); err != nil {
1602 return nil, err
1603 }
1604 if interceptor == nil {
1605 return srv.(OnuInterAdapterServiceServer).DownloadTechProfile(ctx, in)
1606 }
1607 info := &grpc.UnaryServerInfo{
1608 Server: srv,
1609 FullMethod: "/voltha.OnuInterAdapterService/DownloadTechProfile",
1610 }
1611 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
1612 return srv.(OnuInterAdapterServiceServer).DownloadTechProfile(ctx, req.(*inter_container.TechProfileDownloadMessage))
1613 }
1614 return interceptor(ctx, in, info, handler)
1615}
1616
1617func _OnuInterAdapterService_DeleteGemPort_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
1618 in := new(inter_container.DeleteGemPortMessage)
1619 if err := dec(in); err != nil {
1620 return nil, err
1621 }
1622 if interceptor == nil {
1623 return srv.(OnuInterAdapterServiceServer).DeleteGemPort(ctx, in)
1624 }
1625 info := &grpc.UnaryServerInfo{
1626 Server: srv,
1627 FullMethod: "/voltha.OnuInterAdapterService/DeleteGemPort",
1628 }
1629 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
1630 return srv.(OnuInterAdapterServiceServer).DeleteGemPort(ctx, req.(*inter_container.DeleteGemPortMessage))
1631 }
1632 return interceptor(ctx, in, info, handler)
1633}
1634
1635func _OnuInterAdapterService_DeleteTCont_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
1636 in := new(inter_container.DeleteTcontMessage)
1637 if err := dec(in); err != nil {
1638 return nil, err
1639 }
1640 if interceptor == nil {
1641 return srv.(OnuInterAdapterServiceServer).DeleteTCont(ctx, in)
1642 }
1643 info := &grpc.UnaryServerInfo{
1644 Server: srv,
1645 FullMethod: "/voltha.OnuInterAdapterService/DeleteTCont",
1646 }
1647 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
1648 return srv.(OnuInterAdapterServiceServer).DeleteTCont(ctx, req.(*inter_container.DeleteTcontMessage))
1649 }
1650 return interceptor(ctx, in, info, handler)
1651}
1652
1653var _OnuInterAdapterService_serviceDesc = grpc.ServiceDesc{
1654 ServiceName: "voltha.OnuInterAdapterService",
1655 HandlerType: (*OnuInterAdapterServiceServer)(nil),
1656 Methods: []grpc.MethodDesc{
1657 {
1658 MethodName: "GetHealthStatus",
1659 Handler: _OnuInterAdapterService_GetHealthStatus_Handler,
1660 },
1661 {
1662 MethodName: "OnuIndication",
1663 Handler: _OnuInterAdapterService_OnuIndication_Handler,
1664 },
1665 {
1666 MethodName: "OmciIndication",
1667 Handler: _OnuInterAdapterService_OmciIndication_Handler,
1668 },
1669 {
1670 MethodName: "DownloadTechProfile",
1671 Handler: _OnuInterAdapterService_DownloadTechProfile_Handler,
1672 },
1673 {
1674 MethodName: "DeleteGemPort",
1675 Handler: _OnuInterAdapterService_DeleteGemPort_Handler,
1676 },
1677 {
1678 MethodName: "DeleteTCont",
1679 Handler: _OnuInterAdapterService_DeleteTCont_Handler,
1680 },
1681 },
1682 Streams: []grpc.StreamDesc{},
1683 Metadata: "voltha_protos/adapter_services.proto",
1684}
1685
1686// OltInterAdapterServiceClient is the client API for OltInterAdapterService service.
1687//
1688// For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
1689type OltInterAdapterServiceClient interface {
1690 // GetHealthStatus is used by an OltInterAdapterService client to verify connectivity
1691 // to the gRPC server hosting the OltInterAdapterService service
1692 GetHealthStatus(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*voltha.HealthStatus, error)
1693 ProxyOmciRequest(ctx context.Context, in *inter_container.OmciMessage, opts ...grpc.CallOption) (*empty.Empty, error)
1694 GetTechProfileInstance(ctx context.Context, in *inter_container.TechProfileInstanceRequestMessage, opts ...grpc.CallOption) (*inter_container.TechProfileDownloadMessage, error)
1695}
1696
1697type oltInterAdapterServiceClient struct {
1698 cc *grpc.ClientConn
1699}
1700
1701func NewOltInterAdapterServiceClient(cc *grpc.ClientConn) OltInterAdapterServiceClient {
1702 return &oltInterAdapterServiceClient{cc}
1703}
1704
1705func (c *oltInterAdapterServiceClient) GetHealthStatus(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*voltha.HealthStatus, error) {
1706 out := new(voltha.HealthStatus)
1707 err := c.cc.Invoke(ctx, "/voltha.OltInterAdapterService/GetHealthStatus", in, out, opts...)
1708 if err != nil {
1709 return nil, err
1710 }
1711 return out, nil
1712}
1713
1714func (c *oltInterAdapterServiceClient) ProxyOmciRequest(ctx context.Context, in *inter_container.OmciMessage, opts ...grpc.CallOption) (*empty.Empty, error) {
1715 out := new(empty.Empty)
1716 err := c.cc.Invoke(ctx, "/voltha.OltInterAdapterService/ProxyOmciRequest", in, out, opts...)
1717 if err != nil {
1718 return nil, err
1719 }
1720 return out, nil
1721}
1722
1723func (c *oltInterAdapterServiceClient) GetTechProfileInstance(ctx context.Context, in *inter_container.TechProfileInstanceRequestMessage, opts ...grpc.CallOption) (*inter_container.TechProfileDownloadMessage, error) {
1724 out := new(inter_container.TechProfileDownloadMessage)
1725 err := c.cc.Invoke(ctx, "/voltha.OltInterAdapterService/GetTechProfileInstance", in, out, opts...)
1726 if err != nil {
1727 return nil, err
1728 }
1729 return out, nil
1730}
1731
1732// OltInterAdapterServiceServer is the server API for OltInterAdapterService service.
1733type OltInterAdapterServiceServer interface {
1734 // GetHealthStatus is used by an OltInterAdapterService client to verify connectivity
1735 // to the gRPC server hosting the OltInterAdapterService service
1736 GetHealthStatus(context.Context, *empty.Empty) (*voltha.HealthStatus, error)
1737 ProxyOmciRequest(context.Context, *inter_container.OmciMessage) (*empty.Empty, error)
1738 GetTechProfileInstance(context.Context, *inter_container.TechProfileInstanceRequestMessage) (*inter_container.TechProfileDownloadMessage, error)
1739}
1740
1741// UnimplementedOltInterAdapterServiceServer can be embedded to have forward compatible implementations.
1742type UnimplementedOltInterAdapterServiceServer struct {
1743}
1744
1745func (*UnimplementedOltInterAdapterServiceServer) GetHealthStatus(ctx context.Context, req *empty.Empty) (*voltha.HealthStatus, error) {
1746 return nil, status.Errorf(codes.Unimplemented, "method GetHealthStatus not implemented")
1747}
1748func (*UnimplementedOltInterAdapterServiceServer) ProxyOmciRequest(ctx context.Context, req *inter_container.OmciMessage) (*empty.Empty, error) {
1749 return nil, status.Errorf(codes.Unimplemented, "method ProxyOmciRequest not implemented")
1750}
1751func (*UnimplementedOltInterAdapterServiceServer) GetTechProfileInstance(ctx context.Context, req *inter_container.TechProfileInstanceRequestMessage) (*inter_container.TechProfileDownloadMessage, error) {
1752 return nil, status.Errorf(codes.Unimplemented, "method GetTechProfileInstance not implemented")
1753}
1754
1755func RegisterOltInterAdapterServiceServer(s *grpc.Server, srv OltInterAdapterServiceServer) {
1756 s.RegisterService(&_OltInterAdapterService_serviceDesc, srv)
1757}
1758
1759func _OltInterAdapterService_GetHealthStatus_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
1760 in := new(empty.Empty)
1761 if err := dec(in); err != nil {
1762 return nil, err
1763 }
1764 if interceptor == nil {
1765 return srv.(OltInterAdapterServiceServer).GetHealthStatus(ctx, in)
1766 }
1767 info := &grpc.UnaryServerInfo{
1768 Server: srv,
1769 FullMethod: "/voltha.OltInterAdapterService/GetHealthStatus",
1770 }
1771 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
1772 return srv.(OltInterAdapterServiceServer).GetHealthStatus(ctx, req.(*empty.Empty))
1773 }
1774 return interceptor(ctx, in, info, handler)
1775}
1776
1777func _OltInterAdapterService_ProxyOmciRequest_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
1778 in := new(inter_container.OmciMessage)
1779 if err := dec(in); err != nil {
1780 return nil, err
1781 }
1782 if interceptor == nil {
1783 return srv.(OltInterAdapterServiceServer).ProxyOmciRequest(ctx, in)
1784 }
1785 info := &grpc.UnaryServerInfo{
1786 Server: srv,
1787 FullMethod: "/voltha.OltInterAdapterService/ProxyOmciRequest",
1788 }
1789 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
1790 return srv.(OltInterAdapterServiceServer).ProxyOmciRequest(ctx, req.(*inter_container.OmciMessage))
1791 }
1792 return interceptor(ctx, in, info, handler)
1793}
1794
1795func _OltInterAdapterService_GetTechProfileInstance_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
1796 in := new(inter_container.TechProfileInstanceRequestMessage)
1797 if err := dec(in); err != nil {
1798 return nil, err
1799 }
1800 if interceptor == nil {
1801 return srv.(OltInterAdapterServiceServer).GetTechProfileInstance(ctx, in)
1802 }
1803 info := &grpc.UnaryServerInfo{
1804 Server: srv,
1805 FullMethod: "/voltha.OltInterAdapterService/GetTechProfileInstance",
1806 }
1807 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
1808 return srv.(OltInterAdapterServiceServer).GetTechProfileInstance(ctx, req.(*inter_container.TechProfileInstanceRequestMessage))
1809 }
1810 return interceptor(ctx, in, info, handler)
1811}
1812
1813var _OltInterAdapterService_serviceDesc = grpc.ServiceDesc{
1814 ServiceName: "voltha.OltInterAdapterService",
1815 HandlerType: (*OltInterAdapterServiceServer)(nil),
1816 Methods: []grpc.MethodDesc{
1817 {
1818 MethodName: "GetHealthStatus",
1819 Handler: _OltInterAdapterService_GetHealthStatus_Handler,
1820 },
1821 {
1822 MethodName: "ProxyOmciRequest",
1823 Handler: _OltInterAdapterService_ProxyOmciRequest_Handler,
1824 },
1825 {
1826 MethodName: "GetTechProfileInstance",
1827 Handler: _OltInterAdapterService_GetTechProfileInstance_Handler,
1828 },
1829 },
1830 Streams: []grpc.StreamDesc{},
1831 Metadata: "voltha_protos/adapter_services.proto",
1832}