agentfunctions

package
v2.27.0 Latest Latest
Warning

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

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

Documentation

Index

Constants

This section is empty.

Variables

Module provides rpc client for agent functions.

Functions

func RegisterCacheHandlers added in v2.25.0

func RegisterCacheHandlers(handler *CacheHandler, t *transport.EtcdTransportServer) error

RegisterCacheHandlers registers cache handler functions in handler registry.

func RegisterControlPointsHandler

func RegisterControlPointsHandler(handler FlowControlControlPointsHandler, t *transport.EtcdTransportServer) error

RegisterControlPointsHandler registers ControlPointsHandler in handler registry.

func RegisterEtcdTransport added in v2.20.0

func RegisterEtcdTransport(in RegisterClientIn)

RegisterEtcdTransport registers a server on the etcd transport.

func RegisterPreviewHandler

func RegisterPreviewHandler(handler *PreviewHandler, t *transport.EtcdTransportServer) error

RegisterPreviewHandler registers PreviewHandler in handler registry.

Types

type CacheHandler added in v2.25.0

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

CacheHandler is a handler for cache-family of functions.

func NewCacheHandler added in v2.25.0

func NewCacheHandler(
	cache iface.Cache,
	agentInfo *agentinfo.AgentInfo,
) (*CacheHandler, error)

NewCacheHandler creates a new CacheHandler.

func (*CacheHandler) CacheDelete added in v2.25.0

CacheDelete deletes given keys from the cache.

func (*CacheHandler) CacheLookup added in v2.25.0

CacheLookup looks up given keys in the cache.

func (*CacheHandler) CacheUpsert added in v2.25.0

CacheUpsert inserts or updates given keys into the cache.

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

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

PreviewFlowLabels previews flow labels on given control point.

func (*PreviewHandler) PreviewHTTPRequests

PreviewHTTPRequests previews HTTP requests on given control point.

type RegisterClientIn

type RegisterClientIn struct {
	fx.In
	Lc                  fx.Lifecycle
	Unmarshaller        config.Unmarshaller
	ConnBuilder         grpcclient.ClientConnectionBuilder `name:"agent-functions"`
	EtcdTransportServer *transport.EtcdTransportServer
	EtcdClient          *etcdclient.Client
}

RegisterClientIn are parameters for InvokeClient function.

Directories

Path Synopsis
+kubebuilder:validation:Optional
+kubebuilder:validation:Optional

Jump to

Keyboard shortcuts

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