Documentation
¶
Index ¶
- Variables
- func RegisterControllerServer(handler *Handler, server *grpc.Server, healthsrv *health.Server)
- type AutoScaleControlPointID
- type GlobalAutoScaleControlPointID
- type Handler
- func (h *Handler) DeletePolicy(ctx context.Context, req *policylangv1.DeletePolicyRequest) (*emptypb.Empty, error)
- func (h *Handler) ListAgents(ctx context.Context, _ *emptypb.Empty) (*cmdv1.ListAgentsResponse, error)
- func (h *Handler) ListAutoScaleControlPoints(ctx context.Context, _ *cmdv1.ListAutoScaleControlPointsRequest) (*cmdv1.ListAutoScaleControlPointsControllerResponse, error)
- func (h *Handler) ListDiscoveryEntities(ctx context.Context, req *cmdv1.ListDiscoveryEntitiesRequest) (*cmdv1.ListDiscoveryEntitiesControllerResponse, error)
- func (h *Handler) ListDiscoveryEntity(ctx context.Context, req *cmdv1.ListDiscoveryEntityRequest) (*cmdv1.ListDiscoveryEntityAgentResponse, error)
- func (h *Handler) ListFlowControlPoints(ctx context.Context, _ *cmdv1.ListFlowControlPointsRequest) (*cmdv1.ListFlowControlPointsControllerResponse, error)
- func (h *Handler) PostDynamicConfig(ctx context.Context, req *policylangv1.PostDynamicConfigRequest) (*emptypb.Empty, error)
- func (h *Handler) PreviewFlowLabels(ctx context.Context, req *cmdv1.PreviewFlowLabelsRequest) (*cmdv1.PreviewFlowLabelsControllerResponse, error)
- func (h *Handler) PreviewHTTPRequests(ctx context.Context, req *cmdv1.PreviewHTTPRequestsRequest) (*cmdv1.PreviewHTTPRequestsControllerResponse, error)
- func (h *Handler) UpsertPolicy(ctx context.Context, req *policylangv1.UpsertPolicyRequest) (*emptypb.Empty, error)
Constants ¶
This section is empty.
Variables ¶
var Module = fx.Options( fx.Provide(NewHandler), fx.Invoke(RegisterControllerServer), )
Module is a module for running cmd.v1.Controller service.
Functions ¶
Types ¶
type AutoScaleControlPointID ¶ added in v0.27.0
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, policyService *controlplane.PolicyService) *Handler
NewHandler creates a new Handler.
func (*Handler) DeletePolicy ¶ added in v1.5.0
func (h *Handler) DeletePolicy(ctx context.Context, req *policylangv1.DeletePolicyRequest) (*emptypb.Empty, error)
DeletePolicy deletes policies from the system.
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) PostDynamicConfig ¶ added in v1.5.0
func (h *Handler) PostDynamicConfig(ctx context.Context, req *policylangv1.PostDynamicConfigRequest) (*emptypb.Empty, error)
PostDynamicConfig updates dynamic-config in the system.
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.
func (*Handler) UpsertPolicy ¶ added in v1.5.0
func (h *Handler) UpsertPolicy(ctx context.Context, req *policylangv1.UpsertPolicyRequest) (*emptypb.Empty, error)
UpsertPolicy creates/updates policies in the system.