controlpoints

Documentation

Index

• func Module() fx.Option
• func RegisterControlPointCacheService(in RegisterControlPointCacheServiceIn)
• func RegisterControlPointsHandler(handler *Handler, t *transport.EtcdTransportClient) 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)
• type RegisterControlPointCacheServiceIn

Functions

func Module

func Module() fx.Option

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

func RegisterControlPointCacheService

func RegisterControlPointCacheService(in RegisterControlPointCacheServiceIn)

RegisterControlPointCacheService registers the ControlPointCache service handler with the gRPC server.

func RegisterControlPointsHandler

func RegisterControlPointsHandler(handler *Handler, t *transport.EtcdTransportClient) 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.

type RegisterControlPointCacheServiceIn

type RegisterControlPointCacheServiceIn struct {
	fx.In
	Server  *grpc.Server `name:"default"`
	Handler *Handler
}

RegisterControlPointCacheServiceIn bundles and annotates parameters.