controlpoints

Documentation

Index

• func Module() fx.Option
• func RegisterControlPointCacheService(handler *Handler, server *grpc.Server)
• func RegisterControlPointsHandler(handler *Handler, registry *rpc.HandlerRegistry) error
• type Handler
  • func NewHandler(cpc discovery.AutoScaleControlPoints, agentInfo *agentinfo.AgentInfo) *Handler
  • func (h *Handler) GetControlPoints(ctx context.Context, _ *emptypb.Empty) (*controlpointsv1.AutoScaleKubernetesControlPoints, error)
  • func (h *Handler) ListAutoScaleControlPoints(ctx context.Context, _ *cmdv1.ListAutoScaleControlPointsRequest) (*cmdv1.ListAutoScaleControlPointsAgentResponse, error)

Functions

func Module

func Module() fx.Option

Module returns an fx.Option that provides the Kubernetes discovery module.

func RegisterControlPointCacheService

func RegisterControlPointCacheService(handler *Handler, server *grpc.Server)

RegisterControlPointCacheService registers the ControlPointCache service handler with the gRPC server.

func RegisterControlPointsHandler

func RegisterControlPointsHandler(handler *Handler, registry *rpc.HandlerRegistry) error

RegisterControlPointsHandler registers ControlPointsHandler in RPC handler registry.

Types

type Handler

type Handler struct {
	controlpointsv1.UnimplementedAutoScaleKubernetesControlPointsServiceServer
	AutoScaleControlPoints discovery.AutoScaleControlPoints
	AgentGroup             string
}

Handler is the gRPC server handler.

func NewHandler

func NewHandler(cpc discovery.AutoScaleControlPoints, agentInfo *agentinfo.AgentInfo) *Handler

NewHandler returns a new Handler.

func (*Handler) GetControlPoints

func (h *Handler) GetControlPoints(ctx context.Context, _ *emptypb.Empty) (*controlpointsv1.AutoScaleKubernetesControlPoints, error)

GetControlPoints returns a ControlPoint from the cache.

func (*Handler) ListAutoScaleControlPoints

func (h *Handler) ListAutoScaleControlPoints(
	ctx context.Context,
	_ *cmdv1.ListAutoScaleControlPointsRequest,
) (*cmdv1.ListAutoScaleControlPointsAgentResponse, error)

ListAutoScaleControlPoints lists currently discovered control points.