The highest tagged major version is v2.

cmd

package

v1.6.0 Latest Latest Go to latest Published: May 2, 2023 License: Apache-2.0 Imports: 18 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/fluxninja/aperture

Links

Open Source Insights

Documentation ¶

Index ¶

Variables
func RegisterControllerServer(handler *Handler, server *grpc.Server, healthsrv *health.Server)
type AutoScaleControlPointID
- func AutoScaleControlPointIDFromProto(protoCP *autoscalecontrolpointsv1.AutoScaleKubernetesControlPoint) AutoScaleControlPointID
type GlobalAutoScaleControlPointID
- func (gcp GlobalAutoScaleControlPointID) ToProto() *cmdv1.GlobalAutoScaleControlPoint
type Handler
- func NewHandler(agents agents.Agents, policyService *controlplane.PolicyService) *Handler

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, 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.

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL