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