discoverer

Documentation

Index

• func RegisterDiscovererServer(s *grpc.Server, srv DiscovererServer)
• type DiscovererClient
  • func NewDiscovererClient(cc *grpc.ClientConn) DiscovererClient
• type DiscovererServer
• type UnimplementedDiscovererServer
  • func (*UnimplementedDiscovererServer) Nodes(ctx context.Context, req *payload.Discoverer_Request) (*payload.Info_Nodes, error)
  • func (*UnimplementedDiscovererServer) Pods(ctx context.Context, req *payload.Discoverer_Request) (*payload.Info_Pods, error)

Functions

func RegisterDiscovererServer

func RegisterDiscovererServer(s *grpc.Server, srv DiscovererServer)

Types

type DiscovererClient

type DiscovererClient interface {
	Pods(ctx context.Context, in *payload.Discoverer_Request, opts ...grpc.CallOption) (*payload.Info_Pods, error)
	Nodes(ctx context.Context, in *payload.Discoverer_Request, opts ...grpc.CallOption) (*payload.Info_Nodes, error)
}

DiscovererClient is the client API for Discoverer service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewDiscovererClient

func NewDiscovererClient(cc *grpc.ClientConn) DiscovererClient

type DiscovererServer

type DiscovererServer interface {
	Pods(context.Context, *payload.Discoverer_Request) (*payload.Info_Pods, error)
	Nodes(context.Context, *payload.Discoverer_Request) (*payload.Info_Nodes, error)
}

DiscovererServer is the server API for Discoverer service.

type UnimplementedDiscovererServer

type UnimplementedDiscovererServer struct {
}

UnimplementedDiscovererServer can be embedded to have forward compatible implementations.

func (*UnimplementedDiscovererServer) Nodes

func (*UnimplementedDiscovererServer) Nodes(ctx context.Context, req *payload.Discoverer_Request) (*payload.Info_Nodes, error)

func (*UnimplementedDiscovererServer) Pods

func (*UnimplementedDiscovererServer) Pods(ctx context.Context, req *payload.Discoverer_Request) (*payload.Info_Pods, error)