Documentation
¶
Index ¶
- Variables
- func RegisterDiscovererServer(s grpc.ServiceRegistrar, srv DiscovererServer)
- type DiscovererClient
- type DiscovererServer
- type UnimplementedDiscovererServer
- func (UnimplementedDiscovererServer) Nodes(context.Context, *payload.Discoverer_Request) (*payload.Info_Nodes, error)
- func (UnimplementedDiscovererServer) Pods(context.Context, *payload.Discoverer_Request) (*payload.Info_Pods, error)
- func (UnimplementedDiscovererServer) Services(context.Context, *payload.Discoverer_Request) (*payload.Info_Services, error)
- type UnsafeDiscovererServer
Constants ¶
This section is empty.
Variables ¶
var Discoverer_ServiceDesc = grpc.ServiceDesc{ ServiceName: "discoverer.v1.Discoverer", HandlerType: (*DiscovererServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "Pods", Handler: _Discoverer_Pods_Handler, }, { MethodName: "Nodes", Handler: _Discoverer_Nodes_Handler, }, { MethodName: "Services", Handler: _Discoverer_Services_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "v1/discoverer/discoverer.proto", }
Discoverer_ServiceDesc is the grpc.ServiceDesc for Discoverer service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var File_v1_discoverer_discoverer_proto protoreflect.FileDescriptor
Functions ¶
func RegisterDiscovererServer ¶
func RegisterDiscovererServer(s grpc.ServiceRegistrar, srv DiscovererServer)
Types ¶
type DiscovererClient ¶
type DiscovererClient interface {
// Represent the RPC to get the agent pods information.
Pods(ctx context.Context, in *payload.Discoverer_Request, opts ...grpc.CallOption) (*payload.Info_Pods, error)
// Represent the RPC to get the node information.
Nodes(ctx context.Context, in *payload.Discoverer_Request, opts ...grpc.CallOption) (*payload.Info_Nodes, error)
// Represent the RPC to get the readreplica svc information.
Services(ctx context.Context, in *payload.Discoverer_Request, opts ...grpc.CallOption) (*payload.Info_Services, error)
}
DiscovererClient is the client API for Discoverer 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 NewDiscovererClient ¶
func NewDiscovererClient(cc grpc.ClientConnInterface) DiscovererClient
type DiscovererServer ¶
type DiscovererServer interface {
// Represent the RPC to get the agent pods information.
Pods(context.Context, *payload.Discoverer_Request) (*payload.Info_Pods, error)
// Represent the RPC to get the node information.
Nodes(context.Context, *payload.Discoverer_Request) (*payload.Info_Nodes, error)
// Represent the RPC to get the readreplica svc information.
Services(context.Context, *payload.Discoverer_Request) (*payload.Info_Services, error)
// contains filtered or unexported methods
}
DiscovererServer is the server API for Discoverer service. All implementations must embed UnimplementedDiscovererServer for forward compatibility
type UnimplementedDiscovererServer ¶
type UnimplementedDiscovererServer struct {
}
UnimplementedDiscovererServer must be embedded to have forward compatible implementations.
func (UnimplementedDiscovererServer) Nodes ¶
func (UnimplementedDiscovererServer) Nodes(context.Context, *payload.Discoverer_Request) (*payload.Info_Nodes, error)
func (UnimplementedDiscovererServer) Pods ¶
func (UnimplementedDiscovererServer) Pods(context.Context, *payload.Discoverer_Request) (*payload.Info_Pods, error)
func (UnimplementedDiscovererServer) Services ¶ added in v1.7.10
func (UnimplementedDiscovererServer) Services(context.Context, *payload.Discoverer_Request) (*payload.Info_Services, error)
type UnsafeDiscovererServer ¶ added in v1.2.1
type UnsafeDiscovererServer interface {
// contains filtered or unexported methods
}
UnsafeDiscovererServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to DiscovererServer will result in compilation errors.
Source Files