agents

Documentation

Overview

Server-side for handling agent functions

Index

• Variables
• type Agents
  • func NewAgents(transport *transport.EtcdTransportClient, client *etcdclient.Client) Agents
  • func (a Agents) GetAgents(ctx context.Context) (map[string][]string, error)
  • func (a Agents) GetAgentsForGroup(ctx context.Context, agentGroup string) ([]string, error)
  • func (a Agents) ListAutoScaleControlPoints(ctx context.Context) ([]transport.Result[*cmdv1.ListAutoScaleControlPointsAgentResponse], error)
  • func (a Agents) ListDiscoveryEntities(ctx context.Context, agentGroup string) ([]transport.Result[*cmdv1.ListDiscoveryEntitiesAgentResponse], error)
  • func (a Agents) ListDiscoveryEntity(ctx context.Context, req *cmdv1.ListDiscoveryEntityRequest) (*cmdv1.ListDiscoveryEntityAgentResponse, error)
  • func (a Agents) ListFlowControlPoints(ctx context.Context) ([]transport.Result[*cmdv1.ListFlowControlPointsAgentResponse], error)
  • func (a Agents) PreviewFlowLabels(ctx context.Context, agent string, req *previewv1.PreviewRequest) (*previewv1.PreviewFlowLabelsResponse, error)
  • func (a Agents) PreviewHTTPRequests(ctx context.Context, agent string, req *previewv1.PreviewRequest) (*previewv1.PreviewHTTPRequestsResponse, error)

Variables

var Module = fx.Provide(NewAgents)

Module is fx module for controlling Agents on controller side.

Types

type Agents

type Agents struct {
	// contains filtered or unexported fields
}

Agents wraps rpc.Clients where clients are agents and provides wrapper

Agents wraps functions registered in agentfunctions, types should match.

func NewAgents

func NewAgents(transport *transport.EtcdTransportClient, client *etcdclient.Client) Agents

NewAgents wraps Clients with Agent-specific function wrappers.

func (Agents) GetAgents

func (a Agents) GetAgents(ctx context.Context) (map[string][]string, error)

GetAgents lists the agents registered on etcd under /peers/aperture-agent.

func (Agents) GetAgentsForGroup

func (a Agents) GetAgentsForGroup(ctx context.Context, agentGroup string) ([]string, error)

GetAgentsForGroup lists the agents under an agent-group registered on etcd under /peers/aperture-agent.

func (Agents) ListAutoScaleControlPoints

func (a Agents) ListAutoScaleControlPoints(ctx context.Context) ([]transport.Result[*cmdv1.ListAutoScaleControlPointsAgentResponse], error)

ListAutoScaleControlPoints lists auto-scale control points of all agents.

func (Agents) ListDiscoveryEntities

func (a Agents) ListDiscoveryEntities(ctx context.Context, agentGroup string) ([]transport.Result[*cmdv1.ListDiscoveryEntitiesAgentResponse], error)

ListDiscoveryEntities lists discovery entities.

func (Agents) ListDiscoveryEntity

func (a Agents) ListDiscoveryEntity(ctx context.Context, req *cmdv1.ListDiscoveryEntityRequest) (*cmdv1.ListDiscoveryEntityAgentResponse, error)

ListDiscoveryEntity lists discovery entity by ip address or name.

func (Agents) ListFlowControlPoints

func (a Agents) ListFlowControlPoints(ctx context.Context) ([]transport.Result[*cmdv1.ListFlowControlPointsAgentResponse], error)

ListFlowControlPoints lists control points of all agents.

Handled by agentfunctions.ControlPointsHandler.

func (Agents) PreviewFlowLabels

func (a Agents) PreviewFlowLabels(
	ctx context.Context,
	agent string,
	req *previewv1.PreviewRequest,
) (*previewv1.PreviewFlowLabelsResponse, error)

PreviewFlowLabels previews flow labels on a given agent.

Handled by agentfunctions.PreviewHandler.

func (Agents) PreviewHTTPRequests

func (a Agents) PreviewHTTPRequests(
	ctx context.Context,
	agent string,
	req *previewv1.PreviewRequest,
) (*previewv1.PreviewHTTPRequestsResponse, error)

PreviewHTTPRequests previews flow labels on a given agent.

Handled by agentfunctions.PreviewHandler.