1// Code generated by protoc-gen-go. DO NOT EDIT. 2// versions: 3// protoc-gen-go v1.25.0 4// protoc v3.16.0 5// source: envoy/api/v2/cds.proto 6 7package envoy_api_v2 8 9import ( 10 context "context" 11 _ "github.com/cncf/xds/go/udpa/annotations" 12 _ "github.com/envoyproxy/go-control-plane/envoy/annotations" 13 proto "github.com/golang/protobuf/proto" 14 _ "google.golang.org/genproto/googleapis/api/annotations" 15 grpc "google.golang.org/grpc" 16 codes "google.golang.org/grpc/codes" 17 status "google.golang.org/grpc/status" 18 protoreflect "google.golang.org/protobuf/reflect/protoreflect" 19 protoimpl "google.golang.org/protobuf/runtime/protoimpl" 20 reflect "reflect" 21 sync "sync" 22) 23 24const ( 25 // Verify that this generated code is sufficiently up-to-date. 26 _ = protoimpl.EnforceVersion(20 - protoimpl.MinVersion) 27 // Verify that runtime/protoimpl is sufficiently up-to-date. 28 _ = protoimpl.EnforceVersion(protoimpl.MaxVersion - 20) 29) 30 31// This is a compile-time assertion that a sufficiently up-to-date version 32// of the legacy proto package is being used. 33const _ = proto.ProtoPackageIsVersion4 34 35// [#not-implemented-hide:] Not configuration. Workaround c++ protobuf issue with importing 36// services: https://github.com/google/protobuf/issues/4221 and protoxform to upgrade the file. 37type CdsDummy struct { 38 state protoimpl.MessageState 39 sizeCache protoimpl.SizeCache 40 unknownFields protoimpl.UnknownFields 41} 42 43func (x *CdsDummy) Reset() { 44 *x = CdsDummy{} 45 if protoimpl.UnsafeEnabled { 46 mi := &file_envoy_api_v2_cds_proto_msgTypes[0] 47 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 48 ms.StoreMessageInfo(mi) 49 } 50} 51 52func (x *CdsDummy) String() string { 53 return protoimpl.X.MessageStringOf(x) 54} 55 56func (*CdsDummy) ProtoMessage() {} 57 58func (x *CdsDummy) ProtoReflect() protoreflect.Message { 59 mi := &file_envoy_api_v2_cds_proto_msgTypes[0] 60 if protoimpl.UnsafeEnabled && x != nil { 61 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 62 if ms.LoadMessageInfo() == nil { 63 ms.StoreMessageInfo(mi) 64 } 65 return ms 66 } 67 return mi.MessageOf(x) 68} 69 70// Deprecated: Use CdsDummy.ProtoReflect.Descriptor instead. 71func (*CdsDummy) Descriptor() ([]byte, []int) { 72 return file_envoy_api_v2_cds_proto_rawDescGZIP(), []int{0} 73} 74 75var File_envoy_api_v2_cds_proto protoreflect.FileDescriptor 76 77var file_envoy_api_v2_cds_proto_rawDesc = []byte{ 78 0x0a, 0x16, 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x2f, 0x61, 0x70, 0x69, 0x2f, 0x76, 0x32, 0x2f, 0x63, 79 0x64, 0x73, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x12, 0x0c, 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x2e, 80 0x61, 0x70, 0x69, 0x2e, 0x76, 0x32, 0x1a, 0x1c, 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x2f, 0x61, 0x70, 81 0x69, 0x2f, 0x76, 0x32, 0x2f, 0x64, 0x69, 0x73, 0x63, 0x6f, 0x76, 0x65, 0x72, 0x79, 0x2e, 0x70, 82 0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x1c, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x61, 0x70, 0x69, 83 0x2f, 0x61, 0x6e, 0x6e, 0x6f, 0x74, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2e, 0x70, 0x72, 0x6f, 84 0x74, 0x6f, 0x1a, 0x20, 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x2f, 0x61, 0x6e, 0x6e, 0x6f, 0x74, 0x61, 85 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2f, 0x72, 0x65, 0x73, 0x6f, 0x75, 0x72, 0x63, 0x65, 0x2e, 0x70, 86 0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x1e, 0x75, 0x64, 0x70, 0x61, 0x2f, 0x61, 0x6e, 0x6e, 0x6f, 0x74, 87 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2f, 0x6d, 0x69, 0x67, 0x72, 0x61, 0x74, 0x65, 0x2e, 0x70, 88 0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x1d, 0x75, 0x64, 0x70, 0x61, 0x2f, 0x61, 0x6e, 0x6e, 0x6f, 0x74, 89 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2f, 0x73, 0x74, 0x61, 0x74, 0x75, 0x73, 0x2e, 0x70, 0x72, 90 0x6f, 0x74, 0x6f, 0x1a, 0x1a, 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x2f, 0x61, 0x70, 0x69, 0x2f, 0x76, 91 0x32, 0x2f, 0x63, 0x6c, 0x75, 0x73, 0x74, 0x65, 0x72, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x22, 92 0x0a, 0x0a, 0x08, 0x43, 0x64, 0x73, 0x44, 0x75, 0x6d, 0x6d, 0x79, 0x32, 0xed, 0x02, 0x0a, 0x17, 93 0x43, 0x6c, 0x75, 0x73, 0x74, 0x65, 0x72, 0x44, 0x69, 0x73, 0x63, 0x6f, 0x76, 0x65, 0x72, 0x79, 94 0x53, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x12, 0x57, 0x0a, 0x0e, 0x53, 0x74, 0x72, 0x65, 0x61, 95 0x6d, 0x43, 0x6c, 0x75, 0x73, 0x74, 0x65, 0x72, 0x73, 0x12, 0x1e, 0x2e, 0x65, 0x6e, 0x76, 0x6f, 96 0x79, 0x2e, 0x61, 0x70, 0x69, 0x2e, 0x76, 0x32, 0x2e, 0x44, 0x69, 0x73, 0x63, 0x6f, 0x76, 0x65, 97 0x72, 0x79, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x1f, 0x2e, 0x65, 0x6e, 0x76, 0x6f, 98 0x79, 0x2e, 0x61, 0x70, 0x69, 0x2e, 0x76, 0x32, 0x2e, 0x44, 0x69, 0x73, 0x63, 0x6f, 0x76, 0x65, 99 0x72, 0x79, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x00, 0x28, 0x01, 0x30, 0x01, 100 0x12, 0x60, 0x0a, 0x0d, 0x44, 0x65, 0x6c, 0x74, 0x61, 0x43, 0x6c, 0x75, 0x73, 0x74, 0x65, 0x72, 101 0x73, 0x12, 0x23, 0x2e, 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x2e, 0x61, 0x70, 0x69, 0x2e, 0x76, 0x32, 102 0x2e, 0x44, 0x65, 0x6c, 0x74, 0x61, 0x44, 0x69, 0x73, 0x63, 0x6f, 0x76, 0x65, 0x72, 0x79, 0x52, 103 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x24, 0x2e, 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x2e, 0x61, 104 0x70, 0x69, 0x2e, 0x76, 0x32, 0x2e, 0x44, 0x65, 0x6c, 0x74, 0x61, 0x44, 0x69, 0x73, 0x63, 0x6f, 105 0x76, 0x65, 0x72, 0x79, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x00, 0x28, 0x01, 106 0x30, 0x01, 0x12, 0x79, 0x0a, 0x0d, 0x46, 0x65, 0x74, 0x63, 0x68, 0x43, 0x6c, 0x75, 0x73, 0x74, 107 0x65, 0x72, 0x73, 0x12, 0x1e, 0x2e, 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x2e, 0x61, 0x70, 0x69, 0x2e, 108 0x76, 0x32, 0x2e, 0x44, 0x69, 0x73, 0x63, 0x6f, 0x76, 0x65, 0x72, 0x79, 0x52, 0x65, 0x71, 0x75, 109 0x65, 0x73, 0x74, 0x1a, 0x1f, 0x2e, 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x2e, 0x61, 0x70, 0x69, 0x2e, 110 0x76, 0x32, 0x2e, 0x44, 0x69, 0x73, 0x63, 0x6f, 0x76, 0x65, 0x72, 0x79, 0x52, 0x65, 0x73, 0x70, 111 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x27, 0x82, 0xd3, 0xe4, 0x93, 0x02, 0x18, 0x22, 0x16, 0x2f, 0x76, 112 0x32, 0x2f, 0x64, 0x69, 0x73, 0x63, 0x6f, 0x76, 0x65, 0x72, 0x79, 0x3a, 0x63, 0x6c, 0x75, 0x73, 113 0x74, 0x65, 0x72, 0x73, 0x82, 0xd3, 0xe4, 0x93, 0x02, 0x03, 0x3a, 0x01, 0x2a, 0x1a, 0x1c, 0x8a, 114 0xa4, 0x96, 0xf3, 0x07, 0x16, 0x0a, 0x14, 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x2e, 0x61, 0x70, 0x69, 115 0x2e, 0x76, 0x32, 0x2e, 0x43, 0x6c, 0x75, 0x73, 0x74, 0x65, 0x72, 0x42, 0x53, 0x0a, 0x1a, 0x69, 116 0x6f, 0x2e, 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x70, 0x72, 0x6f, 0x78, 0x79, 0x2e, 0x65, 0x6e, 0x76, 117 0x6f, 0x79, 0x2e, 0x61, 0x70, 0x69, 0x2e, 0x76, 0x32, 0x42, 0x08, 0x43, 0x64, 0x73, 0x50, 0x72, 118 0x6f, 0x74, 0x6f, 0x50, 0x01, 0x88, 0x01, 0x01, 0xf2, 0x98, 0xfe, 0x8f, 0x05, 0x1a, 0x12, 0x18, 119 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x2e, 0x73, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x2e, 0x63, 0x6c, 120 0x75, 0x73, 0x74, 0x65, 0x72, 0x2e, 0x76, 0x33, 0xba, 0x80, 0xc8, 0xd1, 0x06, 0x02, 0x10, 0x01, 121 0x50, 0x05, 0x62, 0x06, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x33, 122} 123 124var ( 125 file_envoy_api_v2_cds_proto_rawDescOnce sync.Once 126 file_envoy_api_v2_cds_proto_rawDescData = file_envoy_api_v2_cds_proto_rawDesc 127) 128 129func file_envoy_api_v2_cds_proto_rawDescGZIP() []byte { 130 file_envoy_api_v2_cds_proto_rawDescOnce.Do(func() { 131 file_envoy_api_v2_cds_proto_rawDescData = protoimpl.X.CompressGZIP(file_envoy_api_v2_cds_proto_rawDescData) 132 }) 133 return file_envoy_api_v2_cds_proto_rawDescData 134} 135 136var file_envoy_api_v2_cds_proto_msgTypes = make([]protoimpl.MessageInfo, 1) 137var file_envoy_api_v2_cds_proto_goTypes = []interface{}{ 138 (*CdsDummy)(nil), // 0: envoy.api.v2.CdsDummy 139 (*DiscoveryRequest)(nil), // 1: envoy.api.v2.DiscoveryRequest 140 (*DeltaDiscoveryRequest)(nil), // 2: envoy.api.v2.DeltaDiscoveryRequest 141 (*DiscoveryResponse)(nil), // 3: envoy.api.v2.DiscoveryResponse 142 (*DeltaDiscoveryResponse)(nil), // 4: envoy.api.v2.DeltaDiscoveryResponse 143} 144var file_envoy_api_v2_cds_proto_depIdxs = []int32{ 145 1, // 0: envoy.api.v2.ClusterDiscoveryService.StreamClusters:input_type -> envoy.api.v2.DiscoveryRequest 146 2, // 1: envoy.api.v2.ClusterDiscoveryService.DeltaClusters:input_type -> envoy.api.v2.DeltaDiscoveryRequest 147 1, // 2: envoy.api.v2.ClusterDiscoveryService.FetchClusters:input_type -> envoy.api.v2.DiscoveryRequest 148 3, // 3: envoy.api.v2.ClusterDiscoveryService.StreamClusters:output_type -> envoy.api.v2.DiscoveryResponse 149 4, // 4: envoy.api.v2.ClusterDiscoveryService.DeltaClusters:output_type -> envoy.api.v2.DeltaDiscoveryResponse 150 3, // 5: envoy.api.v2.ClusterDiscoveryService.FetchClusters:output_type -> envoy.api.v2.DiscoveryResponse 151 3, // [3:6] is the sub-list for method output_type 152 0, // [0:3] is the sub-list for method input_type 153 0, // [0:0] is the sub-list for extension type_name 154 0, // [0:0] is the sub-list for extension extendee 155 0, // [0:0] is the sub-list for field type_name 156} 157 158func init() { file_envoy_api_v2_cds_proto_init() } 159func file_envoy_api_v2_cds_proto_init() { 160 if File_envoy_api_v2_cds_proto != nil { 161 return 162 } 163 file_envoy_api_v2_discovery_proto_init() 164 file_envoy_api_v2_cluster_proto_init() 165 if !protoimpl.UnsafeEnabled { 166 file_envoy_api_v2_cds_proto_msgTypes[0].Exporter = func(v interface{}, i int) interface{} { 167 switch v := v.(*CdsDummy); i { 168 case 0: 169 return &v.state 170 case 1: 171 return &v.sizeCache 172 case 2: 173 return &v.unknownFields 174 default: 175 return nil 176 } 177 } 178 } 179 type x struct{} 180 out := protoimpl.TypeBuilder{ 181 File: protoimpl.DescBuilder{ 182 GoPackagePath: reflect.TypeOf(x{}).PkgPath(), 183 RawDescriptor: file_envoy_api_v2_cds_proto_rawDesc, 184 NumEnums: 0, 185 NumMessages: 1, 186 NumExtensions: 0, 187 NumServices: 1, 188 }, 189 GoTypes: file_envoy_api_v2_cds_proto_goTypes, 190 DependencyIndexes: file_envoy_api_v2_cds_proto_depIdxs, 191 MessageInfos: file_envoy_api_v2_cds_proto_msgTypes, 192 }.Build() 193 File_envoy_api_v2_cds_proto = out.File 194 file_envoy_api_v2_cds_proto_rawDesc = nil 195 file_envoy_api_v2_cds_proto_goTypes = nil 196 file_envoy_api_v2_cds_proto_depIdxs = nil 197} 198 199// Reference imports to suppress errors if they are not otherwise used. 200var _ context.Context 201var _ grpc.ClientConnInterface 202 203// This is a compile-time assertion to ensure that this generated file 204// is compatible with the grpc package it is being compiled against. 205const _ = grpc.SupportPackageIsVersion6 206 207// ClusterDiscoveryServiceClient is the client API for ClusterDiscoveryService service. 208// 209// For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream. 210type ClusterDiscoveryServiceClient interface { 211 StreamClusters(ctx context.Context, opts ...grpc.CallOption) (ClusterDiscoveryService_StreamClustersClient, error) 212 DeltaClusters(ctx context.Context, opts ...grpc.CallOption) (ClusterDiscoveryService_DeltaClustersClient, error) 213 FetchClusters(ctx context.Context, in *DiscoveryRequest, opts ...grpc.CallOption) (*DiscoveryResponse, error) 214} 215 216type clusterDiscoveryServiceClient struct { 217 cc grpc.ClientConnInterface 218} 219 220func NewClusterDiscoveryServiceClient(cc grpc.ClientConnInterface) ClusterDiscoveryServiceClient { 221 return &clusterDiscoveryServiceClient{cc} 222} 223 224func (c *clusterDiscoveryServiceClient) StreamClusters(ctx context.Context, opts ...grpc.CallOption) (ClusterDiscoveryService_StreamClustersClient, error) { 225 stream, err := c.cc.NewStream(ctx, &_ClusterDiscoveryService_serviceDesc.Streams[0], "/envoy.api.v2.ClusterDiscoveryService/StreamClusters", opts...) 226 if err != nil { 227 return nil, err 228 } 229 x := &clusterDiscoveryServiceStreamClustersClient{stream} 230 return x, nil 231} 232 233type ClusterDiscoveryService_StreamClustersClient interface { 234 Send(*DiscoveryRequest) error 235 Recv() (*DiscoveryResponse, error) 236 grpc.ClientStream 237} 238 239type clusterDiscoveryServiceStreamClustersClient struct { 240 grpc.ClientStream 241} 242 243func (x *clusterDiscoveryServiceStreamClustersClient) Send(m *DiscoveryRequest) error { 244 return x.ClientStream.SendMsg(m) 245} 246 247func (x *clusterDiscoveryServiceStreamClustersClient) Recv() (*DiscoveryResponse, error) { 248 m := new(DiscoveryResponse) 249 if err := x.ClientStream.RecvMsg(m); err != nil { 250 return nil, err 251 } 252 return m, nil 253} 254 255func (c *clusterDiscoveryServiceClient) DeltaClusters(ctx context.Context, opts ...grpc.CallOption) (ClusterDiscoveryService_DeltaClustersClient, error) { 256 stream, err := c.cc.NewStream(ctx, &_ClusterDiscoveryService_serviceDesc.Streams[1], "/envoy.api.v2.ClusterDiscoveryService/DeltaClusters", opts...) 257 if err != nil { 258 return nil, err 259 } 260 x := &clusterDiscoveryServiceDeltaClustersClient{stream} 261 return x, nil 262} 263 264type ClusterDiscoveryService_DeltaClustersClient interface { 265 Send(*DeltaDiscoveryRequest) error 266 Recv() (*DeltaDiscoveryResponse, error) 267 grpc.ClientStream 268} 269 270type clusterDiscoveryServiceDeltaClustersClient struct { 271 grpc.ClientStream 272} 273 274func (x *clusterDiscoveryServiceDeltaClustersClient) Send(m *DeltaDiscoveryRequest) error { 275 return x.ClientStream.SendMsg(m) 276} 277 278func (x *clusterDiscoveryServiceDeltaClustersClient) Recv() (*DeltaDiscoveryResponse, error) { 279 m := new(DeltaDiscoveryResponse) 280 if err := x.ClientStream.RecvMsg(m); err != nil { 281 return nil, err 282 } 283 return m, nil 284} 285 286func (c *clusterDiscoveryServiceClient) FetchClusters(ctx context.Context, in *DiscoveryRequest, opts ...grpc.CallOption) (*DiscoveryResponse, error) { 287 out := new(DiscoveryResponse) 288 err := c.cc.Invoke(ctx, "/envoy.api.v2.ClusterDiscoveryService/FetchClusters", in, out, opts...) 289 if err != nil { 290 return nil, err 291 } 292 return out, nil 293} 294 295// ClusterDiscoveryServiceServer is the server API for ClusterDiscoveryService service. 296type ClusterDiscoveryServiceServer interface { 297 StreamClusters(ClusterDiscoveryService_StreamClustersServer) error 298 DeltaClusters(ClusterDiscoveryService_DeltaClustersServer) error 299 FetchClusters(context.Context, *DiscoveryRequest) (*DiscoveryResponse, error) 300} 301 302// UnimplementedClusterDiscoveryServiceServer can be embedded to have forward compatible implementations. 303type UnimplementedClusterDiscoveryServiceServer struct { 304} 305 306func (*UnimplementedClusterDiscoveryServiceServer) StreamClusters(ClusterDiscoveryService_StreamClustersServer) error { 307 return status.Errorf(codes.Unimplemented, "method StreamClusters not implemented") 308} 309func (*UnimplementedClusterDiscoveryServiceServer) DeltaClusters(ClusterDiscoveryService_DeltaClustersServer) error { 310 return status.Errorf(codes.Unimplemented, "method DeltaClusters not implemented") 311} 312func (*UnimplementedClusterDiscoveryServiceServer) FetchClusters(context.Context, *DiscoveryRequest) (*DiscoveryResponse, error) { 313 return nil, status.Errorf(codes.Unimplemented, "method FetchClusters not implemented") 314} 315 316func RegisterClusterDiscoveryServiceServer(s *grpc.Server, srv ClusterDiscoveryServiceServer) { 317 s.RegisterService(&_ClusterDiscoveryService_serviceDesc, srv) 318} 319 320func _ClusterDiscoveryService_StreamClusters_Handler(srv interface{}, stream grpc.ServerStream) error { 321 return srv.(ClusterDiscoveryServiceServer).StreamClusters(&clusterDiscoveryServiceStreamClustersServer{stream}) 322} 323 324type ClusterDiscoveryService_StreamClustersServer interface { 325 Send(*DiscoveryResponse) error 326 Recv() (*DiscoveryRequest, error) 327 grpc.ServerStream 328} 329 330type clusterDiscoveryServiceStreamClustersServer struct { 331 grpc.ServerStream 332} 333 334func (x *clusterDiscoveryServiceStreamClustersServer) Send(m *DiscoveryResponse) error { 335 return x.ServerStream.SendMsg(m) 336} 337 338func (x *clusterDiscoveryServiceStreamClustersServer) Recv() (*DiscoveryRequest, error) { 339 m := new(DiscoveryRequest) 340 if err := x.ServerStream.RecvMsg(m); err != nil { 341 return nil, err 342 } 343 return m, nil 344} 345 346func _ClusterDiscoveryService_DeltaClusters_Handler(srv interface{}, stream grpc.ServerStream) error { 347 return srv.(ClusterDiscoveryServiceServer).DeltaClusters(&clusterDiscoveryServiceDeltaClustersServer{stream}) 348} 349 350type ClusterDiscoveryService_DeltaClustersServer interface { 351 Send(*DeltaDiscoveryResponse) error 352 Recv() (*DeltaDiscoveryRequest, error) 353 grpc.ServerStream 354} 355 356type clusterDiscoveryServiceDeltaClustersServer struct { 357 grpc.ServerStream 358} 359 360func (x *clusterDiscoveryServiceDeltaClustersServer) Send(m *DeltaDiscoveryResponse) error { 361 return x.ServerStream.SendMsg(m) 362} 363 364func (x *clusterDiscoveryServiceDeltaClustersServer) Recv() (*DeltaDiscoveryRequest, error) { 365 m := new(DeltaDiscoveryRequest) 366 if err := x.ServerStream.RecvMsg(m); err != nil { 367 return nil, err 368 } 369 return m, nil 370} 371 372func _ClusterDiscoveryService_FetchClusters_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 373 in := new(DiscoveryRequest) 374 if err := dec(in); err != nil { 375 return nil, err 376 } 377 if interceptor == nil { 378 return srv.(ClusterDiscoveryServiceServer).FetchClusters(ctx, in) 379 } 380 info := &grpc.UnaryServerInfo{ 381 Server: srv, 382 FullMethod: "/envoy.api.v2.ClusterDiscoveryService/FetchClusters", 383 } 384 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 385 return srv.(ClusterDiscoveryServiceServer).FetchClusters(ctx, req.(*DiscoveryRequest)) 386 } 387 return interceptor(ctx, in, info, handler) 388} 389 390var _ClusterDiscoveryService_serviceDesc = grpc.ServiceDesc{ 391 ServiceName: "envoy.api.v2.ClusterDiscoveryService", 392 HandlerType: (*ClusterDiscoveryServiceServer)(nil), 393 Methods: []grpc.MethodDesc{ 394 { 395 MethodName: "FetchClusters", 396 Handler: _ClusterDiscoveryService_FetchClusters_Handler, 397 }, 398 }, 399 Streams: []grpc.StreamDesc{ 400 { 401 StreamName: "StreamClusters", 402 Handler: _ClusterDiscoveryService_StreamClusters_Handler, 403 ServerStreams: true, 404 ClientStreams: true, 405 }, 406 { 407 StreamName: "DeltaClusters", 408 Handler: _ClusterDiscoveryService_DeltaClusters_Handler, 409 ServerStreams: true, 410 ClientStreams: true, 411 }, 412 }, 413 Metadata: "envoy/api/v2/cds.proto", 414} 415