cmd

package
v1.0.0-rc.4 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Mar 20, 2023 License: Apache-2.0 Imports: 15 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var Module = fx.Options(
	fx.Provide(NewHandler),
	fx.Invoke(RegisterControllerServer),
)

Module is a module for running cmd.v1.Controller service.

Functions

func RegisterControllerServer

func RegisterControllerServer(handler *Handler, server *grpc.Server, healthsrv *health.Server)

RegisterControllerServer registers handler for cmd.v1.Controller service.

Types

type AutoScaleControlPointID added in v0.27.0

type AutoScaleControlPointID struct {
	APIVersion string
	Kind       string
	Namespace  string
	Name       string
}

AutoScaleControlPointID is a ControlPointID without an agent group.

func AutoScaleControlPointIDFromProto added in v0.27.0

func AutoScaleControlPointIDFromProto(protoCP *autoscalecontrolpointsv1.AutoScaleKubernetesControlPoint) AutoScaleControlPointID

AutoScaleControlPointIDFromProto creates ControlPointID from protobuf representation.

type GlobalAutoScaleControlPointID added in v0.27.0

type GlobalAutoScaleControlPointID struct {
	AutoScaleControlPointID
	AgentGroup string
}

GlobalAutoScaleControlPointID is a ControlPointID with an agent group.

func (GlobalAutoScaleControlPointID) ToProto added in v0.27.0

func (gcp GlobalAutoScaleControlPointID) ToProto() *cmdv1.GlobalAutoScaleControlPoint

ToProto converts ControlPointID to protobuf representation.

type Handler

type Handler struct {
	cmdv1.UnimplementedControllerServer
	// contains filtered or unexported fields
}

Handler is a gRPC server for the controller service.

func NewHandler

func NewHandler(agents agents.Agents) *Handler

NewHandler creates a new Handler.

func (*Handler) ListAgents

func (h *Handler) ListAgents(
	ctx context.Context,
	_ *emptypb.Empty,
) (*cmdv1.ListAgentsResponse, error)

ListAgents lists all agents.

func (*Handler) ListAutoScaleControlPoints added in v0.27.0

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

ListAutoScaleControlPoints lists all AutoScaleControlPoints.

func (*Handler) ListDiscoveryEntities added in v0.27.0

func (h *Handler) ListDiscoveryEntities(ctx context.Context, req *cmdv1.ListDiscoveryEntitiesRequest) (*cmdv1.ListDiscoveryEntitiesControllerResponse, error)

ListDiscoveryEntities lists all Discovery entities.

func (*Handler) ListDiscoveryEntity added in v0.27.0

func (h *Handler) ListDiscoveryEntity(ctx context.Context, req *cmdv1.ListDiscoveryEntityRequest) (*cmdv1.ListDiscoveryEntityAgentResponse, error)

ListDiscoveryEntity lists all Discovery entity.

func (*Handler) ListFlowControlPoints added in v0.27.0

func (h *Handler) ListFlowControlPoints(
	ctx context.Context,
	_ *cmdv1.ListFlowControlPointsRequest,
) (*cmdv1.ListFlowControlPointsControllerResponse, error)

ListFlowControlPoints lists all FlowControlPoints.

func (*Handler) PreviewFlowLabels

func (h *Handler) PreviewFlowLabels(
	ctx context.Context,
	req *cmdv1.PreviewFlowLabelsRequest,
) (*cmdv1.PreviewFlowLabelsControllerResponse, error)

PreviewFlowLabels previews flow labels.

func (*Handler) PreviewHTTPRequests

func (h *Handler) PreviewHTTPRequests(
	ctx context.Context,
	req *cmdv1.PreviewHTTPRequestsRequest,
) (*cmdv1.PreviewHTTPRequestsControllerResponse, error)

PreviewHTTPRequests previews HTTP requests.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
JackTT - Gopher 🇻🇳