1// Code generated by protoc-gen-go. DO NOT EDIT.
2// source: envoy/api/v2/lds.proto
3
4package envoy_api_v2
5
6import (
7	context "context"
8	fmt "fmt"
9	_ "github.com/cncf/udpa/go/udpa/annotations"
10	_ "github.com/envoyproxy/go-control-plane/envoy/annotations"
11	_ "github.com/envoyproxy/protoc-gen-validate/validate"
12	proto "github.com/golang/protobuf/proto"
13	_ "github.com/golang/protobuf/ptypes/duration"
14	_ "github.com/golang/protobuf/ptypes/wrappers"
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	math "math"
20)
21
22// Reference imports to suppress errors if they are not otherwise used.
23var _ = proto.Marshal
24var _ = fmt.Errorf
25var _ = math.Inf
26
27// This is a compile-time assertion to ensure that this generated file
28// is compatible with the proto package it is being compiled against.
29// A compilation error at this line likely means your copy of the
30// proto package needs to be updated.
31const _ = proto.ProtoPackageIsVersion3 // please upgrade the proto package
32
33type LdsDummy struct {
34	XXX_NoUnkeyedLiteral struct{} `json:"-"`
35	XXX_unrecognized     []byte   `json:"-"`
36	XXX_sizecache        int32    `json:"-"`
37}
38
39func (m *LdsDummy) Reset()         { *m = LdsDummy{} }
40func (m *LdsDummy) String() string { return proto.CompactTextString(m) }
41func (*LdsDummy) ProtoMessage()    {}
42func (*LdsDummy) Descriptor() ([]byte, []int) {
43	return fileDescriptor_34e2cd84a105bcd1, []int{0}
44}
45
46func (m *LdsDummy) XXX_Unmarshal(b []byte) error {
47	return xxx_messageInfo_LdsDummy.Unmarshal(m, b)
48}
49func (m *LdsDummy) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
50	return xxx_messageInfo_LdsDummy.Marshal(b, m, deterministic)
51}
52func (m *LdsDummy) XXX_Merge(src proto.Message) {
53	xxx_messageInfo_LdsDummy.Merge(m, src)
54}
55func (m *LdsDummy) XXX_Size() int {
56	return xxx_messageInfo_LdsDummy.Size(m)
57}
58func (m *LdsDummy) XXX_DiscardUnknown() {
59	xxx_messageInfo_LdsDummy.DiscardUnknown(m)
60}
61
62var xxx_messageInfo_LdsDummy proto.InternalMessageInfo
63
64func init() {
65	proto.RegisterType((*LdsDummy)(nil), "envoy.api.v2.LdsDummy")
66}
67
68func init() { proto.RegisterFile("envoy/api/v2/lds.proto", fileDescriptor_34e2cd84a105bcd1) }
69
70var fileDescriptor_34e2cd84a105bcd1 = []byte{
71	// 394 bytes of a gzipped FileDescriptorProto
72	0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0xac, 0x92, 0xbd, 0x4e, 0xe3, 0x40,
73	0x14, 0x85, 0xd7, 0x59, 0x6d, 0x36, 0x1a, 0xad, 0xb2, 0xc8, 0x12, 0x84, 0x38, 0x3f, 0xa0, 0x40,
74	0x11, 0x51, 0xd8, 0x28, 0xe9, 0x52, 0x46, 0x11, 0x55, 0x8a, 0x88, 0x50, 0xd0, 0x4e, 0xec, 0x4b,
75	0x18, 0xc9, 0xf6, 0x0c, 0x33, 0x63, 0x83, 0x45, 0x83, 0xa8, 0x10, 0x0d, 0x05, 0x12, 0xe2, 0x01,
76	0x78, 0x0a, 0x9e, 0x80, 0x16, 0xf1, 0x0a, 0x3c, 0x01, 0xe9, 0x11, 0x8a, 0xed, 0x49, 0x70, 0x50,
77	0xa8, 0xe8, 0x6c, 0x7f, 0xe7, 0x9e, 0x7b, 0x75, 0x8e, 0xd1, 0x1a, 0xf8, 0x21, 0x8d, 0x2c, 0xcc,
78	0x88, 0x15, 0xb6, 0x2c, 0xd7, 0x11, 0x26, 0xe3, 0x54, 0x52, 0xfd, 0x5f, 0xfc, 0xdd, 0xc4, 0x8c,
79	0x98, 0x61, 0xcb, 0xa8, 0x66, 0x54, 0x0e, 0x11, 0x36, 0x0d, 0x81, 0x47, 0x89, 0xd6, 0xa8, 0x8e,
80	0x29, 0x1d, 0xbb, 0x10, 0x63, 0xec, 0xfb, 0x54, 0x62, 0x49, 0xa8, 0x9f, 0x3a, 0x19, 0xf5, 0x94,
81	0xc6, 0x6f, 0xa3, 0xe0, 0xc8, 0x72, 0x02, 0x1e, 0x0b, 0x96, 0xf1, 0x53, 0x8e, 0x19, 0x03, 0xae,
82	0xe6, 0x37, 0xd3, 0xdd, 0x73, 0x63, 0x8b, 0x83, 0xa0, 0x01, 0xb7, 0x41, 0x39, 0x04, 0x0e, 0xc3,
83	0x19, 0x81, 0x47, 0xc6, 0x1c, 0x4b, 0xc5, 0x6b, 0x5f, 0xb8, 0x90, 0x58, 0x06, 0x6a, 0x41, 0x29,
84	0xc4, 0x2e, 0x71, 0xb0, 0x04, 0x4b, 0x3d, 0xa4, 0xa0, 0x92, 0xcd, 0x86, 0x08, 0x09, 0x3e, 0xf0,
85	0x04, 0x36, 0x10, 0x2a, 0xf4, 0x1d, 0xd1, 0x0b, 0x3c, 0x2f, 0x6a, 0x4d, 0x72, 0x68, 0xbd, 0x9f,
86	0xe2, 0x9e, 0x0a, 0x67, 0x08, 0x3c, 0x24, 0x36, 0xe8, 0x18, 0x15, 0x7b, 0xe0, 0x4a, 0xac, 0x04,
87	0x42, 0xdf, 0x32, 0x3f, 0x87, 0x6b, 0xc6, 0x74, 0x36, 0xb6, 0x0f, 0x27, 0x01, 0x08, 0x69, 0x6c,
88	0x7f, 0x2f, 0x12, 0x8c, 0xfa, 0x02, 0x1a, 0xbf, 0x9a, 0xda, 0xae, 0xa6, 0x1f, 0xa2, 0xff, 0x43,
89	0xc9, 0x01, 0x7b, 0xf3, 0x1d, 0xf5, 0x85, 0xf1, 0x45, 0xfb, 0x8d, 0xa5, 0x3c, 0xe3, 0x7c, 0x8e,
90	0x8a, 0x7b, 0x20, 0xed, 0xe3, 0x1f, 0x34, 0x6e, 0x5e, 0xbe, 0xbc, 0xde, 0xe6, 0xca, 0x8d, 0x52,
91	0xe6, 0x57, 0xea, 0xa8, 0x78, 0x45, 0x8c, 0x7f, 0x77, 0xb4, 0x1d, 0xa3, 0x76, 0xfd, 0x70, 0x37,
92	0xf9, 0x5b, 0x42, 0xab, 0x19, 0x47, 0x75, 0x4a, 0xf7, 0xe0, 0xed, 0xfe, 0xfd, 0xe6, 0x4f, 0x45,
93	0x2f, 0x27, 0x58, 0x24, 0x79, 0x9b, 0xb3, 0x9e, 0xc2, 0xf6, 0xe3, 0xc5, 0xd3, 0x73, 0x3e, 0xb7,
94	0xa2, 0x21, 0x83, 0xd0, 0xe4, 0x2c, 0xc6, 0xe9, 0x59, 0x94, 0xb9, 0xb0, 0x3b, 0xad, 0x71, 0x30,
95	0xad, 0x74, 0xa0, 0x5d, 0x69, 0xda, 0xa0, 0x30, 0xca, 0xc7, 0x05, 0xb7, 0x3f, 0x02, 0x00, 0x00,
96	0xff, 0xff, 0x34, 0x66, 0x06, 0x72, 0x1b, 0x03, 0x00, 0x00,
97}
98
99// Reference imports to suppress errors if they are not otherwise used.
100var _ context.Context
101var _ grpc.ClientConn
102
103// This is a compile-time assertion to ensure that this generated file
104// is compatible with the grpc package it is being compiled against.
105const _ = grpc.SupportPackageIsVersion4
106
107// ListenerDiscoveryServiceClient is the client API for ListenerDiscoveryService service.
108//
109// For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
110type ListenerDiscoveryServiceClient interface {
111	DeltaListeners(ctx context.Context, opts ...grpc.CallOption) (ListenerDiscoveryService_DeltaListenersClient, error)
112	StreamListeners(ctx context.Context, opts ...grpc.CallOption) (ListenerDiscoveryService_StreamListenersClient, error)
113	FetchListeners(ctx context.Context, in *DiscoveryRequest, opts ...grpc.CallOption) (*DiscoveryResponse, error)
114}
115
116type listenerDiscoveryServiceClient struct {
117	cc *grpc.ClientConn
118}
119
120func NewListenerDiscoveryServiceClient(cc *grpc.ClientConn) ListenerDiscoveryServiceClient {
121	return &listenerDiscoveryServiceClient{cc}
122}
123
124func (c *listenerDiscoveryServiceClient) DeltaListeners(ctx context.Context, opts ...grpc.CallOption) (ListenerDiscoveryService_DeltaListenersClient, error) {
125	stream, err := c.cc.NewStream(ctx, &_ListenerDiscoveryService_serviceDesc.Streams[0], "/envoy.api.v2.ListenerDiscoveryService/DeltaListeners", opts...)
126	if err != nil {
127		return nil, err
128	}
129	x := &listenerDiscoveryServiceDeltaListenersClient{stream}
130	return x, nil
131}
132
133type ListenerDiscoveryService_DeltaListenersClient interface {
134	Send(*DeltaDiscoveryRequest) error
135	Recv() (*DeltaDiscoveryResponse, error)
136	grpc.ClientStream
137}
138
139type listenerDiscoveryServiceDeltaListenersClient struct {
140	grpc.ClientStream
141}
142
143func (x *listenerDiscoveryServiceDeltaListenersClient) Send(m *DeltaDiscoveryRequest) error {
144	return x.ClientStream.SendMsg(m)
145}
146
147func (x *listenerDiscoveryServiceDeltaListenersClient) Recv() (*DeltaDiscoveryResponse, error) {
148	m := new(DeltaDiscoveryResponse)
149	if err := x.ClientStream.RecvMsg(m); err != nil {
150		return nil, err
151	}
152	return m, nil
153}
154
155func (c *listenerDiscoveryServiceClient) StreamListeners(ctx context.Context, opts ...grpc.CallOption) (ListenerDiscoveryService_StreamListenersClient, error) {
156	stream, err := c.cc.NewStream(ctx, &_ListenerDiscoveryService_serviceDesc.Streams[1], "/envoy.api.v2.ListenerDiscoveryService/StreamListeners", opts...)
157	if err != nil {
158		return nil, err
159	}
160	x := &listenerDiscoveryServiceStreamListenersClient{stream}
161	return x, nil
162}
163
164type ListenerDiscoveryService_StreamListenersClient interface {
165	Send(*DiscoveryRequest) error
166	Recv() (*DiscoveryResponse, error)
167	grpc.ClientStream
168}
169
170type listenerDiscoveryServiceStreamListenersClient struct {
171	grpc.ClientStream
172}
173
174func (x *listenerDiscoveryServiceStreamListenersClient) Send(m *DiscoveryRequest) error {
175	return x.ClientStream.SendMsg(m)
176}
177
178func (x *listenerDiscoveryServiceStreamListenersClient) Recv() (*DiscoveryResponse, error) {
179	m := new(DiscoveryResponse)
180	if err := x.ClientStream.RecvMsg(m); err != nil {
181		return nil, err
182	}
183	return m, nil
184}
185
186func (c *listenerDiscoveryServiceClient) FetchListeners(ctx context.Context, in *DiscoveryRequest, opts ...grpc.CallOption) (*DiscoveryResponse, error) {
187	out := new(DiscoveryResponse)
188	err := c.cc.Invoke(ctx, "/envoy.api.v2.ListenerDiscoveryService/FetchListeners", in, out, opts...)
189	if err != nil {
190		return nil, err
191	}
192	return out, nil
193}
194
195// ListenerDiscoveryServiceServer is the server API for ListenerDiscoveryService service.
196type ListenerDiscoveryServiceServer interface {
197	DeltaListeners(ListenerDiscoveryService_DeltaListenersServer) error
198	StreamListeners(ListenerDiscoveryService_StreamListenersServer) error
199	FetchListeners(context.Context, *DiscoveryRequest) (*DiscoveryResponse, error)
200}
201
202// UnimplementedListenerDiscoveryServiceServer can be embedded to have forward compatible implementations.
203type UnimplementedListenerDiscoveryServiceServer struct {
204}
205
206func (*UnimplementedListenerDiscoveryServiceServer) DeltaListeners(srv ListenerDiscoveryService_DeltaListenersServer) error {
207	return status.Errorf(codes.Unimplemented, "method DeltaListeners not implemented")
208}
209func (*UnimplementedListenerDiscoveryServiceServer) StreamListeners(srv ListenerDiscoveryService_StreamListenersServer) error {
210	return status.Errorf(codes.Unimplemented, "method StreamListeners not implemented")
211}
212func (*UnimplementedListenerDiscoveryServiceServer) FetchListeners(ctx context.Context, req *DiscoveryRequest) (*DiscoveryResponse, error) {
213	return nil, status.Errorf(codes.Unimplemented, "method FetchListeners not implemented")
214}
215
216func RegisterListenerDiscoveryServiceServer(s *grpc.Server, srv ListenerDiscoveryServiceServer) {
217	s.RegisterService(&_ListenerDiscoveryService_serviceDesc, srv)
218}
219
220func _ListenerDiscoveryService_DeltaListeners_Handler(srv interface{}, stream grpc.ServerStream) error {
221	return srv.(ListenerDiscoveryServiceServer).DeltaListeners(&listenerDiscoveryServiceDeltaListenersServer{stream})
222}
223
224type ListenerDiscoveryService_DeltaListenersServer interface {
225	Send(*DeltaDiscoveryResponse) error
226	Recv() (*DeltaDiscoveryRequest, error)
227	grpc.ServerStream
228}
229
230type listenerDiscoveryServiceDeltaListenersServer struct {
231	grpc.ServerStream
232}
233
234func (x *listenerDiscoveryServiceDeltaListenersServer) Send(m *DeltaDiscoveryResponse) error {
235	return x.ServerStream.SendMsg(m)
236}
237
238func (x *listenerDiscoveryServiceDeltaListenersServer) Recv() (*DeltaDiscoveryRequest, error) {
239	m := new(DeltaDiscoveryRequest)
240	if err := x.ServerStream.RecvMsg(m); err != nil {
241		return nil, err
242	}
243	return m, nil
244}
245
246func _ListenerDiscoveryService_StreamListeners_Handler(srv interface{}, stream grpc.ServerStream) error {
247	return srv.(ListenerDiscoveryServiceServer).StreamListeners(&listenerDiscoveryServiceStreamListenersServer{stream})
248}
249
250type ListenerDiscoveryService_StreamListenersServer interface {
251	Send(*DiscoveryResponse) error
252	Recv() (*DiscoveryRequest, error)
253	grpc.ServerStream
254}
255
256type listenerDiscoveryServiceStreamListenersServer struct {
257	grpc.ServerStream
258}
259
260func (x *listenerDiscoveryServiceStreamListenersServer) Send(m *DiscoveryResponse) error {
261	return x.ServerStream.SendMsg(m)
262}
263
264func (x *listenerDiscoveryServiceStreamListenersServer) Recv() (*DiscoveryRequest, error) {
265	m := new(DiscoveryRequest)
266	if err := x.ServerStream.RecvMsg(m); err != nil {
267		return nil, err
268	}
269	return m, nil
270}
271
272func _ListenerDiscoveryService_FetchListeners_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
273	in := new(DiscoveryRequest)
274	if err := dec(in); err != nil {
275		return nil, err
276	}
277	if interceptor == nil {
278		return srv.(ListenerDiscoveryServiceServer).FetchListeners(ctx, in)
279	}
280	info := &grpc.UnaryServerInfo{
281		Server:     srv,
282		FullMethod: "/envoy.api.v2.ListenerDiscoveryService/FetchListeners",
283	}
284	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
285		return srv.(ListenerDiscoveryServiceServer).FetchListeners(ctx, req.(*DiscoveryRequest))
286	}
287	return interceptor(ctx, in, info, handler)
288}
289
290var _ListenerDiscoveryService_serviceDesc = grpc.ServiceDesc{
291	ServiceName: "envoy.api.v2.ListenerDiscoveryService",
292	HandlerType: (*ListenerDiscoveryServiceServer)(nil),
293	Methods: []grpc.MethodDesc{
294		{
295			MethodName: "FetchListeners",
296			Handler:    _ListenerDiscoveryService_FetchListeners_Handler,
297		},
298	},
299	Streams: []grpc.StreamDesc{
300		{
301			StreamName:    "DeltaListeners",
302			Handler:       _ListenerDiscoveryService_DeltaListeners_Handler,
303			ServerStreams: true,
304			ClientStreams: true,
305		},
306		{
307			StreamName:    "StreamListeners",
308			Handler:       _ListenerDiscoveryService_StreamListeners_Handler,
309			ServerStreams: true,
310			ClientStreams: true,
311		},
312	},
313	Metadata: "envoy/api/v2/lds.proto",
314}
315