1// Code generated by protoc-gen-go. DO NOT EDIT. 2// versions: 3// protoc-gen-go v1.25.0 4// protoc v3.19.1 5// source: envoy/service/discovery/v2/ads.proto 6 7package envoy_service_discovery_v2 8 9import ( 10 context "context" 11 _ "github.com/cncf/xds/go/udpa/annotations" 12 v2 "github.com/envoyproxy/go-control-plane/envoy/api/v2" 13 proto "github.com/golang/protobuf/proto" 14 grpc "google.golang.org/grpc" 15 codes "google.golang.org/grpc/codes" 16 status "google.golang.org/grpc/status" 17 protoreflect "google.golang.org/protobuf/reflect/protoreflect" 18 protoimpl "google.golang.org/protobuf/runtime/protoimpl" 19 reflect "reflect" 20 sync "sync" 21) 22 23const ( 24 // Verify that this generated code is sufficiently up-to-date. 25 _ = protoimpl.EnforceVersion(20 - protoimpl.MinVersion) 26 // Verify that runtime/protoimpl is sufficiently up-to-date. 27 _ = protoimpl.EnforceVersion(protoimpl.MaxVersion - 20) 28) 29 30// This is a compile-time assertion that a sufficiently up-to-date version 31// of the legacy proto package is being used. 32const _ = proto.ProtoPackageIsVersion4 33 34// [#not-implemented-hide:] Not configuration. Workaround c++ protobuf issue with importing 35// services: https://github.com/google/protobuf/issues/4221 36type AdsDummy struct { 37 state protoimpl.MessageState 38 sizeCache protoimpl.SizeCache 39 unknownFields protoimpl.UnknownFields 40} 41 42func (x *AdsDummy) Reset() { 43 *x = AdsDummy{} 44 if protoimpl.UnsafeEnabled { 45 mi := &file_envoy_service_discovery_v2_ads_proto_msgTypes[0] 46 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 47 ms.StoreMessageInfo(mi) 48 } 49} 50 51func (x *AdsDummy) String() string { 52 return protoimpl.X.MessageStringOf(x) 53} 54 55func (*AdsDummy) ProtoMessage() {} 56 57func (x *AdsDummy) ProtoReflect() protoreflect.Message { 58 mi := &file_envoy_service_discovery_v2_ads_proto_msgTypes[0] 59 if protoimpl.UnsafeEnabled && x != nil { 60 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 61 if ms.LoadMessageInfo() == nil { 62 ms.StoreMessageInfo(mi) 63 } 64 return ms 65 } 66 return mi.MessageOf(x) 67} 68 69// Deprecated: Use AdsDummy.ProtoReflect.Descriptor instead. 70func (*AdsDummy) Descriptor() ([]byte, []int) { 71 return file_envoy_service_discovery_v2_ads_proto_rawDescGZIP(), []int{0} 72} 73 74var File_envoy_service_discovery_v2_ads_proto protoreflect.FileDescriptor 75 76var file_envoy_service_discovery_v2_ads_proto_rawDesc = []byte{ 77 0x0a, 0x24, 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x2f, 0x73, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x2f, 78 0x64, 0x69, 0x73, 0x63, 0x6f, 0x76, 0x65, 0x72, 0x79, 0x2f, 0x76, 0x32, 0x2f, 0x61, 0x64, 0x73, 79 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x12, 0x1a, 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x2e, 0x73, 0x65, 80 0x72, 0x76, 0x69, 0x63, 0x65, 0x2e, 0x64, 0x69, 0x73, 0x63, 0x6f, 0x76, 0x65, 0x72, 0x79, 0x2e, 81 0x76, 0x32, 0x1a, 0x1c, 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x2f, 0x61, 0x70, 0x69, 0x2f, 0x76, 0x32, 82 0x2f, 0x64, 0x69, 0x73, 0x63, 0x6f, 0x76, 0x65, 0x72, 0x79, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 83 0x1a, 0x1d, 0x75, 0x64, 0x70, 0x61, 0x2f, 0x61, 0x6e, 0x6e, 0x6f, 0x74, 0x61, 0x74, 0x69, 0x6f, 84 0x6e, 0x73, 0x2f, 0x73, 0x74, 0x61, 0x74, 0x75, 0x73, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x22, 85 0x0a, 0x0a, 0x08, 0x41, 0x64, 0x73, 0x44, 0x75, 0x6d, 0x6d, 0x79, 0x32, 0xed, 0x01, 0x0a, 0x1a, 86 0x41, 0x67, 0x67, 0x72, 0x65, 0x67, 0x61, 0x74, 0x65, 0x64, 0x44, 0x69, 0x73, 0x63, 0x6f, 0x76, 87 0x65, 0x72, 0x79, 0x53, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x12, 0x62, 0x0a, 0x19, 0x53, 0x74, 88 0x72, 0x65, 0x61, 0x6d, 0x41, 0x67, 0x67, 0x72, 0x65, 0x67, 0x61, 0x74, 0x65, 0x64, 0x52, 0x65, 89 0x73, 0x6f, 0x75, 0x72, 0x63, 0x65, 0x73, 0x12, 0x1e, 0x2e, 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x2e, 90 0x61, 0x70, 0x69, 0x2e, 0x76, 0x32, 0x2e, 0x44, 0x69, 0x73, 0x63, 0x6f, 0x76, 0x65, 0x72, 0x79, 91 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x1f, 0x2e, 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x2e, 92 0x61, 0x70, 0x69, 0x2e, 0x76, 0x32, 0x2e, 0x44, 0x69, 0x73, 0x63, 0x6f, 0x76, 0x65, 0x72, 0x79, 93 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x00, 0x28, 0x01, 0x30, 0x01, 0x12, 0x6b, 94 0x0a, 0x18, 0x44, 0x65, 0x6c, 0x74, 0x61, 0x41, 0x67, 0x67, 0x72, 0x65, 0x67, 0x61, 0x74, 0x65, 95 0x64, 0x52, 0x65, 0x73, 0x6f, 0x75, 0x72, 0x63, 0x65, 0x73, 0x12, 0x23, 0x2e, 0x65, 0x6e, 0x76, 96 0x6f, 0x79, 0x2e, 0x61, 0x70, 0x69, 0x2e, 0x76, 0x32, 0x2e, 0x44, 0x65, 0x6c, 0x74, 0x61, 0x44, 97 0x69, 0x73, 0x63, 0x6f, 0x76, 0x65, 0x72, 0x79, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 98 0x24, 0x2e, 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x2e, 0x61, 0x70, 0x69, 0x2e, 0x76, 0x32, 0x2e, 0x44, 99 0x65, 0x6c, 0x74, 0x61, 0x44, 0x69, 0x73, 0x63, 0x6f, 0x76, 0x65, 0x72, 0x79, 0x52, 0x65, 0x73, 100 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x00, 0x28, 0x01, 0x30, 0x01, 0x42, 0x41, 0x0a, 0x28, 0x69, 101 0x6f, 0x2e, 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x70, 0x72, 0x6f, 0x78, 0x79, 0x2e, 0x65, 0x6e, 0x76, 102 0x6f, 0x79, 0x2e, 0x73, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x2e, 0x64, 0x69, 0x73, 0x63, 0x6f, 103 0x76, 0x65, 0x72, 0x79, 0x2e, 0x76, 0x32, 0x42, 0x08, 0x41, 0x64, 0x73, 0x50, 0x72, 0x6f, 0x74, 104 0x6f, 0x50, 0x01, 0x88, 0x01, 0x01, 0xba, 0x80, 0xc8, 0xd1, 0x06, 0x02, 0x10, 0x01, 0x62, 0x06, 105 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x33, 106} 107 108var ( 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 113func 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 120var file_envoy_service_discovery_v2_ads_proto_msgTypes = make([]protoimpl.MessageInfo, 1) 121var file_envoy_service_discovery_v2_ads_proto_goTypes = []interface{}{ 122 (*AdsDummy)(nil), // 0: envoy.service.discovery.v2.AdsDummy 123 (*v2.DiscoveryRequest)(nil), // 1: envoy.api.v2.DiscoveryRequest 124 (*v2.DeltaDiscoveryRequest)(nil), // 2: envoy.api.v2.DeltaDiscoveryRequest 125 (*v2.DiscoveryResponse)(nil), // 3: envoy.api.v2.DiscoveryResponse 126 (*v2.DeltaDiscoveryResponse)(nil), // 4: envoy.api.v2.DeltaDiscoveryResponse 127} 128var file_envoy_service_discovery_v2_ads_proto_depIdxs = []int32{ 129 1, // 0: envoy.service.discovery.v2.AggregatedDiscoveryService.StreamAggregatedResources:input_type -> envoy.api.v2.DiscoveryRequest 130 2, // 1: envoy.service.discovery.v2.AggregatedDiscoveryService.DeltaAggregatedResources:input_type -> envoy.api.v2.DeltaDiscoveryRequest 131 3, // 2: envoy.service.discovery.v2.AggregatedDiscoveryService.StreamAggregatedResources:output_type -> envoy.api.v2.DiscoveryResponse 132 4, // 3: envoy.service.discovery.v2.AggregatedDiscoveryService.DeltaAggregatedResources:output_type -> envoy.api.v2.DeltaDiscoveryResponse 133 2, // [2:4] is the sub-list for method output_type 134 0, // [0:2] is the sub-list for method input_type 135 0, // [0:0] is the sub-list for extension type_name 136 0, // [0:0] is the sub-list for extension extendee 137 0, // [0:0] is the sub-list for field type_name 138} 139 140func init() { file_envoy_service_discovery_v2_ads_proto_init() } 141func 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// Reference imports to suppress errors if they are not otherwise used. 180var _ context.Context 181var _ grpc.ClientConnInterface 182 183// This is a compile-time assertion to ensure that this generated file 184// is compatible with the grpc package it is being compiled against. 185const _ = grpc.SupportPackageIsVersion6 186 187// AggregatedDiscoveryServiceClient is the client API for AggregatedDiscoveryService service. 188// 189// For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream. 190type AggregatedDiscoveryServiceClient interface { 191 // This is a gRPC-only API. 192 StreamAggregatedResources(ctx context.Context, opts ...grpc.CallOption) (AggregatedDiscoveryService_StreamAggregatedResourcesClient, error) 193 DeltaAggregatedResources(ctx context.Context, opts ...grpc.CallOption) (AggregatedDiscoveryService_DeltaAggregatedResourcesClient, error) 194} 195 196type aggregatedDiscoveryServiceClient struct { 197 cc grpc.ClientConnInterface 198} 199 200func NewAggregatedDiscoveryServiceClient(cc grpc.ClientConnInterface) AggregatedDiscoveryServiceClient { 201 return &aggregatedDiscoveryServiceClient{cc} 202} 203 204func (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 213type AggregatedDiscoveryService_StreamAggregatedResourcesClient interface { 214 Send(*v2.DiscoveryRequest) error 215 Recv() (*v2.DiscoveryResponse, error) 216 grpc.ClientStream 217} 218 219type aggregatedDiscoveryServiceStreamAggregatedResourcesClient struct { 220 grpc.ClientStream 221} 222 223func (x *aggregatedDiscoveryServiceStreamAggregatedResourcesClient) Send(m *v2.DiscoveryRequest) error { 224 return x.ClientStream.SendMsg(m) 225} 226 227func (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 235func (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 244type AggregatedDiscoveryService_DeltaAggregatedResourcesClient interface { 245 Send(*v2.DeltaDiscoveryRequest) error 246 Recv() (*v2.DeltaDiscoveryResponse, error) 247 grpc.ClientStream 248} 249 250type aggregatedDiscoveryServiceDeltaAggregatedResourcesClient struct { 251 grpc.ClientStream 252} 253 254func (x *aggregatedDiscoveryServiceDeltaAggregatedResourcesClient) Send(m *v2.DeltaDiscoveryRequest) error { 255 return x.ClientStream.SendMsg(m) 256} 257 258func (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// AggregatedDiscoveryServiceServer is the server API for AggregatedDiscoveryService service. 267type AggregatedDiscoveryServiceServer interface { 268 // This is a gRPC-only API. 269 StreamAggregatedResources(AggregatedDiscoveryService_StreamAggregatedResourcesServer) error 270 DeltaAggregatedResources(AggregatedDiscoveryService_DeltaAggregatedResourcesServer) error 271} 272 273// UnimplementedAggregatedDiscoveryServiceServer can be embedded to have forward compatible implementations. 274type UnimplementedAggregatedDiscoveryServiceServer struct { 275} 276 277func (*UnimplementedAggregatedDiscoveryServiceServer) StreamAggregatedResources(AggregatedDiscoveryService_StreamAggregatedResourcesServer) error { 278 return status.Errorf(codes.Unimplemented, "method StreamAggregatedResources not implemented") 279} 280func (*UnimplementedAggregatedDiscoveryServiceServer) DeltaAggregatedResources(AggregatedDiscoveryService_DeltaAggregatedResourcesServer) error { 281 return status.Errorf(codes.Unimplemented, "method DeltaAggregatedResources not implemented") 282} 283 284func RegisterAggregatedDiscoveryServiceServer(s *grpc.Server, srv AggregatedDiscoveryServiceServer) { 285 s.RegisterService(&_AggregatedDiscoveryService_serviceDesc, srv) 286} 287 288func _AggregatedDiscoveryService_StreamAggregatedResources_Handler(srv interface{}, stream grpc.ServerStream) error { 289 return srv.(AggregatedDiscoveryServiceServer).StreamAggregatedResources(&aggregatedDiscoveryServiceStreamAggregatedResourcesServer{stream}) 290} 291 292type AggregatedDiscoveryService_StreamAggregatedResourcesServer interface { 293 Send(*v2.DiscoveryResponse) error 294 Recv() (*v2.DiscoveryRequest, error) 295 grpc.ServerStream 296} 297 298type aggregatedDiscoveryServiceStreamAggregatedResourcesServer struct { 299 grpc.ServerStream 300} 301 302func (x *aggregatedDiscoveryServiceStreamAggregatedResourcesServer) Send(m *v2.DiscoveryResponse) error { 303 return x.ServerStream.SendMsg(m) 304} 305 306func (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 314func _AggregatedDiscoveryService_DeltaAggregatedResources_Handler(srv interface{}, stream grpc.ServerStream) error { 315 return srv.(AggregatedDiscoveryServiceServer).DeltaAggregatedResources(&aggregatedDiscoveryServiceDeltaAggregatedResourcesServer{stream}) 316} 317 318type AggregatedDiscoveryService_DeltaAggregatedResourcesServer interface { 319 Send(*v2.DeltaDiscoveryResponse) error 320 Recv() (*v2.DeltaDiscoveryRequest, error) 321 grpc.ServerStream 322} 323 324type aggregatedDiscoveryServiceDeltaAggregatedResourcesServer struct { 325 grpc.ServerStream 326} 327 328func (x *aggregatedDiscoveryServiceDeltaAggregatedResourcesServer) Send(m *v2.DeltaDiscoveryResponse) error { 329 return x.ServerStream.SendMsg(m) 330} 331 332func (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 340var _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