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