1
2
3
4
5
6
7 package discoveryv2
8
9 import (
10 context "context"
11 _ "github.com/cncf/xds/go/udpa/annotations"
12 v2 "github.com/emissary-ingress/emissary/v3/pkg/api/envoy/api/v2"
13 grpc "google.golang.org/grpc"
14 codes "google.golang.org/grpc/codes"
15 status "google.golang.org/grpc/status"
16 protoreflect "google.golang.org/protobuf/reflect/protoreflect"
17 protoimpl "google.golang.org/protobuf/runtime/protoimpl"
18 reflect "reflect"
19 sync "sync"
20 )
21
22 const (
23
24 _ = protoimpl.EnforceVersion(20 - protoimpl.MinVersion)
25
26 _ = protoimpl.EnforceVersion(protoimpl.MaxVersion - 20)
27 )
28
29
30
31 type AdsDummy struct {
32 state protoimpl.MessageState
33 sizeCache protoimpl.SizeCache
34 unknownFields protoimpl.UnknownFields
35 }
36
37 func (x *AdsDummy) Reset() {
38 *x = AdsDummy{}
39 if protoimpl.UnsafeEnabled {
40 mi := &file_envoy_service_discovery_v2_ads_proto_msgTypes[0]
41 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
42 ms.StoreMessageInfo(mi)
43 }
44 }
45
46 func (x *AdsDummy) String() string {
47 return protoimpl.X.MessageStringOf(x)
48 }
49
50 func (*AdsDummy) ProtoMessage() {}
51
52 func (x *AdsDummy) ProtoReflect() protoreflect.Message {
53 mi := &file_envoy_service_discovery_v2_ads_proto_msgTypes[0]
54 if protoimpl.UnsafeEnabled && x != nil {
55 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
56 if ms.LoadMessageInfo() == nil {
57 ms.StoreMessageInfo(mi)
58 }
59 return ms
60 }
61 return mi.MessageOf(x)
62 }
63
64
65 func (*AdsDummy) Descriptor() ([]byte, []int) {
66 return file_envoy_service_discovery_v2_ads_proto_rawDescGZIP(), []int{0}
67 }
68
69 var File_envoy_service_discovery_v2_ads_proto protoreflect.FileDescriptor
70
71 var file_envoy_service_discovery_v2_ads_proto_rawDesc = []byte{
72 0x0a, 0x24, 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x2f, 0x73, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x2f,
73 0x64, 0x69, 0x73, 0x63, 0x6f, 0x76, 0x65, 0x72, 0x79, 0x2f, 0x76, 0x32, 0x2f, 0x61, 0x64, 0x73,
74 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x12, 0x1a, 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x2e, 0x73, 0x65,
75 0x72, 0x76, 0x69, 0x63, 0x65, 0x2e, 0x64, 0x69, 0x73, 0x63, 0x6f, 0x76, 0x65, 0x72, 0x79, 0x2e,
76 0x76, 0x32, 0x1a, 0x1c, 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x2f, 0x61, 0x70, 0x69, 0x2f, 0x76, 0x32,
77 0x2f, 0x64, 0x69, 0x73, 0x63, 0x6f, 0x76, 0x65, 0x72, 0x79, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f,
78 0x1a, 0x1d, 0x75, 0x64, 0x70, 0x61, 0x2f, 0x61, 0x6e, 0x6e, 0x6f, 0x74, 0x61, 0x74, 0x69, 0x6f,
79 0x6e, 0x73, 0x2f, 0x73, 0x74, 0x61, 0x74, 0x75, 0x73, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x22,
80 0x0a, 0x0a, 0x08, 0x41, 0x64, 0x73, 0x44, 0x75, 0x6d, 0x6d, 0x79, 0x32, 0xed, 0x01, 0x0a, 0x1a,
81 0x41, 0x67, 0x67, 0x72, 0x65, 0x67, 0x61, 0x74, 0x65, 0x64, 0x44, 0x69, 0x73, 0x63, 0x6f, 0x76,
82 0x65, 0x72, 0x79, 0x53, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x12, 0x62, 0x0a, 0x19, 0x53, 0x74,
83 0x72, 0x65, 0x61, 0x6d, 0x41, 0x67, 0x67, 0x72, 0x65, 0x67, 0x61, 0x74, 0x65, 0x64, 0x52, 0x65,
84 0x73, 0x6f, 0x75, 0x72, 0x63, 0x65, 0x73, 0x12, 0x1e, 0x2e, 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x2e,
85 0x61, 0x70, 0x69, 0x2e, 0x76, 0x32, 0x2e, 0x44, 0x69, 0x73, 0x63, 0x6f, 0x76, 0x65, 0x72, 0x79,
86 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x1f, 0x2e, 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x2e,
87 0x61, 0x70, 0x69, 0x2e, 0x76, 0x32, 0x2e, 0x44, 0x69, 0x73, 0x63, 0x6f, 0x76, 0x65, 0x72, 0x79,
88 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x00, 0x28, 0x01, 0x30, 0x01, 0x12, 0x6b,
89 0x0a, 0x18, 0x44, 0x65, 0x6c, 0x74, 0x61, 0x41, 0x67, 0x67, 0x72, 0x65, 0x67, 0x61, 0x74, 0x65,
90 0x64, 0x52, 0x65, 0x73, 0x6f, 0x75, 0x72, 0x63, 0x65, 0x73, 0x12, 0x23, 0x2e, 0x65, 0x6e, 0x76,
91 0x6f, 0x79, 0x2e, 0x61, 0x70, 0x69, 0x2e, 0x76, 0x32, 0x2e, 0x44, 0x65, 0x6c, 0x74, 0x61, 0x44,
92 0x69, 0x73, 0x63, 0x6f, 0x76, 0x65, 0x72, 0x79, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a,
93 0x24, 0x2e, 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x2e, 0x61, 0x70, 0x69, 0x2e, 0x76, 0x32, 0x2e, 0x44,
94 0x65, 0x6c, 0x74, 0x61, 0x44, 0x69, 0x73, 0x63, 0x6f, 0x76, 0x65, 0x72, 0x79, 0x52, 0x65, 0x73,
95 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x00, 0x28, 0x01, 0x30, 0x01, 0x42, 0x90, 0x01, 0x0a, 0x28,
96 0x69, 0x6f, 0x2e, 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x70, 0x72, 0x6f, 0x78, 0x79, 0x2e, 0x65, 0x6e,
97 0x76, 0x6f, 0x79, 0x2e, 0x73, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x2e, 0x64, 0x69, 0x73, 0x63,
98 0x6f, 0x76, 0x65, 0x72, 0x79, 0x2e, 0x76, 0x32, 0x42, 0x08, 0x41, 0x64, 0x73, 0x50, 0x72, 0x6f,
99 0x74, 0x6f, 0x50, 0x01, 0x5a, 0x4d, 0x67, 0x69, 0x74, 0x68, 0x75, 0x62, 0x2e, 0x63, 0x6f, 0x6d,
100 0x2f, 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x70, 0x72, 0x6f, 0x78, 0x79, 0x2f, 0x67, 0x6f, 0x2d, 0x63,
101 0x6f, 0x6e, 0x74, 0x72, 0x6f, 0x6c, 0x2d, 0x70, 0x6c, 0x61, 0x6e, 0x65, 0x2f, 0x65, 0x6e, 0x76,
102 0x6f, 0x79, 0x2f, 0x73, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x2f, 0x64, 0x69, 0x73, 0x63, 0x6f,
103 0x76, 0x65, 0x72, 0x79, 0x2f, 0x76, 0x32, 0x3b, 0x64, 0x69, 0x73, 0x63, 0x6f, 0x76, 0x65, 0x72,
104 0x79, 0x76, 0x32, 0x88, 0x01, 0x01, 0xba, 0x80, 0xc8, 0xd1, 0x06, 0x02, 0x10, 0x01, 0x62, 0x06,
105 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x33,
106 }
107
108 var (
109 file_envoy_service_discovery_v2_ads_proto_rawDescOnce sync.Once
110 file_envoy_service_discovery_v2_ads_proto_rawDescData = file_envoy_service_discovery_v2_ads_proto_rawDesc
111 )
112
113 func file_envoy_service_discovery_v2_ads_proto_rawDescGZIP() []byte {
114 file_envoy_service_discovery_v2_ads_proto_rawDescOnce.Do(func() {
115 file_envoy_service_discovery_v2_ads_proto_rawDescData = protoimpl.X.CompressGZIP(file_envoy_service_discovery_v2_ads_proto_rawDescData)
116 })
117 return file_envoy_service_discovery_v2_ads_proto_rawDescData
118 }
119
120 var file_envoy_service_discovery_v2_ads_proto_msgTypes = make([]protoimpl.MessageInfo, 1)
121 var file_envoy_service_discovery_v2_ads_proto_goTypes = []interface{}{
122 (*AdsDummy)(nil),
123 (*v2.DiscoveryRequest)(nil),
124 (*v2.DeltaDiscoveryRequest)(nil),
125 (*v2.DiscoveryResponse)(nil),
126 (*v2.DeltaDiscoveryResponse)(nil),
127 }
128 var file_envoy_service_discovery_v2_ads_proto_depIdxs = []int32{
129 1,
130 2,
131 3,
132 4,
133 2,
134 0,
135 0,
136 0,
137 0,
138 }
139
140 func init() { file_envoy_service_discovery_v2_ads_proto_init() }
141 func file_envoy_service_discovery_v2_ads_proto_init() {
142 if File_envoy_service_discovery_v2_ads_proto != nil {
143 return
144 }
145 if !protoimpl.UnsafeEnabled {
146 file_envoy_service_discovery_v2_ads_proto_msgTypes[0].Exporter = func(v interface{}, i int) interface{} {
147 switch v := v.(*AdsDummy); i {
148 case 0:
149 return &v.state
150 case 1:
151 return &v.sizeCache
152 case 2:
153 return &v.unknownFields
154 default:
155 return nil
156 }
157 }
158 }
159 type x struct{}
160 out := protoimpl.TypeBuilder{
161 File: protoimpl.DescBuilder{
162 GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
163 RawDescriptor: file_envoy_service_discovery_v2_ads_proto_rawDesc,
164 NumEnums: 0,
165 NumMessages: 1,
166 NumExtensions: 0,
167 NumServices: 1,
168 },
169 GoTypes: file_envoy_service_discovery_v2_ads_proto_goTypes,
170 DependencyIndexes: file_envoy_service_discovery_v2_ads_proto_depIdxs,
171 MessageInfos: file_envoy_service_discovery_v2_ads_proto_msgTypes,
172 }.Build()
173 File_envoy_service_discovery_v2_ads_proto = out.File
174 file_envoy_service_discovery_v2_ads_proto_rawDesc = nil
175 file_envoy_service_discovery_v2_ads_proto_goTypes = nil
176 file_envoy_service_discovery_v2_ads_proto_depIdxs = nil
177 }
178
179
180 var _ context.Context
181 var _ grpc.ClientConnInterface
182
183
184
185 const _ = grpc.SupportPackageIsVersion6
186
187
188
189
190 type AggregatedDiscoveryServiceClient interface {
191
192 StreamAggregatedResources(ctx context.Context, opts ...grpc.CallOption) (AggregatedDiscoveryService_StreamAggregatedResourcesClient, error)
193 DeltaAggregatedResources(ctx context.Context, opts ...grpc.CallOption) (AggregatedDiscoveryService_DeltaAggregatedResourcesClient, error)
194 }
195
196 type aggregatedDiscoveryServiceClient struct {
197 cc grpc.ClientConnInterface
198 }
199
200 func NewAggregatedDiscoveryServiceClient(cc grpc.ClientConnInterface) AggregatedDiscoveryServiceClient {
201 return &aggregatedDiscoveryServiceClient{cc}
202 }
203
204 func (c *aggregatedDiscoveryServiceClient) StreamAggregatedResources(ctx context.Context, opts ...grpc.CallOption) (AggregatedDiscoveryService_StreamAggregatedResourcesClient, error) {
205 stream, err := c.cc.NewStream(ctx, &_AggregatedDiscoveryService_serviceDesc.Streams[0], "/envoy.service.discovery.v2.AggregatedDiscoveryService/StreamAggregatedResources", opts...)
206 if err != nil {
207 return nil, err
208 }
209 x := &aggregatedDiscoveryServiceStreamAggregatedResourcesClient{stream}
210 return x, nil
211 }
212
213 type AggregatedDiscoveryService_StreamAggregatedResourcesClient interface {
214 Send(*v2.DiscoveryRequest) error
215 Recv() (*v2.DiscoveryResponse, error)
216 grpc.ClientStream
217 }
218
219 type aggregatedDiscoveryServiceStreamAggregatedResourcesClient struct {
220 grpc.ClientStream
221 }
222
223 func (x *aggregatedDiscoveryServiceStreamAggregatedResourcesClient) Send(m *v2.DiscoveryRequest) error {
224 return x.ClientStream.SendMsg(m)
225 }
226
227 func (x *aggregatedDiscoveryServiceStreamAggregatedResourcesClient) Recv() (*v2.DiscoveryResponse, error) {
228 m := new(v2.DiscoveryResponse)
229 if err := x.ClientStream.RecvMsg(m); err != nil {
230 return nil, err
231 }
232 return m, nil
233 }
234
235 func (c *aggregatedDiscoveryServiceClient) DeltaAggregatedResources(ctx context.Context, opts ...grpc.CallOption) (AggregatedDiscoveryService_DeltaAggregatedResourcesClient, error) {
236 stream, err := c.cc.NewStream(ctx, &_AggregatedDiscoveryService_serviceDesc.Streams[1], "/envoy.service.discovery.v2.AggregatedDiscoveryService/DeltaAggregatedResources", opts...)
237 if err != nil {
238 return nil, err
239 }
240 x := &aggregatedDiscoveryServiceDeltaAggregatedResourcesClient{stream}
241 return x, nil
242 }
243
244 type AggregatedDiscoveryService_DeltaAggregatedResourcesClient interface {
245 Send(*v2.DeltaDiscoveryRequest) error
246 Recv() (*v2.DeltaDiscoveryResponse, error)
247 grpc.ClientStream
248 }
249
250 type aggregatedDiscoveryServiceDeltaAggregatedResourcesClient struct {
251 grpc.ClientStream
252 }
253
254 func (x *aggregatedDiscoveryServiceDeltaAggregatedResourcesClient) Send(m *v2.DeltaDiscoveryRequest) error {
255 return x.ClientStream.SendMsg(m)
256 }
257
258 func (x *aggregatedDiscoveryServiceDeltaAggregatedResourcesClient) Recv() (*v2.DeltaDiscoveryResponse, error) {
259 m := new(v2.DeltaDiscoveryResponse)
260 if err := x.ClientStream.RecvMsg(m); err != nil {
261 return nil, err
262 }
263 return m, nil
264 }
265
266
267 type AggregatedDiscoveryServiceServer interface {
268
269 StreamAggregatedResources(AggregatedDiscoveryService_StreamAggregatedResourcesServer) error
270 DeltaAggregatedResources(AggregatedDiscoveryService_DeltaAggregatedResourcesServer) error
271 }
272
273
274 type UnimplementedAggregatedDiscoveryServiceServer struct {
275 }
276
277 func (*UnimplementedAggregatedDiscoveryServiceServer) StreamAggregatedResources(AggregatedDiscoveryService_StreamAggregatedResourcesServer) error {
278 return status.Errorf(codes.Unimplemented, "method StreamAggregatedResources not implemented")
279 }
280 func (*UnimplementedAggregatedDiscoveryServiceServer) DeltaAggregatedResources(AggregatedDiscoveryService_DeltaAggregatedResourcesServer) error {
281 return status.Errorf(codes.Unimplemented, "method DeltaAggregatedResources not implemented")
282 }
283
284 func RegisterAggregatedDiscoveryServiceServer(s *grpc.Server, srv AggregatedDiscoveryServiceServer) {
285 s.RegisterService(&_AggregatedDiscoveryService_serviceDesc, srv)
286 }
287
288 func _AggregatedDiscoveryService_StreamAggregatedResources_Handler(srv interface{}, stream grpc.ServerStream) error {
289 return srv.(AggregatedDiscoveryServiceServer).StreamAggregatedResources(&aggregatedDiscoveryServiceStreamAggregatedResourcesServer{stream})
290 }
291
292 type AggregatedDiscoveryService_StreamAggregatedResourcesServer interface {
293 Send(*v2.DiscoveryResponse) error
294 Recv() (*v2.DiscoveryRequest, error)
295 grpc.ServerStream
296 }
297
298 type aggregatedDiscoveryServiceStreamAggregatedResourcesServer struct {
299 grpc.ServerStream
300 }
301
302 func (x *aggregatedDiscoveryServiceStreamAggregatedResourcesServer) Send(m *v2.DiscoveryResponse) error {
303 return x.ServerStream.SendMsg(m)
304 }
305
306 func (x *aggregatedDiscoveryServiceStreamAggregatedResourcesServer) Recv() (*v2.DiscoveryRequest, error) {
307 m := new(v2.DiscoveryRequest)
308 if err := x.ServerStream.RecvMsg(m); err != nil {
309 return nil, err
310 }
311 return m, nil
312 }
313
314 func _AggregatedDiscoveryService_DeltaAggregatedResources_Handler(srv interface{}, stream grpc.ServerStream) error {
315 return srv.(AggregatedDiscoveryServiceServer).DeltaAggregatedResources(&aggregatedDiscoveryServiceDeltaAggregatedResourcesServer{stream})
316 }
317
318 type AggregatedDiscoveryService_DeltaAggregatedResourcesServer interface {
319 Send(*v2.DeltaDiscoveryResponse) error
320 Recv() (*v2.DeltaDiscoveryRequest, error)
321 grpc.ServerStream
322 }
323
324 type aggregatedDiscoveryServiceDeltaAggregatedResourcesServer struct {
325 grpc.ServerStream
326 }
327
328 func (x *aggregatedDiscoveryServiceDeltaAggregatedResourcesServer) Send(m *v2.DeltaDiscoveryResponse) error {
329 return x.ServerStream.SendMsg(m)
330 }
331
332 func (x *aggregatedDiscoveryServiceDeltaAggregatedResourcesServer) Recv() (*v2.DeltaDiscoveryRequest, error) {
333 m := new(v2.DeltaDiscoveryRequest)
334 if err := x.ServerStream.RecvMsg(m); err != nil {
335 return nil, err
336 }
337 return m, nil
338 }
339
340 var _AggregatedDiscoveryService_serviceDesc = grpc.ServiceDesc{
341 ServiceName: "envoy.service.discovery.v2.AggregatedDiscoveryService",
342 HandlerType: (*AggregatedDiscoveryServiceServer)(nil),
343 Methods: []grpc.MethodDesc{},
344 Streams: []grpc.StreamDesc{
345 {
346 StreamName: "StreamAggregatedResources",
347 Handler: _AggregatedDiscoveryService_StreamAggregatedResources_Handler,
348 ServerStreams: true,
349 ClientStreams: true,
350 },
351 {
352 StreamName: "DeltaAggregatedResources",
353 Handler: _AggregatedDiscoveryService_DeltaAggregatedResources_Handler,
354 ServerStreams: true,
355 ClientStreams: true,
356 },
357 },
358 Metadata: "envoy/service/discovery/v2/ads.proto",
359 }
360
View as plain text