apm

Documentation

Index

• type APM
• type PluginAPM
  • func (p *PluginAPM) GRPCClient(ctx context.Context, _ *plugin.GRPCBroker, c *grpc.ClientConn) (interface{}, error)
  • func (p *PluginAPM) GRPCServer(broker *plugin.GRPCBroker, s *grpc.Server) error

Types

type APM

type APM interface {

	// Embed the base.Base ensuring that APM plugins implement this
	// interface.
	base.Base

	// Query is used to ask the remote APM for timestamped metrics based on the
	// passed query and time range.
	Query(query string, timeRange sdk.TimeRange) (sdk.TimestampedMetrics, error)

	// QueryMultiple is used exclusively by Dynamic Application Sizing in order
	// to gather the metrics desired by the feature.
	QueryMultiple(query string, timeRange sdk.TimeRange) ([]sdk.TimestampedMetrics, error)
}

APM is the interface that all APM plugins are required to implement and details the functions that are used to provide the Autoscaler with metrics to make scaling decisions on.

type PluginAPM

type PluginAPM struct {

	// Embedded so we disable support for net/rpc based plugins.
	plugin.NetRPCUnsupportedPlugin

	// Impl is the APM interface implementation that the plugin serves.
	Impl APM
}

PluginAPM is the APM implementation of the go-plugin GRPCPlugin interface.

func (*PluginAPM) GRPCClient

func (p *PluginAPM) GRPCClient(ctx context.Context, _ *plugin.GRPCBroker, c *grpc.ClientConn) (interface{}, error)

GRPCClient is the APM implementation of the go-plugin GRPCPlugin.GRPCClient interface function.

func (*PluginAPM) GRPCServer

func (p *PluginAPM) GRPCServer(broker *plugin.GRPCBroker, s *grpc.Server) error

GRPCServer is the APM implementation of the go-plugin GRPCPlugin.GRPCServer interface function.