1
2
3
4
5
6
7 package envoy_service_status_v3
8
9 import (
10 context "context"
11 _ "github.com/cncf/udpa/go/udpa/annotations"
12 v32 "github.com/datawire/ambassador/v2/pkg/api/envoy/admin/v3"
13 v31 "github.com/datawire/ambassador/v2/pkg/api/envoy/config/core/v3"
14 v3 "github.com/datawire/ambassador/v2/pkg/api/envoy/type/matcher/v3"
15 proto "github.com/golang/protobuf/proto"
16 _ "github.com/golang/protobuf/ptypes/struct"
17 _ "google.golang.org/genproto/googleapis/api/annotations"
18 grpc "google.golang.org/grpc"
19 codes "google.golang.org/grpc/codes"
20 status "google.golang.org/grpc/status"
21 protoreflect "google.golang.org/protobuf/reflect/protoreflect"
22 protoimpl "google.golang.org/protobuf/runtime/protoimpl"
23 reflect "reflect"
24 sync "sync"
25 )
26
27 const (
28
29 _ = protoimpl.EnforceVersion(20 - protoimpl.MinVersion)
30
31 _ = protoimpl.EnforceVersion(protoimpl.MaxVersion - 20)
32 )
33
34
35
36 const _ = proto.ProtoPackageIsVersion4
37
38
39 type ConfigStatus int32
40
41 const (
42
43 ConfigStatus_UNKNOWN ConfigStatus = 0
44
45 ConfigStatus_SYNCED ConfigStatus = 1
46
47 ConfigStatus_NOT_SENT ConfigStatus = 2
48
49
50 ConfigStatus_STALE ConfigStatus = 3
51
52
53
54 ConfigStatus_ERROR ConfigStatus = 4
55 )
56
57
58 var (
59 ConfigStatus_name = map[int32]string{
60 0: "UNKNOWN",
61 1: "SYNCED",
62 2: "NOT_SENT",
63 3: "STALE",
64 4: "ERROR",
65 }
66 ConfigStatus_value = map[string]int32{
67 "UNKNOWN": 0,
68 "SYNCED": 1,
69 "NOT_SENT": 2,
70 "STALE": 3,
71 "ERROR": 4,
72 }
73 )
74
75 func (x ConfigStatus) Enum() *ConfigStatus {
76 p := new(ConfigStatus)
77 *p = x
78 return p
79 }
80
81 func (x ConfigStatus) String() string {
82 return protoimpl.X.EnumStringOf(x.Descriptor(), protoreflect.EnumNumber(x))
83 }
84
85 func (ConfigStatus) Descriptor() protoreflect.EnumDescriptor {
86 return file_envoy_service_status_v3_csds_proto_enumTypes[0].Descriptor()
87 }
88
89 func (ConfigStatus) Type() protoreflect.EnumType {
90 return &file_envoy_service_status_v3_csds_proto_enumTypes[0]
91 }
92
93 func (x ConfigStatus) Number() protoreflect.EnumNumber {
94 return protoreflect.EnumNumber(x)
95 }
96
97
98 func (ConfigStatus) EnumDescriptor() ([]byte, []int) {
99 return file_envoy_service_status_v3_csds_proto_rawDescGZIP(), []int{0}
100 }
101
102
103 type ClientConfigStatus int32
104
105 const (
106
107 ClientConfigStatus_CLIENT_UNKNOWN ClientConfigStatus = 0
108
109
110 ClientConfigStatus_CLIENT_REQUESTED ClientConfigStatus = 1
111
112 ClientConfigStatus_CLIENT_ACKED ClientConfigStatus = 2
113
114
115
116 ClientConfigStatus_CLIENT_NACKED ClientConfigStatus = 3
117 )
118
119
120 var (
121 ClientConfigStatus_name = map[int32]string{
122 0: "CLIENT_UNKNOWN",
123 1: "CLIENT_REQUESTED",
124 2: "CLIENT_ACKED",
125 3: "CLIENT_NACKED",
126 }
127 ClientConfigStatus_value = map[string]int32{
128 "CLIENT_UNKNOWN": 0,
129 "CLIENT_REQUESTED": 1,
130 "CLIENT_ACKED": 2,
131 "CLIENT_NACKED": 3,
132 }
133 )
134
135 func (x ClientConfigStatus) Enum() *ClientConfigStatus {
136 p := new(ClientConfigStatus)
137 *p = x
138 return p
139 }
140
141 func (x ClientConfigStatus) String() string {
142 return protoimpl.X.EnumStringOf(x.Descriptor(), protoreflect.EnumNumber(x))
143 }
144
145 func (ClientConfigStatus) Descriptor() protoreflect.EnumDescriptor {
146 return file_envoy_service_status_v3_csds_proto_enumTypes[1].Descriptor()
147 }
148
149 func (ClientConfigStatus) Type() protoreflect.EnumType {
150 return &file_envoy_service_status_v3_csds_proto_enumTypes[1]
151 }
152
153 func (x ClientConfigStatus) Number() protoreflect.EnumNumber {
154 return protoreflect.EnumNumber(x)
155 }
156
157
158 func (ClientConfigStatus) EnumDescriptor() ([]byte, []int) {
159 return file_envoy_service_status_v3_csds_proto_rawDescGZIP(), []int{1}
160 }
161
162
163 type ClientStatusRequest struct {
164 state protoimpl.MessageState
165 sizeCache protoimpl.SizeCache
166 unknownFields protoimpl.UnknownFields
167
168
169
170 NodeMatchers []*v3.NodeMatcher `protobuf:"bytes,1,rep,name=node_matchers,json=nodeMatchers,proto3" json:"node_matchers,omitempty"`
171
172 Node *v31.Node `protobuf:"bytes,2,opt,name=node,proto3" json:"node,omitempty"`
173 }
174
175 func (x *ClientStatusRequest) Reset() {
176 *x = ClientStatusRequest{}
177 if protoimpl.UnsafeEnabled {
178 mi := &file_envoy_service_status_v3_csds_proto_msgTypes[0]
179 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
180 ms.StoreMessageInfo(mi)
181 }
182 }
183
184 func (x *ClientStatusRequest) String() string {
185 return protoimpl.X.MessageStringOf(x)
186 }
187
188 func (*ClientStatusRequest) ProtoMessage() {}
189
190 func (x *ClientStatusRequest) ProtoReflect() protoreflect.Message {
191 mi := &file_envoy_service_status_v3_csds_proto_msgTypes[0]
192 if protoimpl.UnsafeEnabled && x != nil {
193 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
194 if ms.LoadMessageInfo() == nil {
195 ms.StoreMessageInfo(mi)
196 }
197 return ms
198 }
199 return mi.MessageOf(x)
200 }
201
202
203 func (*ClientStatusRequest) Descriptor() ([]byte, []int) {
204 return file_envoy_service_status_v3_csds_proto_rawDescGZIP(), []int{0}
205 }
206
207 func (x *ClientStatusRequest) GetNodeMatchers() []*v3.NodeMatcher {
208 if x != nil {
209 return x.NodeMatchers
210 }
211 return nil
212 }
213
214 func (x *ClientStatusRequest) GetNode() *v31.Node {
215 if x != nil {
216 return x.Node
217 }
218 return nil
219 }
220
221
222
223 type PerXdsConfig struct {
224 state protoimpl.MessageState
225 sizeCache protoimpl.SizeCache
226 unknownFields protoimpl.UnknownFields
227
228
229
230 Status ConfigStatus `protobuf:"varint,1,opt,name=status,proto3,enum=envoy.service.status.v3.ConfigStatus" json:"status,omitempty"`
231
232
233
234 ClientStatus ClientConfigStatus `protobuf:"varint,7,opt,name=client_status,json=clientStatus,proto3,enum=envoy.service.status.v3.ClientConfigStatus" json:"client_status,omitempty"`
235
236
237
238
239
240
241 PerXdsConfig isPerXdsConfig_PerXdsConfig `protobuf_oneof:"per_xds_config"`
242 }
243
244 func (x *PerXdsConfig) Reset() {
245 *x = PerXdsConfig{}
246 if protoimpl.UnsafeEnabled {
247 mi := &file_envoy_service_status_v3_csds_proto_msgTypes[1]
248 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
249 ms.StoreMessageInfo(mi)
250 }
251 }
252
253 func (x *PerXdsConfig) String() string {
254 return protoimpl.X.MessageStringOf(x)
255 }
256
257 func (*PerXdsConfig) ProtoMessage() {}
258
259 func (x *PerXdsConfig) ProtoReflect() protoreflect.Message {
260 mi := &file_envoy_service_status_v3_csds_proto_msgTypes[1]
261 if protoimpl.UnsafeEnabled && x != nil {
262 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
263 if ms.LoadMessageInfo() == nil {
264 ms.StoreMessageInfo(mi)
265 }
266 return ms
267 }
268 return mi.MessageOf(x)
269 }
270
271
272 func (*PerXdsConfig) Descriptor() ([]byte, []int) {
273 return file_envoy_service_status_v3_csds_proto_rawDescGZIP(), []int{1}
274 }
275
276 func (x *PerXdsConfig) GetStatus() ConfigStatus {
277 if x != nil {
278 return x.Status
279 }
280 return ConfigStatus_UNKNOWN
281 }
282
283 func (x *PerXdsConfig) GetClientStatus() ClientConfigStatus {
284 if x != nil {
285 return x.ClientStatus
286 }
287 return ClientConfigStatus_CLIENT_UNKNOWN
288 }
289
290 func (m *PerXdsConfig) GetPerXdsConfig() isPerXdsConfig_PerXdsConfig {
291 if m != nil {
292 return m.PerXdsConfig
293 }
294 return nil
295 }
296
297 func (x *PerXdsConfig) GetListenerConfig() *v32.ListenersConfigDump {
298 if x, ok := x.GetPerXdsConfig().(*PerXdsConfig_ListenerConfig); ok {
299 return x.ListenerConfig
300 }
301 return nil
302 }
303
304 func (x *PerXdsConfig) GetClusterConfig() *v32.ClustersConfigDump {
305 if x, ok := x.GetPerXdsConfig().(*PerXdsConfig_ClusterConfig); ok {
306 return x.ClusterConfig
307 }
308 return nil
309 }
310
311 func (x *PerXdsConfig) GetRouteConfig() *v32.RoutesConfigDump {
312 if x, ok := x.GetPerXdsConfig().(*PerXdsConfig_RouteConfig); ok {
313 return x.RouteConfig
314 }
315 return nil
316 }
317
318 func (x *PerXdsConfig) GetScopedRouteConfig() *v32.ScopedRoutesConfigDump {
319 if x, ok := x.GetPerXdsConfig().(*PerXdsConfig_ScopedRouteConfig); ok {
320 return x.ScopedRouteConfig
321 }
322 return nil
323 }
324
325 func (x *PerXdsConfig) GetEndpointConfig() *v32.EndpointsConfigDump {
326 if x, ok := x.GetPerXdsConfig().(*PerXdsConfig_EndpointConfig); ok {
327 return x.EndpointConfig
328 }
329 return nil
330 }
331
332 type isPerXdsConfig_PerXdsConfig interface {
333 isPerXdsConfig_PerXdsConfig()
334 }
335
336 type PerXdsConfig_ListenerConfig struct {
337 ListenerConfig *v32.ListenersConfigDump `protobuf:"bytes,2,opt,name=listener_config,json=listenerConfig,proto3,oneof"`
338 }
339
340 type PerXdsConfig_ClusterConfig struct {
341 ClusterConfig *v32.ClustersConfigDump `protobuf:"bytes,3,opt,name=cluster_config,json=clusterConfig,proto3,oneof"`
342 }
343
344 type PerXdsConfig_RouteConfig struct {
345 RouteConfig *v32.RoutesConfigDump `protobuf:"bytes,4,opt,name=route_config,json=routeConfig,proto3,oneof"`
346 }
347
348 type PerXdsConfig_ScopedRouteConfig struct {
349 ScopedRouteConfig *v32.ScopedRoutesConfigDump `protobuf:"bytes,5,opt,name=scoped_route_config,json=scopedRouteConfig,proto3,oneof"`
350 }
351
352 type PerXdsConfig_EndpointConfig struct {
353 EndpointConfig *v32.EndpointsConfigDump `protobuf:"bytes,6,opt,name=endpoint_config,json=endpointConfig,proto3,oneof"`
354 }
355
356 func (*PerXdsConfig_ListenerConfig) isPerXdsConfig_PerXdsConfig() {}
357
358 func (*PerXdsConfig_ClusterConfig) isPerXdsConfig_PerXdsConfig() {}
359
360 func (*PerXdsConfig_RouteConfig) isPerXdsConfig_PerXdsConfig() {}
361
362 func (*PerXdsConfig_ScopedRouteConfig) isPerXdsConfig_PerXdsConfig() {}
363
364 func (*PerXdsConfig_EndpointConfig) isPerXdsConfig_PerXdsConfig() {}
365
366
367 type ClientConfig struct {
368 state protoimpl.MessageState
369 sizeCache protoimpl.SizeCache
370 unknownFields protoimpl.UnknownFields
371
372
373 Node *v31.Node `protobuf:"bytes,1,opt,name=node,proto3" json:"node,omitempty"`
374 XdsConfig []*PerXdsConfig `protobuf:"bytes,2,rep,name=xds_config,json=xdsConfig,proto3" json:"xds_config,omitempty"`
375 }
376
377 func (x *ClientConfig) Reset() {
378 *x = ClientConfig{}
379 if protoimpl.UnsafeEnabled {
380 mi := &file_envoy_service_status_v3_csds_proto_msgTypes[2]
381 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
382 ms.StoreMessageInfo(mi)
383 }
384 }
385
386 func (x *ClientConfig) String() string {
387 return protoimpl.X.MessageStringOf(x)
388 }
389
390 func (*ClientConfig) ProtoMessage() {}
391
392 func (x *ClientConfig) ProtoReflect() protoreflect.Message {
393 mi := &file_envoy_service_status_v3_csds_proto_msgTypes[2]
394 if protoimpl.UnsafeEnabled && x != nil {
395 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
396 if ms.LoadMessageInfo() == nil {
397 ms.StoreMessageInfo(mi)
398 }
399 return ms
400 }
401 return mi.MessageOf(x)
402 }
403
404
405 func (*ClientConfig) Descriptor() ([]byte, []int) {
406 return file_envoy_service_status_v3_csds_proto_rawDescGZIP(), []int{2}
407 }
408
409 func (x *ClientConfig) GetNode() *v31.Node {
410 if x != nil {
411 return x.Node
412 }
413 return nil
414 }
415
416 func (x *ClientConfig) GetXdsConfig() []*PerXdsConfig {
417 if x != nil {
418 return x.XdsConfig
419 }
420 return nil
421 }
422
423 type ClientStatusResponse struct {
424 state protoimpl.MessageState
425 sizeCache protoimpl.SizeCache
426 unknownFields protoimpl.UnknownFields
427
428
429 Config []*ClientConfig `protobuf:"bytes,1,rep,name=config,proto3" json:"config,omitempty"`
430 }
431
432 func (x *ClientStatusResponse) Reset() {
433 *x = ClientStatusResponse{}
434 if protoimpl.UnsafeEnabled {
435 mi := &file_envoy_service_status_v3_csds_proto_msgTypes[3]
436 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
437 ms.StoreMessageInfo(mi)
438 }
439 }
440
441 func (x *ClientStatusResponse) String() string {
442 return protoimpl.X.MessageStringOf(x)
443 }
444
445 func (*ClientStatusResponse) ProtoMessage() {}
446
447 func (x *ClientStatusResponse) ProtoReflect() protoreflect.Message {
448 mi := &file_envoy_service_status_v3_csds_proto_msgTypes[3]
449 if protoimpl.UnsafeEnabled && x != nil {
450 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
451 if ms.LoadMessageInfo() == nil {
452 ms.StoreMessageInfo(mi)
453 }
454 return ms
455 }
456 return mi.MessageOf(x)
457 }
458
459
460 func (*ClientStatusResponse) Descriptor() ([]byte, []int) {
461 return file_envoy_service_status_v3_csds_proto_rawDescGZIP(), []int{3}
462 }
463
464 func (x *ClientStatusResponse) GetConfig() []*ClientConfig {
465 if x != nil {
466 return x.Config
467 }
468 return nil
469 }
470
471 var File_envoy_service_status_v3_csds_proto protoreflect.FileDescriptor
472
473 var file_envoy_service_status_v3_csds_proto_rawDesc = []byte{
474 0x0a, 0x22, 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x2f, 0x73, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x2f,
475 0x73, 0x74, 0x61, 0x74, 0x75, 0x73, 0x2f, 0x76, 0x33, 0x2f, 0x63, 0x73, 0x64, 0x73, 0x2e, 0x70,
476 0x72, 0x6f, 0x74, 0x6f, 0x12, 0x17, 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x2e, 0x73, 0x65, 0x72, 0x76,
477 0x69, 0x63, 0x65, 0x2e, 0x73, 0x74, 0x61, 0x74, 0x75, 0x73, 0x2e, 0x76, 0x33, 0x1a, 0x20, 0x65,
478 0x6e, 0x76, 0x6f, 0x79, 0x2f, 0x61, 0x64, 0x6d, 0x69, 0x6e, 0x2f, 0x76, 0x33, 0x2f, 0x63, 0x6f,
479 0x6e, 0x66, 0x69, 0x67, 0x5f, 0x64, 0x75, 0x6d, 0x70, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a,
480 0x1f, 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x2f, 0x63, 0x6f, 0x6e, 0x66, 0x69, 0x67, 0x2f, 0x63, 0x6f,
481 0x72, 0x65, 0x2f, 0x76, 0x33, 0x2f, 0x62, 0x61, 0x73, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f,
482 0x1a, 0x20, 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x2f, 0x74, 0x79, 0x70, 0x65, 0x2f, 0x6d, 0x61, 0x74,
483 0x63, 0x68, 0x65, 0x72, 0x2f, 0x76, 0x33, 0x2f, 0x6e, 0x6f, 0x64, 0x65, 0x2e, 0x70, 0x72, 0x6f,
484 0x74, 0x6f, 0x1a, 0x1c, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x61, 0x70, 0x69, 0x2f, 0x61,
485 0x6e, 0x6e, 0x6f, 0x74, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f,
486 0x1a, 0x1c, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75,
487 0x66, 0x2f, 0x73, 0x74, 0x72, 0x75, 0x63, 0x74, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x1e,
488 0x75, 0x64, 0x70, 0x61, 0x2f, 0x61, 0x6e, 0x6e, 0x6f, 0x74, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x73,
489 0x2f, 0x6d, 0x69, 0x67, 0x72, 0x61, 0x74, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x1d,
490 0x75, 0x64, 0x70, 0x61, 0x2f, 0x61, 0x6e, 0x6e, 0x6f, 0x74, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x73,
491 0x2f, 0x73, 0x74, 0x61, 0x74, 0x75, 0x73, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x21, 0x75,
492 0x64, 0x70, 0x61, 0x2f, 0x61, 0x6e, 0x6e, 0x6f, 0x74, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2f,
493 0x76, 0x65, 0x72, 0x73, 0x69, 0x6f, 0x6e, 0x69, 0x6e, 0x67, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f,
494 0x22, 0xc2, 0x01, 0x0a, 0x13, 0x43, 0x6c, 0x69, 0x65, 0x6e, 0x74, 0x53, 0x74, 0x61, 0x74, 0x75,
495 0x73, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x47, 0x0a, 0x0d, 0x6e, 0x6f, 0x64, 0x65,
496 0x5f, 0x6d, 0x61, 0x74, 0x63, 0x68, 0x65, 0x72, 0x73, 0x18, 0x01, 0x20, 0x03, 0x28, 0x0b, 0x32,
497 0x22, 0x2e, 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x2e, 0x74, 0x79, 0x70, 0x65, 0x2e, 0x6d, 0x61, 0x74,
498 0x63, 0x68, 0x65, 0x72, 0x2e, 0x76, 0x33, 0x2e, 0x4e, 0x6f, 0x64, 0x65, 0x4d, 0x61, 0x74, 0x63,
499 0x68, 0x65, 0x72, 0x52, 0x0c, 0x6e, 0x6f, 0x64, 0x65, 0x4d, 0x61, 0x74, 0x63, 0x68, 0x65, 0x72,
500 0x73, 0x12, 0x2e, 0x0a, 0x04, 0x6e, 0x6f, 0x64, 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0b, 0x32,
501 0x1a, 0x2e, 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x2e, 0x63, 0x6f, 0x6e, 0x66, 0x69, 0x67, 0x2e, 0x63,
502 0x6f, 0x72, 0x65, 0x2e, 0x76, 0x33, 0x2e, 0x4e, 0x6f, 0x64, 0x65, 0x52, 0x04, 0x6e, 0x6f, 0x64,
503 0x65, 0x3a, 0x32, 0x9a, 0xc5, 0x88, 0x1e, 0x2d, 0x0a, 0x2b, 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x2e,
504 0x73, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x2e, 0x73, 0x74, 0x61, 0x74, 0x75, 0x73, 0x2e, 0x76,
505 0x32, 0x2e, 0x43, 0x6c, 0x69, 0x65, 0x6e, 0x74, 0x53, 0x74, 0x61, 0x74, 0x75, 0x73, 0x52, 0x65,
506 0x71, 0x75, 0x65, 0x73, 0x74, 0x22, 0x9a, 0x05, 0x0a, 0x0c, 0x50, 0x65, 0x72, 0x58, 0x64, 0x73,
507 0x43, 0x6f, 0x6e, 0x66, 0x69, 0x67, 0x12, 0x54, 0x0a, 0x06, 0x73, 0x74, 0x61, 0x74, 0x75, 0x73,
508 0x18, 0x01, 0x20, 0x01, 0x28, 0x0e, 0x32, 0x25, 0x2e, 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x2e, 0x73,
509 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x2e, 0x73, 0x74, 0x61, 0x74, 0x75, 0x73, 0x2e, 0x76, 0x33,
510 0x2e, 0x43, 0x6f, 0x6e, 0x66, 0x69, 0x67, 0x53, 0x74, 0x61, 0x74, 0x75, 0x73, 0x42, 0x15, 0xf2,
511 0x98, 0xfe, 0x8f, 0x05, 0x0f, 0x12, 0x0d, 0x73, 0x74, 0x61, 0x74, 0x75, 0x73, 0x5f, 0x63, 0x6f,
512 0x6e, 0x66, 0x69, 0x67, 0x52, 0x06, 0x73, 0x74, 0x61, 0x74, 0x75, 0x73, 0x12, 0x67, 0x0a, 0x0d,
513 0x63, 0x6c, 0x69, 0x65, 0x6e, 0x74, 0x5f, 0x73, 0x74, 0x61, 0x74, 0x75, 0x73, 0x18, 0x07, 0x20,
514 0x01, 0x28, 0x0e, 0x32, 0x2b, 0x2e, 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x2e, 0x73, 0x65, 0x72, 0x76,
515 0x69, 0x63, 0x65, 0x2e, 0x73, 0x74, 0x61, 0x74, 0x75, 0x73, 0x2e, 0x76, 0x33, 0x2e, 0x43, 0x6c,
516 0x69, 0x65, 0x6e, 0x74, 0x43, 0x6f, 0x6e, 0x66, 0x69, 0x67, 0x53, 0x74, 0x61, 0x74, 0x75, 0x73,
517 0x42, 0x15, 0xf2, 0x98, 0xfe, 0x8f, 0x05, 0x0f, 0x12, 0x0d, 0x73, 0x74, 0x61, 0x74, 0x75, 0x73,
518 0x5f, 0x63, 0x6f, 0x6e, 0x66, 0x69, 0x67, 0x52, 0x0c, 0x63, 0x6c, 0x69, 0x65, 0x6e, 0x74, 0x53,
519 0x74, 0x61, 0x74, 0x75, 0x73, 0x12, 0x4e, 0x0a, 0x0f, 0x6c, 0x69, 0x73, 0x74, 0x65, 0x6e, 0x65,
520 0x72, 0x5f, 0x63, 0x6f, 0x6e, 0x66, 0x69, 0x67, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x23,
521 0x2e, 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x2e, 0x61, 0x64, 0x6d, 0x69, 0x6e, 0x2e, 0x76, 0x33, 0x2e,
522 0x4c, 0x69, 0x73, 0x74, 0x65, 0x6e, 0x65, 0x72, 0x73, 0x43, 0x6f, 0x6e, 0x66, 0x69, 0x67, 0x44,
523 0x75, 0x6d, 0x70, 0x48, 0x00, 0x52, 0x0e, 0x6c, 0x69, 0x73, 0x74, 0x65, 0x6e, 0x65, 0x72, 0x43,
524 0x6f, 0x6e, 0x66, 0x69, 0x67, 0x12, 0x4b, 0x0a, 0x0e, 0x63, 0x6c, 0x75, 0x73, 0x74, 0x65, 0x72,
525 0x5f, 0x63, 0x6f, 0x6e, 0x66, 0x69, 0x67, 0x18, 0x03, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x22, 0x2e,
526 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x2e, 0x61, 0x64, 0x6d, 0x69, 0x6e, 0x2e, 0x76, 0x33, 0x2e, 0x43,
527 0x6c, 0x75, 0x73, 0x74, 0x65, 0x72, 0x73, 0x43, 0x6f, 0x6e, 0x66, 0x69, 0x67, 0x44, 0x75, 0x6d,
528 0x70, 0x48, 0x00, 0x52, 0x0d, 0x63, 0x6c, 0x75, 0x73, 0x74, 0x65, 0x72, 0x43, 0x6f, 0x6e, 0x66,
529 0x69, 0x67, 0x12, 0x45, 0x0a, 0x0c, 0x72, 0x6f, 0x75, 0x74, 0x65, 0x5f, 0x63, 0x6f, 0x6e, 0x66,
530 0x69, 0x67, 0x18, 0x04, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x20, 0x2e, 0x65, 0x6e, 0x76, 0x6f, 0x79,
531 0x2e, 0x61, 0x64, 0x6d, 0x69, 0x6e, 0x2e, 0x76, 0x33, 0x2e, 0x52, 0x6f, 0x75, 0x74, 0x65, 0x73,
532 0x43, 0x6f, 0x6e, 0x66, 0x69, 0x67, 0x44, 0x75, 0x6d, 0x70, 0x48, 0x00, 0x52, 0x0b, 0x72, 0x6f,
533 0x75, 0x74, 0x65, 0x43, 0x6f, 0x6e, 0x66, 0x69, 0x67, 0x12, 0x58, 0x0a, 0x13, 0x73, 0x63, 0x6f,
534 0x70, 0x65, 0x64, 0x5f, 0x72, 0x6f, 0x75, 0x74, 0x65, 0x5f, 0x63, 0x6f, 0x6e, 0x66, 0x69, 0x67,
535 0x18, 0x05, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x26, 0x2e, 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x2e, 0x61,
536 0x64, 0x6d, 0x69, 0x6e, 0x2e, 0x76, 0x33, 0x2e, 0x53, 0x63, 0x6f, 0x70, 0x65, 0x64, 0x52, 0x6f,
537 0x75, 0x74, 0x65, 0x73, 0x43, 0x6f, 0x6e, 0x66, 0x69, 0x67, 0x44, 0x75, 0x6d, 0x70, 0x48, 0x00,
538 0x52, 0x11, 0x73, 0x63, 0x6f, 0x70, 0x65, 0x64, 0x52, 0x6f, 0x75, 0x74, 0x65, 0x43, 0x6f, 0x6e,
539 0x66, 0x69, 0x67, 0x12, 0x4e, 0x0a, 0x0f, 0x65, 0x6e, 0x64, 0x70, 0x6f, 0x69, 0x6e, 0x74, 0x5f,
540 0x63, 0x6f, 0x6e, 0x66, 0x69, 0x67, 0x18, 0x06, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x23, 0x2e, 0x65,
541 0x6e, 0x76, 0x6f, 0x79, 0x2e, 0x61, 0x64, 0x6d, 0x69, 0x6e, 0x2e, 0x76, 0x33, 0x2e, 0x45, 0x6e,
542 0x64, 0x70, 0x6f, 0x69, 0x6e, 0x74, 0x73, 0x43, 0x6f, 0x6e, 0x66, 0x69, 0x67, 0x44, 0x75, 0x6d,
543 0x70, 0x48, 0x00, 0x52, 0x0e, 0x65, 0x6e, 0x64, 0x70, 0x6f, 0x69, 0x6e, 0x74, 0x43, 0x6f, 0x6e,
544 0x66, 0x69, 0x67, 0x3a, 0x2b, 0x9a, 0xc5, 0x88, 0x1e, 0x26, 0x0a, 0x24, 0x65, 0x6e, 0x76, 0x6f,
545 0x79, 0x2e, 0x73, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x2e, 0x73, 0x74, 0x61, 0x74, 0x75, 0x73,
546 0x2e, 0x76, 0x32, 0x2e, 0x50, 0x65, 0x72, 0x58, 0x64, 0x73, 0x43, 0x6f, 0x6e, 0x66, 0x69, 0x67,
547 0x42, 0x10, 0x0a, 0x0e, 0x70, 0x65, 0x72, 0x5f, 0x78, 0x64, 0x73, 0x5f, 0x63, 0x6f, 0x6e, 0x66,
548 0x69, 0x67, 0x22, 0xb1, 0x01, 0x0a, 0x0c, 0x43, 0x6c, 0x69, 0x65, 0x6e, 0x74, 0x43, 0x6f, 0x6e,
549 0x66, 0x69, 0x67, 0x12, 0x2e, 0x0a, 0x04, 0x6e, 0x6f, 0x64, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28,
550 0x0b, 0x32, 0x1a, 0x2e, 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x2e, 0x63, 0x6f, 0x6e, 0x66, 0x69, 0x67,
551 0x2e, 0x63, 0x6f, 0x72, 0x65, 0x2e, 0x76, 0x33, 0x2e, 0x4e, 0x6f, 0x64, 0x65, 0x52, 0x04, 0x6e,
552 0x6f, 0x64, 0x65, 0x12, 0x44, 0x0a, 0x0a, 0x78, 0x64, 0x73, 0x5f, 0x63, 0x6f, 0x6e, 0x66, 0x69,
553 0x67, 0x18, 0x02, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x25, 0x2e, 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x2e,
554 0x73, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x2e, 0x73, 0x74, 0x61, 0x74, 0x75, 0x73, 0x2e, 0x76,
555 0x33, 0x2e, 0x50, 0x65, 0x72, 0x58, 0x64, 0x73, 0x43, 0x6f, 0x6e, 0x66, 0x69, 0x67, 0x52, 0x09,
556 0x78, 0x64, 0x73, 0x43, 0x6f, 0x6e, 0x66, 0x69, 0x67, 0x3a, 0x2b, 0x9a, 0xc5, 0x88, 0x1e, 0x26,
557 0x0a, 0x24, 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x2e, 0x73, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x2e,
558 0x73, 0x74, 0x61, 0x74, 0x75, 0x73, 0x2e, 0x76, 0x32, 0x2e, 0x43, 0x6c, 0x69, 0x65, 0x6e, 0x74,
559 0x43, 0x6f, 0x6e, 0x66, 0x69, 0x67, 0x22, 0x8a, 0x01, 0x0a, 0x14, 0x43, 0x6c, 0x69, 0x65, 0x6e,
560 0x74, 0x53, 0x74, 0x61, 0x74, 0x75, 0x73, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12,
561 0x3d, 0x0a, 0x06, 0x63, 0x6f, 0x6e, 0x66, 0x69, 0x67, 0x18, 0x01, 0x20, 0x03, 0x28, 0x0b, 0x32,
562 0x25, 0x2e, 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x2e, 0x73, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x2e,
563 0x73, 0x74, 0x61, 0x74, 0x75, 0x73, 0x2e, 0x76, 0x33, 0x2e, 0x43, 0x6c, 0x69, 0x65, 0x6e, 0x74,
564 0x43, 0x6f, 0x6e, 0x66, 0x69, 0x67, 0x52, 0x06, 0x63, 0x6f, 0x6e, 0x66, 0x69, 0x67, 0x3a, 0x33,
565 0x9a, 0xc5, 0x88, 0x1e, 0x2e, 0x0a, 0x2c, 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x2e, 0x73, 0x65, 0x72,
566 0x76, 0x69, 0x63, 0x65, 0x2e, 0x73, 0x74, 0x61, 0x74, 0x75, 0x73, 0x2e, 0x76, 0x32, 0x2e, 0x43,
567 0x6c, 0x69, 0x65, 0x6e, 0x74, 0x53, 0x74, 0x61, 0x74, 0x75, 0x73, 0x52, 0x65, 0x73, 0x70, 0x6f,
568 0x6e, 0x73, 0x65, 0x2a, 0x4b, 0x0a, 0x0c, 0x43, 0x6f, 0x6e, 0x66, 0x69, 0x67, 0x53, 0x74, 0x61,
569 0x74, 0x75, 0x73, 0x12, 0x0b, 0x0a, 0x07, 0x55, 0x4e, 0x4b, 0x4e, 0x4f, 0x57, 0x4e, 0x10, 0x00,
570 0x12, 0x0a, 0x0a, 0x06, 0x53, 0x59, 0x4e, 0x43, 0x45, 0x44, 0x10, 0x01, 0x12, 0x0c, 0x0a, 0x08,
571 0x4e, 0x4f, 0x54, 0x5f, 0x53, 0x45, 0x4e, 0x54, 0x10, 0x02, 0x12, 0x09, 0x0a, 0x05, 0x53, 0x54,
572 0x41, 0x4c, 0x45, 0x10, 0x03, 0x12, 0x09, 0x0a, 0x05, 0x45, 0x52, 0x52, 0x4f, 0x52, 0x10, 0x04,
573 0x2a, 0x63, 0x0a, 0x12, 0x43, 0x6c, 0x69, 0x65, 0x6e, 0x74, 0x43, 0x6f, 0x6e, 0x66, 0x69, 0x67,
574 0x53, 0x74, 0x61, 0x74, 0x75, 0x73, 0x12, 0x12, 0x0a, 0x0e, 0x43, 0x4c, 0x49, 0x45, 0x4e, 0x54,
575 0x5f, 0x55, 0x4e, 0x4b, 0x4e, 0x4f, 0x57, 0x4e, 0x10, 0x00, 0x12, 0x14, 0x0a, 0x10, 0x43, 0x4c,
576 0x49, 0x45, 0x4e, 0x54, 0x5f, 0x52, 0x45, 0x51, 0x55, 0x45, 0x53, 0x54, 0x45, 0x44, 0x10, 0x01,
577 0x12, 0x10, 0x0a, 0x0c, 0x43, 0x4c, 0x49, 0x45, 0x4e, 0x54, 0x5f, 0x41, 0x43, 0x4b, 0x45, 0x44,
578 0x10, 0x02, 0x12, 0x11, 0x0a, 0x0d, 0x43, 0x4c, 0x49, 0x45, 0x4e, 0x54, 0x5f, 0x4e, 0x41, 0x43,
579 0x4b, 0x45, 0x44, 0x10, 0x03, 0x32, 0xb8, 0x02, 0x0a, 0x1c, 0x43, 0x6c, 0x69, 0x65, 0x6e, 0x74,
580 0x53, 0x74, 0x61, 0x74, 0x75, 0x73, 0x44, 0x69, 0x73, 0x63, 0x6f, 0x76, 0x65, 0x72, 0x79, 0x53,
581 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x12, 0x77, 0x0a, 0x12, 0x53, 0x74, 0x72, 0x65, 0x61, 0x6d,
582 0x43, 0x6c, 0x69, 0x65, 0x6e, 0x74, 0x53, 0x74, 0x61, 0x74, 0x75, 0x73, 0x12, 0x2c, 0x2e, 0x65,
583 0x6e, 0x76, 0x6f, 0x79, 0x2e, 0x73, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x2e, 0x73, 0x74, 0x61,
584 0x74, 0x75, 0x73, 0x2e, 0x76, 0x33, 0x2e, 0x43, 0x6c, 0x69, 0x65, 0x6e, 0x74, 0x53, 0x74, 0x61,
585 0x74, 0x75, 0x73, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x2d, 0x2e, 0x65, 0x6e, 0x76,
586 0x6f, 0x79, 0x2e, 0x73, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x2e, 0x73, 0x74, 0x61, 0x74, 0x75,
587 0x73, 0x2e, 0x76, 0x33, 0x2e, 0x43, 0x6c, 0x69, 0x65, 0x6e, 0x74, 0x53, 0x74, 0x61, 0x74, 0x75,
588 0x73, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x00, 0x28, 0x01, 0x30, 0x01, 0x12,
589 0x9e, 0x01, 0x0a, 0x11, 0x46, 0x65, 0x74, 0x63, 0x68, 0x43, 0x6c, 0x69, 0x65, 0x6e, 0x74, 0x53,
590 0x74, 0x61, 0x74, 0x75, 0x73, 0x12, 0x2c, 0x2e, 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x2e, 0x73, 0x65,
591 0x72, 0x76, 0x69, 0x63, 0x65, 0x2e, 0x73, 0x74, 0x61, 0x74, 0x75, 0x73, 0x2e, 0x76, 0x33, 0x2e,
592 0x43, 0x6c, 0x69, 0x65, 0x6e, 0x74, 0x53, 0x74, 0x61, 0x74, 0x75, 0x73, 0x52, 0x65, 0x71, 0x75,
593 0x65, 0x73, 0x74, 0x1a, 0x2d, 0x2e, 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x2e, 0x73, 0x65, 0x72, 0x76,
594 0x69, 0x63, 0x65, 0x2e, 0x73, 0x74, 0x61, 0x74, 0x75, 0x73, 0x2e, 0x76, 0x33, 0x2e, 0x43, 0x6c,
595 0x69, 0x65, 0x6e, 0x74, 0x53, 0x74, 0x61, 0x74, 0x75, 0x73, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e,
596 0x73, 0x65, 0x22, 0x2c, 0x82, 0xd3, 0xe4, 0x93, 0x02, 0x1d, 0x22, 0x1b, 0x2f, 0x76, 0x33, 0x2f,
597 0x64, 0x69, 0x73, 0x63, 0x6f, 0x76, 0x65, 0x72, 0x79, 0x3a, 0x63, 0x6c, 0x69, 0x65, 0x6e, 0x74,
598 0x5f, 0x73, 0x74, 0x61, 0x74, 0x75, 0x73, 0x82, 0xd3, 0xe4, 0x93, 0x02, 0x03, 0x3a, 0x01, 0x2a,
599 0x42, 0x3f, 0x0a, 0x25, 0x69, 0x6f, 0x2e, 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x70, 0x72, 0x6f, 0x78,
600 0x79, 0x2e, 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x2e, 0x73, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x2e,
601 0x73, 0x74, 0x61, 0x74, 0x75, 0x73, 0x2e, 0x76, 0x33, 0x42, 0x09, 0x43, 0x73, 0x64, 0x73, 0x50,
602 0x72, 0x6f, 0x74, 0x6f, 0x50, 0x01, 0x88, 0x01, 0x01, 0xba, 0x80, 0xc8, 0xd1, 0x06, 0x02, 0x10,
603 0x02, 0x62, 0x06, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x33,
604 }
605
606 var (
607 file_envoy_service_status_v3_csds_proto_rawDescOnce sync.Once
608 file_envoy_service_status_v3_csds_proto_rawDescData = file_envoy_service_status_v3_csds_proto_rawDesc
609 )
610
611 func file_envoy_service_status_v3_csds_proto_rawDescGZIP() []byte {
612 file_envoy_service_status_v3_csds_proto_rawDescOnce.Do(func() {
613 file_envoy_service_status_v3_csds_proto_rawDescData = protoimpl.X.CompressGZIP(file_envoy_service_status_v3_csds_proto_rawDescData)
614 })
615 return file_envoy_service_status_v3_csds_proto_rawDescData
616 }
617
618 var file_envoy_service_status_v3_csds_proto_enumTypes = make([]protoimpl.EnumInfo, 2)
619 var file_envoy_service_status_v3_csds_proto_msgTypes = make([]protoimpl.MessageInfo, 4)
620 var file_envoy_service_status_v3_csds_proto_goTypes = []interface{}{
621 (ConfigStatus)(0),
622 (ClientConfigStatus)(0),
623 (*ClientStatusRequest)(nil),
624 (*PerXdsConfig)(nil),
625 (*ClientConfig)(nil),
626 (*ClientStatusResponse)(nil),
627 (*v3.NodeMatcher)(nil),
628 (*v31.Node)(nil),
629 (*v32.ListenersConfigDump)(nil),
630 (*v32.ClustersConfigDump)(nil),
631 (*v32.RoutesConfigDump)(nil),
632 (*v32.ScopedRoutesConfigDump)(nil),
633 (*v32.EndpointsConfigDump)(nil),
634 }
635 var file_envoy_service_status_v3_csds_proto_depIdxs = []int32{
636 6,
637 7,
638 0,
639 1,
640 8,
641 9,
642 10,
643 11,
644 12,
645 7,
646 3,
647 4,
648 2,
649 2,
650 5,
651 5,
652 14,
653 12,
654 12,
655 12,
656 0,
657 }
658
659 func init() { file_envoy_service_status_v3_csds_proto_init() }
660 func file_envoy_service_status_v3_csds_proto_init() {
661 if File_envoy_service_status_v3_csds_proto != nil {
662 return
663 }
664 if !protoimpl.UnsafeEnabled {
665 file_envoy_service_status_v3_csds_proto_msgTypes[0].Exporter = func(v interface{}, i int) interface{} {
666 switch v := v.(*ClientStatusRequest); i {
667 case 0:
668 return &v.state
669 case 1:
670 return &v.sizeCache
671 case 2:
672 return &v.unknownFields
673 default:
674 return nil
675 }
676 }
677 file_envoy_service_status_v3_csds_proto_msgTypes[1].Exporter = func(v interface{}, i int) interface{} {
678 switch v := v.(*PerXdsConfig); i {
679 case 0:
680 return &v.state
681 case 1:
682 return &v.sizeCache
683 case 2:
684 return &v.unknownFields
685 default:
686 return nil
687 }
688 }
689 file_envoy_service_status_v3_csds_proto_msgTypes[2].Exporter = func(v interface{}, i int) interface{} {
690 switch v := v.(*ClientConfig); i {
691 case 0:
692 return &v.state
693 case 1:
694 return &v.sizeCache
695 case 2:
696 return &v.unknownFields
697 default:
698 return nil
699 }
700 }
701 file_envoy_service_status_v3_csds_proto_msgTypes[3].Exporter = func(v interface{}, i int) interface{} {
702 switch v := v.(*ClientStatusResponse); i {
703 case 0:
704 return &v.state
705 case 1:
706 return &v.sizeCache
707 case 2:
708 return &v.unknownFields
709 default:
710 return nil
711 }
712 }
713 }
714 file_envoy_service_status_v3_csds_proto_msgTypes[1].OneofWrappers = []interface{}{
715 (*PerXdsConfig_ListenerConfig)(nil),
716 (*PerXdsConfig_ClusterConfig)(nil),
717 (*PerXdsConfig_RouteConfig)(nil),
718 (*PerXdsConfig_ScopedRouteConfig)(nil),
719 (*PerXdsConfig_EndpointConfig)(nil),
720 }
721 type x struct{}
722 out := protoimpl.TypeBuilder{
723 File: protoimpl.DescBuilder{
724 GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
725 RawDescriptor: file_envoy_service_status_v3_csds_proto_rawDesc,
726 NumEnums: 2,
727 NumMessages: 4,
728 NumExtensions: 0,
729 NumServices: 1,
730 },
731 GoTypes: file_envoy_service_status_v3_csds_proto_goTypes,
732 DependencyIndexes: file_envoy_service_status_v3_csds_proto_depIdxs,
733 EnumInfos: file_envoy_service_status_v3_csds_proto_enumTypes,
734 MessageInfos: file_envoy_service_status_v3_csds_proto_msgTypes,
735 }.Build()
736 File_envoy_service_status_v3_csds_proto = out.File
737 file_envoy_service_status_v3_csds_proto_rawDesc = nil
738 file_envoy_service_status_v3_csds_proto_goTypes = nil
739 file_envoy_service_status_v3_csds_proto_depIdxs = nil
740 }
741
742
743 var _ context.Context
744 var _ grpc.ClientConnInterface
745
746
747
748 const _ = grpc.SupportPackageIsVersion6
749
750
751
752
753 type ClientStatusDiscoveryServiceClient interface {
754 StreamClientStatus(ctx context.Context, opts ...grpc.CallOption) (ClientStatusDiscoveryService_StreamClientStatusClient, error)
755 FetchClientStatus(ctx context.Context, in *ClientStatusRequest, opts ...grpc.CallOption) (*ClientStatusResponse, error)
756 }
757
758 type clientStatusDiscoveryServiceClient struct {
759 cc grpc.ClientConnInterface
760 }
761
762 func NewClientStatusDiscoveryServiceClient(cc grpc.ClientConnInterface) ClientStatusDiscoveryServiceClient {
763 return &clientStatusDiscoveryServiceClient{cc}
764 }
765
766 func (c *clientStatusDiscoveryServiceClient) StreamClientStatus(ctx context.Context, opts ...grpc.CallOption) (ClientStatusDiscoveryService_StreamClientStatusClient, error) {
767 stream, err := c.cc.NewStream(ctx, &_ClientStatusDiscoveryService_serviceDesc.Streams[0], "/envoy.service.status.v3.ClientStatusDiscoveryService/StreamClientStatus", opts...)
768 if err != nil {
769 return nil, err
770 }
771 x := &clientStatusDiscoveryServiceStreamClientStatusClient{stream}
772 return x, nil
773 }
774
775 type ClientStatusDiscoveryService_StreamClientStatusClient interface {
776 Send(*ClientStatusRequest) error
777 Recv() (*ClientStatusResponse, error)
778 grpc.ClientStream
779 }
780
781 type clientStatusDiscoveryServiceStreamClientStatusClient struct {
782 grpc.ClientStream
783 }
784
785 func (x *clientStatusDiscoveryServiceStreamClientStatusClient) Send(m *ClientStatusRequest) error {
786 return x.ClientStream.SendMsg(m)
787 }
788
789 func (x *clientStatusDiscoveryServiceStreamClientStatusClient) Recv() (*ClientStatusResponse, error) {
790 m := new(ClientStatusResponse)
791 if err := x.ClientStream.RecvMsg(m); err != nil {
792 return nil, err
793 }
794 return m, nil
795 }
796
797 func (c *clientStatusDiscoveryServiceClient) FetchClientStatus(ctx context.Context, in *ClientStatusRequest, opts ...grpc.CallOption) (*ClientStatusResponse, error) {
798 out := new(ClientStatusResponse)
799 err := c.cc.Invoke(ctx, "/envoy.service.status.v3.ClientStatusDiscoveryService/FetchClientStatus", in, out, opts...)
800 if err != nil {
801 return nil, err
802 }
803 return out, nil
804 }
805
806
807 type ClientStatusDiscoveryServiceServer interface {
808 StreamClientStatus(ClientStatusDiscoveryService_StreamClientStatusServer) error
809 FetchClientStatus(context.Context, *ClientStatusRequest) (*ClientStatusResponse, error)
810 }
811
812
813 type UnimplementedClientStatusDiscoveryServiceServer struct {
814 }
815
816 func (*UnimplementedClientStatusDiscoveryServiceServer) StreamClientStatus(ClientStatusDiscoveryService_StreamClientStatusServer) error {
817 return status.Errorf(codes.Unimplemented, "method StreamClientStatus not implemented")
818 }
819 func (*UnimplementedClientStatusDiscoveryServiceServer) FetchClientStatus(context.Context, *ClientStatusRequest) (*ClientStatusResponse, error) {
820 return nil, status.Errorf(codes.Unimplemented, "method FetchClientStatus not implemented")
821 }
822
823 func RegisterClientStatusDiscoveryServiceServer(s *grpc.Server, srv ClientStatusDiscoveryServiceServer) {
824 s.RegisterService(&_ClientStatusDiscoveryService_serviceDesc, srv)
825 }
826
827 func _ClientStatusDiscoveryService_StreamClientStatus_Handler(srv interface{}, stream grpc.ServerStream) error {
828 return srv.(ClientStatusDiscoveryServiceServer).StreamClientStatus(&clientStatusDiscoveryServiceStreamClientStatusServer{stream})
829 }
830
831 type ClientStatusDiscoveryService_StreamClientStatusServer interface {
832 Send(*ClientStatusResponse) error
833 Recv() (*ClientStatusRequest, error)
834 grpc.ServerStream
835 }
836
837 type clientStatusDiscoveryServiceStreamClientStatusServer struct {
838 grpc.ServerStream
839 }
840
841 func (x *clientStatusDiscoveryServiceStreamClientStatusServer) Send(m *ClientStatusResponse) error {
842 return x.ServerStream.SendMsg(m)
843 }
844
845 func (x *clientStatusDiscoveryServiceStreamClientStatusServer) Recv() (*ClientStatusRequest, error) {
846 m := new(ClientStatusRequest)
847 if err := x.ServerStream.RecvMsg(m); err != nil {
848 return nil, err
849 }
850 return m, nil
851 }
852
853 func _ClientStatusDiscoveryService_FetchClientStatus_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
854 in := new(ClientStatusRequest)
855 if err := dec(in); err != nil {
856 return nil, err
857 }
858 if interceptor == nil {
859 return srv.(ClientStatusDiscoveryServiceServer).FetchClientStatus(ctx, in)
860 }
861 info := &grpc.UnaryServerInfo{
862 Server: srv,
863 FullMethod: "/envoy.service.status.v3.ClientStatusDiscoveryService/FetchClientStatus",
864 }
865 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
866 return srv.(ClientStatusDiscoveryServiceServer).FetchClientStatus(ctx, req.(*ClientStatusRequest))
867 }
868 return interceptor(ctx, in, info, handler)
869 }
870
871 var _ClientStatusDiscoveryService_serviceDesc = grpc.ServiceDesc{
872 ServiceName: "envoy.service.status.v3.ClientStatusDiscoveryService",
873 HandlerType: (*ClientStatusDiscoveryServiceServer)(nil),
874 Methods: []grpc.MethodDesc{
875 {
876 MethodName: "FetchClientStatus",
877 Handler: _ClientStatusDiscoveryService_FetchClientStatus_Handler,
878 },
879 },
880 Streams: []grpc.StreamDesc{
881 {
882 StreamName: "StreamClientStatus",
883 Handler: _ClientStatusDiscoveryService_StreamClientStatus_Handler,
884 ServerStreams: true,
885 ClientStreams: true,
886 },
887 },
888 Metadata: "envoy/service/status/v3/csds.proto",
889 }
890
View as plain text