Documentation ¶
Index ¶
- Constants
- Variables
- func RegisterEndpointDiscoveryServiceServer(s grpc.ServiceRegistrar, srv EndpointDiscoveryServiceServer)
- func RegisterLocalityEndpointDiscoveryServiceServer(s grpc.ServiceRegistrar, srv LocalityEndpointDiscoveryServiceServer)
- type EndpointDiscoveryServiceClient
- type EndpointDiscoveryServiceServer
- type EndpointDiscoveryService_DeltaEndpointsClient
- type EndpointDiscoveryService_DeltaEndpointsServer
- type EndpointDiscoveryService_StreamEndpointsClient
- type EndpointDiscoveryService_StreamEndpointsServer
- type LocalityEndpointDiscoveryServiceClient
- type LocalityEndpointDiscoveryServiceServer
- type LocalityEndpointDiscoveryService_DeltaLocalityEndpointsClient
- type LocalityEndpointDiscoveryService_DeltaLocalityEndpointsServer
- type UnimplementedEndpointDiscoveryServiceServer
- func (UnimplementedEndpointDiscoveryServiceServer) DeltaEndpoints(EndpointDiscoveryService_DeltaEndpointsServer) error
- func (UnimplementedEndpointDiscoveryServiceServer) FetchEndpoints(context.Context, *v3.DiscoveryRequest) (*v3.DiscoveryResponse, error)
- func (UnimplementedEndpointDiscoveryServiceServer) StreamEndpoints(EndpointDiscoveryService_StreamEndpointsServer) error
- type UnimplementedLocalityEndpointDiscoveryServiceServer
- type UnsafeEndpointDiscoveryServiceServer
- type UnsafeLocalityEndpointDiscoveryServiceServer
Constants ¶
const ( EndpointDiscoveryService_StreamEndpoints_FullMethodName = "/envoy.service.endpoint.v3.EndpointDiscoveryService/StreamEndpoints" EndpointDiscoveryService_DeltaEndpoints_FullMethodName = "/envoy.service.endpoint.v3.EndpointDiscoveryService/DeltaEndpoints" EndpointDiscoveryService_FetchEndpoints_FullMethodName = "/envoy.service.endpoint.v3.EndpointDiscoveryService/FetchEndpoints" )
const (
LocalityEndpointDiscoveryService_DeltaLocalityEndpoints_FullMethodName = "/envoy.service.endpoint.v3.LocalityEndpointDiscoveryService/DeltaLocalityEndpoints"
)
Variables ¶
var EndpointDiscoveryService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "envoy.service.endpoint.v3.EndpointDiscoveryService", HandlerType: (*EndpointDiscoveryServiceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "FetchEndpoints", Handler: _EndpointDiscoveryService_FetchEndpoints_Handler, }, }, Streams: []grpc.StreamDesc{ { StreamName: "StreamEndpoints", Handler: _EndpointDiscoveryService_StreamEndpoints_Handler, ServerStreams: true, ClientStreams: true, }, { StreamName: "DeltaEndpoints", Handler: _EndpointDiscoveryService_DeltaEndpoints_Handler, ServerStreams: true, ClientStreams: true, }, }, Metadata: "envoy/service/endpoint/v3/eds.proto", }
EndpointDiscoveryService_ServiceDesc is the grpc.ServiceDesc for EndpointDiscoveryService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var LocalityEndpointDiscoveryService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "envoy.service.endpoint.v3.LocalityEndpointDiscoveryService", HandlerType: (*LocalityEndpointDiscoveryServiceServer)(nil), Methods: []grpc.MethodDesc{}, Streams: []grpc.StreamDesc{ { StreamName: "DeltaLocalityEndpoints", Handler: _LocalityEndpointDiscoveryService_DeltaLocalityEndpoints_Handler, ServerStreams: true, ClientStreams: true, }, }, Metadata: "envoy/service/endpoint/v3/leds.proto", }
LocalityEndpointDiscoveryService_ServiceDesc is the grpc.ServiceDesc for LocalityEndpointDiscoveryService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterEndpointDiscoveryServiceServer ¶
func RegisterEndpointDiscoveryServiceServer(s grpc.ServiceRegistrar, srv EndpointDiscoveryServiceServer)
func RegisterLocalityEndpointDiscoveryServiceServer ¶
func RegisterLocalityEndpointDiscoveryServiceServer(s grpc.ServiceRegistrar, srv LocalityEndpointDiscoveryServiceServer)
Types ¶
type EndpointDiscoveryServiceClient ¶
type EndpointDiscoveryServiceClient interface { // The resource_names field in DiscoveryRequest specifies a list of clusters // to subscribe to updates for. StreamEndpoints(ctx context.Context, opts ...grpc.CallOption) (EndpointDiscoveryService_StreamEndpointsClient, error) DeltaEndpoints(ctx context.Context, opts ...grpc.CallOption) (EndpointDiscoveryService_DeltaEndpointsClient, error) FetchEndpoints(ctx context.Context, in *v3.DiscoveryRequest, opts ...grpc.CallOption) (*v3.DiscoveryResponse, error) }
EndpointDiscoveryServiceClient is the client API for EndpointDiscoveryService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewEndpointDiscoveryServiceClient ¶
func NewEndpointDiscoveryServiceClient(cc grpc.ClientConnInterface) EndpointDiscoveryServiceClient
type EndpointDiscoveryServiceServer ¶
type EndpointDiscoveryServiceServer interface { // The resource_names field in DiscoveryRequest specifies a list of clusters // to subscribe to updates for. StreamEndpoints(EndpointDiscoveryService_StreamEndpointsServer) error DeltaEndpoints(EndpointDiscoveryService_DeltaEndpointsServer) error FetchEndpoints(context.Context, *v3.DiscoveryRequest) (*v3.DiscoveryResponse, error) }
EndpointDiscoveryServiceServer is the server API for EndpointDiscoveryService service. All implementations should embed UnimplementedEndpointDiscoveryServiceServer for forward compatibility
type EndpointDiscoveryService_DeltaEndpointsClient ¶
type EndpointDiscoveryService_DeltaEndpointsClient interface { Send(*v3.DeltaDiscoveryRequest) error Recv() (*v3.DeltaDiscoveryResponse, error) grpc.ClientStream }
type EndpointDiscoveryService_DeltaEndpointsServer ¶
type EndpointDiscoveryService_DeltaEndpointsServer interface { Send(*v3.DeltaDiscoveryResponse) error Recv() (*v3.DeltaDiscoveryRequest, error) grpc.ServerStream }
type EndpointDiscoveryService_StreamEndpointsClient ¶
type EndpointDiscoveryService_StreamEndpointsClient interface { Send(*v3.DiscoveryRequest) error Recv() (*v3.DiscoveryResponse, error) grpc.ClientStream }
type EndpointDiscoveryService_StreamEndpointsServer ¶
type EndpointDiscoveryService_StreamEndpointsServer interface { Send(*v3.DiscoveryResponse) error Recv() (*v3.DiscoveryRequest, error) grpc.ServerStream }
type LocalityEndpointDiscoveryServiceClient ¶
type LocalityEndpointDiscoveryServiceClient interface { // The resource_names_subscribe resource_names_unsubscribe fields in DeltaDiscoveryRequest // specify a list of glob collections to subscribe to updates for. DeltaLocalityEndpoints(ctx context.Context, opts ...grpc.CallOption) (LocalityEndpointDiscoveryService_DeltaLocalityEndpointsClient, error) }
LocalityEndpointDiscoveryServiceClient is the client API for LocalityEndpointDiscoveryService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewLocalityEndpointDiscoveryServiceClient ¶
func NewLocalityEndpointDiscoveryServiceClient(cc grpc.ClientConnInterface) LocalityEndpointDiscoveryServiceClient
type LocalityEndpointDiscoveryServiceServer ¶
type LocalityEndpointDiscoveryServiceServer interface { // The resource_names_subscribe resource_names_unsubscribe fields in DeltaDiscoveryRequest // specify a list of glob collections to subscribe to updates for. DeltaLocalityEndpoints(LocalityEndpointDiscoveryService_DeltaLocalityEndpointsServer) error }
LocalityEndpointDiscoveryServiceServer is the server API for LocalityEndpointDiscoveryService service. All implementations should embed UnimplementedLocalityEndpointDiscoveryServiceServer for forward compatibility
type LocalityEndpointDiscoveryService_DeltaLocalityEndpointsClient ¶
type LocalityEndpointDiscoveryService_DeltaLocalityEndpointsClient interface { Send(*v3.DeltaDiscoveryRequest) error Recv() (*v3.DeltaDiscoveryResponse, error) grpc.ClientStream }
type LocalityEndpointDiscoveryService_DeltaLocalityEndpointsServer ¶
type LocalityEndpointDiscoveryService_DeltaLocalityEndpointsServer interface { Send(*v3.DeltaDiscoveryResponse) error Recv() (*v3.DeltaDiscoveryRequest, error) grpc.ServerStream }
type UnimplementedEndpointDiscoveryServiceServer ¶
type UnimplementedEndpointDiscoveryServiceServer struct { }
UnimplementedEndpointDiscoveryServiceServer should be embedded to have forward compatible implementations.
func (UnimplementedEndpointDiscoveryServiceServer) DeltaEndpoints ¶
func (UnimplementedEndpointDiscoveryServiceServer) DeltaEndpoints(EndpointDiscoveryService_DeltaEndpointsServer) error
func (UnimplementedEndpointDiscoveryServiceServer) FetchEndpoints ¶
func (UnimplementedEndpointDiscoveryServiceServer) FetchEndpoints(context.Context, *v3.DiscoveryRequest) (*v3.DiscoveryResponse, error)
func (UnimplementedEndpointDiscoveryServiceServer) StreamEndpoints ¶
func (UnimplementedEndpointDiscoveryServiceServer) StreamEndpoints(EndpointDiscoveryService_StreamEndpointsServer) error
type UnimplementedLocalityEndpointDiscoveryServiceServer ¶
type UnimplementedLocalityEndpointDiscoveryServiceServer struct { }
UnimplementedLocalityEndpointDiscoveryServiceServer should be embedded to have forward compatible implementations.
func (UnimplementedLocalityEndpointDiscoveryServiceServer) DeltaLocalityEndpoints ¶
func (UnimplementedLocalityEndpointDiscoveryServiceServer) DeltaLocalityEndpoints(LocalityEndpointDiscoveryService_DeltaLocalityEndpointsServer) error
type UnsafeEndpointDiscoveryServiceServer ¶
type UnsafeEndpointDiscoveryServiceServer interface {
// contains filtered or unexported methods
}
UnsafeEndpointDiscoveryServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to EndpointDiscoveryServiceServer will result in compilation errors.
type UnsafeLocalityEndpointDiscoveryServiceServer ¶
type UnsafeLocalityEndpointDiscoveryServiceServer interface {
// contains filtered or unexported methods
}
UnsafeLocalityEndpointDiscoveryServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to LocalityEndpointDiscoveryServiceServer will result in compilation errors.