apm

Documentation

Index

• type APM
• type Plugin
  • func (Plugin) Client(b *plugin.MuxBroker, c *rpc.Client) (interface{}, error)
  • func (p *Plugin) Server(*plugin.MuxBroker) (interface{}, error)
• type QueryRPCReq
• type RPC
  • func (r *RPC) PluginInfo() (*base.PluginInfo, error)
  • func (r *RPC) Query(q string, rng sdk.TimeRange) (sdk.TimestampedMetrics, error)
  • func (r *RPC) SetConfig(config map[string]string) error
• type RPCServer
  • func (s *RPCServer) PluginInfo(_ interface{}, r *base.PluginInfo) error
  • func (s *RPCServer) Query(req QueryRPCReq, resp *sdk.TimestampedMetrics) error
  • func (s *RPCServer) SetConfig(config map[string]string, resp *error) error

Types

type APM

type APM interface {
	Query(q string, r sdk.TimeRange) (sdk.TimestampedMetrics, error)
	QueryMultiple(q string, r sdk.TimeRange) ([]sdk.TimestampedMetrics, error)
	PluginInfo() (*base.PluginInfo, error)
	SetConfig(config map[string]string) error
}

type Plugin

type Plugin struct {
	Impl APM
}

Plugin is the plugin.Plugin

func (Plugin) Client

func (Plugin) Client(b *plugin.MuxBroker, c *rpc.Client) (interface{}, error)

func (*Plugin) Server

func (p *Plugin) Server(*plugin.MuxBroker) (interface{}, error)

type QueryRPCReq

type QueryRPCReq struct {
	Query string
	Range sdk.TimeRange
}

type RPC

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

RPC is a plugin implementation that talks over net/rpc

func (*RPC) PluginInfo

func (r *RPC) PluginInfo() (*base.PluginInfo, error)

func (*RPC) Query

func (r *RPC) Query(q string, rng sdk.TimeRange) (sdk.TimestampedMetrics, error)

func (*RPC) SetConfig

func (r *RPC) SetConfig(config map[string]string) error

type RPCServer

type RPCServer struct {
	Impl APM
}

RPCServer is the net/rpc server

func (*RPCServer) PluginInfo

func (s *RPCServer) PluginInfo(_ interface{}, r *base.PluginInfo) error

func (*RPCServer) Query

func (s *RPCServer) Query(req QueryRPCReq, resp *sdk.TimestampedMetrics) error

func (*RPCServer) SetConfig

func (s *RPCServer) SetConfig(config map[string]string, resp *error) error