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/api/v2/lds.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 LdsDummy struct { 38 state protoimpl.MessageState 39 sizeCache protoimpl.SizeCache 40 unknownFields protoimpl.UnknownFields 41} 42 43func (x *LdsDummy) Reset() { 44 *x = LdsDummy{} 45 if protoimpl.UnsafeEnabled { 46 mi := &file_envoy_api_v2_lds_proto_msgTypes[0] 47 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 48 ms.StoreMessageInfo(mi) 49 } 50} 51 52func (x *LdsDummy) String() string { 53 return protoimpl.X.MessageStringOf(x) 54} 55 56func (*LdsDummy) ProtoMessage() {} 57 58func (x *LdsDummy) ProtoReflect() protoreflect.Message { 59 mi := &file_envoy_api_v2_lds_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 LdsDummy.ProtoReflect.Descriptor instead. 71func (*LdsDummy) Descriptor() ([]byte, []int) { 72 return file_envoy_api_v2_lds_proto_rawDescGZIP(), []int{0} 73} 74 75var File_envoy_api_v2_lds_proto protoreflect.FileDescriptor 76 77var file_envoy_api_v2_lds_proto_rawDesc = []byte{ 78 0x0a, 0x16, 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x2f, 0x61, 0x70, 0x69, 0x2f, 0x76, 0x32, 0x2f, 0x6c, 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, 0x1b, 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x2f, 0x61, 0x70, 0x69, 0x2f, 0x76, 91 0x32, 0x2f, 0x6c, 0x69, 0x73, 0x74, 0x65, 0x6e, 0x65, 0x72, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 92 0x22, 0x0a, 0x0a, 0x08, 0x4c, 0x64, 0x73, 0x44, 0x75, 0x6d, 0x6d, 0x79, 0x32, 0xf3, 0x02, 0x0a, 93 0x18, 0x4c, 0x69, 0x73, 0x74, 0x65, 0x6e, 0x65, 0x72, 0x44, 0x69, 0x73, 0x63, 0x6f, 0x76, 0x65, 94 0x72, 0x79, 0x53, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x12, 0x61, 0x0a, 0x0e, 0x44, 0x65, 0x6c, 95 0x74, 0x61, 0x4c, 0x69, 0x73, 0x74, 0x65, 0x6e, 0x65, 0x72, 0x73, 0x12, 0x23, 0x2e, 0x65, 0x6e, 96 0x76, 0x6f, 0x79, 0x2e, 0x61, 0x70, 0x69, 0x2e, 0x76, 0x32, 0x2e, 0x44, 0x65, 0x6c, 0x74, 0x61, 97 0x44, 0x69, 0x73, 0x63, 0x6f, 0x76, 0x65, 0x72, 0x79, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 98 0x1a, 0x24, 0x2e, 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x2e, 0x61, 0x70, 0x69, 0x2e, 0x76, 0x32, 0x2e, 99 0x44, 0x65, 0x6c, 0x74, 0x61, 0x44, 0x69, 0x73, 0x63, 0x6f, 0x76, 0x65, 0x72, 0x79, 0x52, 0x65, 100 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x00, 0x28, 0x01, 0x30, 0x01, 0x12, 0x58, 0x0a, 0x0f, 101 0x53, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x4c, 0x69, 0x73, 0x74, 0x65, 0x6e, 0x65, 0x72, 0x73, 0x12, 102 0x1e, 0x2e, 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x2e, 0x61, 0x70, 0x69, 0x2e, 0x76, 0x32, 0x2e, 0x44, 103 0x69, 0x73, 0x63, 0x6f, 0x76, 0x65, 0x72, 0x79, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 104 0x1f, 0x2e, 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x2e, 0x61, 0x70, 0x69, 0x2e, 0x76, 0x32, 0x2e, 0x44, 105 0x69, 0x73, 0x63, 0x6f, 0x76, 0x65, 0x72, 0x79, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 106 0x22, 0x00, 0x28, 0x01, 0x30, 0x01, 0x12, 0x7b, 0x0a, 0x0e, 0x46, 0x65, 0x74, 0x63, 0x68, 0x4c, 107 0x69, 0x73, 0x74, 0x65, 0x6e, 0x65, 0x72, 0x73, 0x12, 0x1e, 0x2e, 0x65, 0x6e, 0x76, 0x6f, 0x79, 108 0x2e, 0x61, 0x70, 0x69, 0x2e, 0x76, 0x32, 0x2e, 0x44, 0x69, 0x73, 0x63, 0x6f, 0x76, 0x65, 0x72, 109 0x79, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x1f, 0x2e, 0x65, 0x6e, 0x76, 0x6f, 0x79, 110 0x2e, 0x61, 0x70, 0x69, 0x2e, 0x76, 0x32, 0x2e, 0x44, 0x69, 0x73, 0x63, 0x6f, 0x76, 0x65, 0x72, 111 0x79, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x28, 0x82, 0xd3, 0xe4, 0x93, 0x02, 112 0x19, 0x22, 0x17, 0x2f, 0x76, 0x32, 0x2f, 0x64, 0x69, 0x73, 0x63, 0x6f, 0x76, 0x65, 0x72, 0x79, 113 0x3a, 0x6c, 0x69, 0x73, 0x74, 0x65, 0x6e, 0x65, 0x72, 0x73, 0x82, 0xd3, 0xe4, 0x93, 0x02, 0x03, 114 0x3a, 0x01, 0x2a, 0x1a, 0x1d, 0x8a, 0xa4, 0x96, 0xf3, 0x07, 0x17, 0x0a, 0x15, 0x65, 0x6e, 0x76, 115 0x6f, 0x79, 0x2e, 0x61, 0x70, 0x69, 0x2e, 0x76, 0x32, 0x2e, 0x4c, 0x69, 0x73, 0x74, 0x65, 0x6e, 116 0x65, 0x72, 0x42, 0x54, 0x0a, 0x1a, 0x69, 0x6f, 0x2e, 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x70, 0x72, 117 0x6f, 0x78, 0x79, 0x2e, 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x2e, 0x61, 0x70, 0x69, 0x2e, 0x76, 0x32, 118 0x42, 0x08, 0x4c, 0x64, 0x73, 0x50, 0x72, 0x6f, 0x74, 0x6f, 0x50, 0x01, 0x88, 0x01, 0x01, 0xf2, 119 0x98, 0xfe, 0x8f, 0x05, 0x1b, 0x12, 0x19, 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x2e, 0x73, 0x65, 0x72, 120 0x76, 0x69, 0x63, 0x65, 0x2e, 0x6c, 0x69, 0x73, 0x74, 0x65, 0x6e, 0x65, 0x72, 0x2e, 0x76, 0x33, 121 0xba, 0x80, 0xc8, 0xd1, 0x06, 0x02, 0x10, 0x01, 0x50, 0x05, 0x62, 0x06, 0x70, 0x72, 0x6f, 0x74, 122 0x6f, 0x33, 123} 124 125var ( 126 file_envoy_api_v2_lds_proto_rawDescOnce sync.Once 127 file_envoy_api_v2_lds_proto_rawDescData = file_envoy_api_v2_lds_proto_rawDesc 128) 129 130func file_envoy_api_v2_lds_proto_rawDescGZIP() []byte { 131 file_envoy_api_v2_lds_proto_rawDescOnce.Do(func() { 132 file_envoy_api_v2_lds_proto_rawDescData = protoimpl.X.CompressGZIP(file_envoy_api_v2_lds_proto_rawDescData) 133 }) 134 return file_envoy_api_v2_lds_proto_rawDescData 135} 136 137var file_envoy_api_v2_lds_proto_msgTypes = make([]protoimpl.MessageInfo, 1) 138var file_envoy_api_v2_lds_proto_goTypes = []interface{}{ 139 (*LdsDummy)(nil), // 0: envoy.api.v2.LdsDummy 140 (*DeltaDiscoveryRequest)(nil), // 1: envoy.api.v2.DeltaDiscoveryRequest 141 (*DiscoveryRequest)(nil), // 2: envoy.api.v2.DiscoveryRequest 142 (*DeltaDiscoveryResponse)(nil), // 3: envoy.api.v2.DeltaDiscoveryResponse 143 (*DiscoveryResponse)(nil), // 4: envoy.api.v2.DiscoveryResponse 144} 145var file_envoy_api_v2_lds_proto_depIdxs = []int32{ 146 1, // 0: envoy.api.v2.ListenerDiscoveryService.DeltaListeners:input_type -> envoy.api.v2.DeltaDiscoveryRequest 147 2, // 1: envoy.api.v2.ListenerDiscoveryService.StreamListeners:input_type -> envoy.api.v2.DiscoveryRequest 148 2, // 2: envoy.api.v2.ListenerDiscoveryService.FetchListeners:input_type -> envoy.api.v2.DiscoveryRequest 149 3, // 3: envoy.api.v2.ListenerDiscoveryService.DeltaListeners:output_type -> envoy.api.v2.DeltaDiscoveryResponse 150 4, // 4: envoy.api.v2.ListenerDiscoveryService.StreamListeners:output_type -> envoy.api.v2.DiscoveryResponse 151 4, // 5: envoy.api.v2.ListenerDiscoveryService.FetchListeners:output_type -> envoy.api.v2.DiscoveryResponse 152 3, // [3:6] is the sub-list for method output_type 153 0, // [0:3] is the sub-list for method input_type 154 0, // [0:0] is the sub-list for extension type_name 155 0, // [0:0] is the sub-list for extension extendee 156 0, // [0:0] is the sub-list for field type_name 157} 158 159func init() { file_envoy_api_v2_lds_proto_init() } 160func file_envoy_api_v2_lds_proto_init() { 161 if File_envoy_api_v2_lds_proto != nil { 162 return 163 } 164 file_envoy_api_v2_discovery_proto_init() 165 file_envoy_api_v2_listener_proto_init() 166 if !protoimpl.UnsafeEnabled { 167 file_envoy_api_v2_lds_proto_msgTypes[0].Exporter = func(v interface{}, i int) interface{} { 168 switch v := v.(*LdsDummy); i { 169 case 0: 170 return &v.state 171 case 1: 172 return &v.sizeCache 173 case 2: 174 return &v.unknownFields 175 default: 176 return nil 177 } 178 } 179 } 180 type x struct{} 181 out := protoimpl.TypeBuilder{ 182 File: protoimpl.DescBuilder{ 183 GoPackagePath: reflect.TypeOf(x{}).PkgPath(), 184 RawDescriptor: file_envoy_api_v2_lds_proto_rawDesc, 185 NumEnums: 0, 186 NumMessages: 1, 187 NumExtensions: 0, 188 NumServices: 1, 189 }, 190 GoTypes: file_envoy_api_v2_lds_proto_goTypes, 191 DependencyIndexes: file_envoy_api_v2_lds_proto_depIdxs, 192 MessageInfos: file_envoy_api_v2_lds_proto_msgTypes, 193 }.Build() 194 File_envoy_api_v2_lds_proto = out.File 195 file_envoy_api_v2_lds_proto_rawDesc = nil 196 file_envoy_api_v2_lds_proto_goTypes = nil 197 file_envoy_api_v2_lds_proto_depIdxs = nil 198} 199 200// Reference imports to suppress errors if they are not otherwise used. 201var _ context.Context 202var _ grpc.ClientConnInterface 203 204// This is a compile-time assertion to ensure that this generated file 205// is compatible with the grpc package it is being compiled against. 206const _ = grpc.SupportPackageIsVersion6 207 208// ListenerDiscoveryServiceClient is the client API for ListenerDiscoveryService service. 209// 210// For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream. 211type ListenerDiscoveryServiceClient interface { 212 DeltaListeners(ctx context.Context, opts ...grpc.CallOption) (ListenerDiscoveryService_DeltaListenersClient, error) 213 StreamListeners(ctx context.Context, opts ...grpc.CallOption) (ListenerDiscoveryService_StreamListenersClient, error) 214 FetchListeners(ctx context.Context, in *DiscoveryRequest, opts ...grpc.CallOption) (*DiscoveryResponse, error) 215} 216 217type listenerDiscoveryServiceClient struct { 218 cc grpc.ClientConnInterface 219} 220 221func NewListenerDiscoveryServiceClient(cc grpc.ClientConnInterface) ListenerDiscoveryServiceClient { 222 return &listenerDiscoveryServiceClient{cc} 223} 224 225func (c *listenerDiscoveryServiceClient) DeltaListeners(ctx context.Context, opts ...grpc.CallOption) (ListenerDiscoveryService_DeltaListenersClient, error) { 226 stream, err := c.cc.NewStream(ctx, &_ListenerDiscoveryService_serviceDesc.Streams[0], "/envoy.api.v2.ListenerDiscoveryService/DeltaListeners", opts...) 227 if err != nil { 228 return nil, err 229 } 230 x := &listenerDiscoveryServiceDeltaListenersClient{stream} 231 return x, nil 232} 233 234type ListenerDiscoveryService_DeltaListenersClient interface { 235 Send(*DeltaDiscoveryRequest) error 236 Recv() (*DeltaDiscoveryResponse, error) 237 grpc.ClientStream 238} 239 240type listenerDiscoveryServiceDeltaListenersClient struct { 241 grpc.ClientStream 242} 243 244func (x *listenerDiscoveryServiceDeltaListenersClient) Send(m *DeltaDiscoveryRequest) error { 245 return x.ClientStream.SendMsg(m) 246} 247 248func (x *listenerDiscoveryServiceDeltaListenersClient) Recv() (*DeltaDiscoveryResponse, error) { 249 m := new(DeltaDiscoveryResponse) 250 if err := x.ClientStream.RecvMsg(m); err != nil { 251 return nil, err 252 } 253 return m, nil 254} 255 256func (c *listenerDiscoveryServiceClient) StreamListeners(ctx context.Context, opts ...grpc.CallOption) (ListenerDiscoveryService_StreamListenersClient, error) { 257 stream, err := c.cc.NewStream(ctx, &_ListenerDiscoveryService_serviceDesc.Streams[1], "/envoy.api.v2.ListenerDiscoveryService/StreamListeners", opts...) 258 if err != nil { 259 return nil, err 260 } 261 x := &listenerDiscoveryServiceStreamListenersClient{stream} 262 return x, nil 263} 264 265type ListenerDiscoveryService_StreamListenersClient interface { 266 Send(*DiscoveryRequest) error 267 Recv() (*DiscoveryResponse, error) 268 grpc.ClientStream 269} 270 271type listenerDiscoveryServiceStreamListenersClient struct { 272 grpc.ClientStream 273} 274 275func (x *listenerDiscoveryServiceStreamListenersClient) Send(m *DiscoveryRequest) error { 276 return x.ClientStream.SendMsg(m) 277} 278 279func (x *listenerDiscoveryServiceStreamListenersClient) Recv() (*DiscoveryResponse, error) { 280 m := new(DiscoveryResponse) 281 if err := x.ClientStream.RecvMsg(m); err != nil { 282 return nil, err 283 } 284 return m, nil 285} 286 287func (c *listenerDiscoveryServiceClient) FetchListeners(ctx context.Context, in *DiscoveryRequest, opts ...grpc.CallOption) (*DiscoveryResponse, error) { 288 out := new(DiscoveryResponse) 289 err := c.cc.Invoke(ctx, "/envoy.api.v2.ListenerDiscoveryService/FetchListeners", in, out, opts...) 290 if err != nil { 291 return nil, err 292 } 293 return out, nil 294} 295 296// ListenerDiscoveryServiceServer is the server API for ListenerDiscoveryService service. 297type ListenerDiscoveryServiceServer interface { 298 DeltaListeners(ListenerDiscoveryService_DeltaListenersServer) error 299 StreamListeners(ListenerDiscoveryService_StreamListenersServer) error 300 FetchListeners(context.Context, *DiscoveryRequest) (*DiscoveryResponse, error) 301} 302 303// UnimplementedListenerDiscoveryServiceServer can be embedded to have forward compatible implementations. 304type UnimplementedListenerDiscoveryServiceServer struct { 305} 306 307func (*UnimplementedListenerDiscoveryServiceServer) DeltaListeners(ListenerDiscoveryService_DeltaListenersServer) error { 308 return status.Errorf(codes.Unimplemented, "method DeltaListeners not implemented") 309} 310func (*UnimplementedListenerDiscoveryServiceServer) StreamListeners(ListenerDiscoveryService_StreamListenersServer) error { 311 return status.Errorf(codes.Unimplemented, "method StreamListeners not implemented") 312} 313func (*UnimplementedListenerDiscoveryServiceServer) FetchListeners(context.Context, *DiscoveryRequest) (*DiscoveryResponse, error) { 314 return nil, status.Errorf(codes.Unimplemented, "method FetchListeners not implemented") 315} 316 317func RegisterListenerDiscoveryServiceServer(s *grpc.Server, srv ListenerDiscoveryServiceServer) { 318 s.RegisterService(&_ListenerDiscoveryService_serviceDesc, srv) 319} 320 321func _ListenerDiscoveryService_DeltaListeners_Handler(srv interface{}, stream grpc.ServerStream) error { 322 return srv.(ListenerDiscoveryServiceServer).DeltaListeners(&listenerDiscoveryServiceDeltaListenersServer{stream}) 323} 324 325type ListenerDiscoveryService_DeltaListenersServer interface { 326 Send(*DeltaDiscoveryResponse) error 327 Recv() (*DeltaDiscoveryRequest, error) 328 grpc.ServerStream 329} 330 331type listenerDiscoveryServiceDeltaListenersServer struct { 332 grpc.ServerStream 333} 334 335func (x *listenerDiscoveryServiceDeltaListenersServer) Send(m *DeltaDiscoveryResponse) error { 336 return x.ServerStream.SendMsg(m) 337} 338 339func (x *listenerDiscoveryServiceDeltaListenersServer) Recv() (*DeltaDiscoveryRequest, error) { 340 m := new(DeltaDiscoveryRequest) 341 if err := x.ServerStream.RecvMsg(m); err != nil { 342 return nil, err 343 } 344 return m, nil 345} 346 347func _ListenerDiscoveryService_StreamListeners_Handler(srv interface{}, stream grpc.ServerStream) error { 348 return srv.(ListenerDiscoveryServiceServer).StreamListeners(&listenerDiscoveryServiceStreamListenersServer{stream}) 349} 350 351type ListenerDiscoveryService_StreamListenersServer interface { 352 Send(*DiscoveryResponse) error 353 Recv() (*DiscoveryRequest, error) 354 grpc.ServerStream 355} 356 357type listenerDiscoveryServiceStreamListenersServer struct { 358 grpc.ServerStream 359} 360 361func (x *listenerDiscoveryServiceStreamListenersServer) Send(m *DiscoveryResponse) error { 362 return x.ServerStream.SendMsg(m) 363} 364 365func (x *listenerDiscoveryServiceStreamListenersServer) Recv() (*DiscoveryRequest, error) { 366 m := new(DiscoveryRequest) 367 if err := x.ServerStream.RecvMsg(m); err != nil { 368 return nil, err 369 } 370 return m, nil 371} 372 373func _ListenerDiscoveryService_FetchListeners_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 374 in := new(DiscoveryRequest) 375 if err := dec(in); err != nil { 376 return nil, err 377 } 378 if interceptor == nil { 379 return srv.(ListenerDiscoveryServiceServer).FetchListeners(ctx, in) 380 } 381 info := &grpc.UnaryServerInfo{ 382 Server: srv, 383 FullMethod: "/envoy.api.v2.ListenerDiscoveryService/FetchListeners", 384 } 385 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 386 return srv.(ListenerDiscoveryServiceServer).FetchListeners(ctx, req.(*DiscoveryRequest)) 387 } 388 return interceptor(ctx, in, info, handler) 389} 390 391var _ListenerDiscoveryService_serviceDesc = grpc.ServiceDesc{ 392 ServiceName: "envoy.api.v2.ListenerDiscoveryService", 393 HandlerType: (*ListenerDiscoveryServiceServer)(nil), 394 Methods: []grpc.MethodDesc{ 395 { 396 MethodName: "FetchListeners", 397 Handler: _ListenerDiscoveryService_FetchListeners_Handler, 398 }, 399 }, 400 Streams: []grpc.StreamDesc{ 401 { 402 StreamName: "DeltaListeners", 403 Handler: _ListenerDiscoveryService_DeltaListeners_Handler, 404 ServerStreams: true, 405 ClientStreams: true, 406 }, 407 { 408 StreamName: "StreamListeners", 409 Handler: _ListenerDiscoveryService_StreamListeners_Handler, 410 ServerStreams: true, 411 ClientStreams: true, 412 }, 413 }, 414 Metadata: "envoy/api/v2/lds.proto", 415} 416