discoverer

Documentation

Index

• Variables
• func RegisterDiscovererServer(s grpc.ServiceRegistrar, srv DiscovererServer)
• type DiscovererClient
  • func NewDiscovererClient(cc grpc.ClientConnInterface) 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

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

func (UnimplementedDiscovererServer) Services(
	context.Context, *payload.Discoverer_Request,
) (*payload.Info_Services, error)

type UnsafeDiscovererServer

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.