agentfunctions

Documentation

Index

• Variables
• func RegisterClient(in RegisterClientIn) error
• func RegisterControlPointsHandler(handler FlowControlControlPointsHandler, registry *rpc.HandlerRegistry) error
• func RegisterPreviewHandler(handler *PreviewHandler, registry *rpc.HandlerRegistry) error
• type FlowControlControlPointsHandler
  • func NewFlowControlControlPointsHandler(cache *cache.Cache[selectors.TypedControlPointID], ...) FlowControlControlPointsHandler
  • func (h *FlowControlControlPointsHandler) ListFlowControlPoints(ctx context.Context, _ *cmdv1.ListFlowControlPointsRequest) (*cmdv1.ListFlowControlPointsAgentResponse, error)
• type PreviewHandler
  • func ProvidePreviewHandler(handler *preview.Handler, unmarshaller config.Unmarshaller) (*PreviewHandler, error)
  • func (h *PreviewHandler) PreviewFlowLabels(ctx context.Context, req *cmdv1.PreviewFlowLabelsRequest) (*previewv1.PreviewFlowLabelsResponse, error)
  • func (h *PreviewHandler) PreviewHTTPRequests(ctx context.Context, req *cmdv1.PreviewHTTPRequestsRequest) (*previewv1.PreviewHTTPRequestsResponse, error)
• type RegisterClientIn

Variables

var Module = fx.Options(

	grpcclient.ClientConstructor{
		Name:      "agent-functions",
		ConfigKey: afconfig.Key + ".client.grpc",
	}.Annotate(),
	fx.Provide(
		NewFlowControlControlPointsHandler,
		ProvidePreviewHandler,
	),
	fx.Invoke(
		RegisterClient,
		RegisterControlPointsHandler,
		RegisterPreviewHandler,
	),
)

Module provides rpc client for agent functions.

Functions

func RegisterClient

func RegisterClient(in RegisterClientIn) error

RegisterClient registers a client which will allow calling agent functions from controller.

func RegisterControlPointsHandler

func RegisterControlPointsHandler(handler FlowControlControlPointsHandler, registry *rpc.HandlerRegistry) error

RegisterControlPointsHandler registers ControlPointsHandler in handler registry.

func RegisterPreviewHandler

func RegisterPreviewHandler(handler *PreviewHandler, registry *rpc.HandlerRegistry) error

RegisterPreviewHandler registers PreviewHandler in handler registry.

Types

type FlowControlControlPointsHandler

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

FlowControlControlPointsHandler is a handler for ListFlowControlPoints function

Note: There's no requirement every handler needs to be in a separate struct. More methods can be added to this one.

func NewFlowControlControlPointsHandler

func NewFlowControlControlPointsHandler(
	cache *cache.Cache[selectors.TypedControlPointID],
	agentInfo *agentinfo.AgentInfo,
) FlowControlControlPointsHandler

NewFlowControlControlPointsHandler returns a new FlowControlControlPointsHandler.

func (*FlowControlControlPointsHandler) ListFlowControlPoints

func (h *FlowControlControlPointsHandler) ListFlowControlPoints(
	ctx context.Context,
	_ *cmdv1.ListFlowControlPointsRequest,
) (*cmdv1.ListFlowControlPointsAgentResponse, error)

ListFlowControlPoints lists currently discovered control points.

type PreviewHandler

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

PreviewHandler is a handler for preview-family of functions.

Simply forwards methods to grpc handler, which provides actual implementation.

func ProvidePreviewHandler

func ProvidePreviewHandler(
	handler *preview.Handler,
	unmarshaller config.Unmarshaller,
) (*PreviewHandler, error)

ProvidePreviewHandler provides PreviewHandler.

func (*PreviewHandler) PreviewFlowLabels

func (h *PreviewHandler) PreviewFlowLabels(
	ctx context.Context,
	req *cmdv1.PreviewFlowLabelsRequest,
) (*previewv1.PreviewFlowLabelsResponse, error)

PreviewFlowLabels previews flow labels on given control point.

func (*PreviewHandler) PreviewHTTPRequests

func (h *PreviewHandler) PreviewHTTPRequests(
	ctx context.Context,
	req *cmdv1.PreviewHTTPRequestsRequest,
) (*previewv1.PreviewHTTPRequestsResponse, error)

PreviewHTTPRequests previews HTTP requests on given control point.

type RegisterClientIn

type RegisterClientIn struct {
	fx.In
	Lc           fx.Lifecycle
	Unmarshaller config.Unmarshaller
	Handlers     *rpc.HandlerRegistry
	ConnBuilder  grpcclient.ClientConnectionBuilder `name:"agent-functions"`
}

RegisterClientIn are parameters for InvokeClient function.