rpc

Documentation

Index

• Variables
• func InitPackage(config *viper.Viper)
• func Start()
• func Stop()
• type Agent
  • func (t *Agent) BuiltinMetrics(args *model.AgentHeartbeatRequest, reply *model.BuiltinMetricResponse) (err error)
  • func (t *Agent) MinePlugins(args model.AgentHeartbeatRequest, reply *model.AgentPluginsResponse) (err error)
  • func (t *Agent) ReportStatus(args *model.AgentReportRequest, reply *model.SimpleRpcResponse) (err error)
• type Hbs
  • func (t *Hbs) GetExpressions(req model.NullRpcRequest, reply *model.ExpressionResponse) (err error)
  • func (t *Hbs) GetStrategies(req model.NullRpcRequest, reply *model.StrategiesResponse) (err error)
• type NqmAgent
  • func (t *NqmAgent) Task(request commonModel.NqmTaskRequest, response *commonModel.NqmTaskResponse) (err error)

Variables

var AgentHeartbeatService *service.AgentHeartbeatService

Functions

func InitPackage

func InitPackage(config *viper.Viper)

func Start

func Start()

func Stop

func Stop()

Types

type Agent

type Agent int

func (*Agent) BuiltinMetrics

func (t *Agent) BuiltinMetrics(args *model.AgentHeartbeatRequest, reply *model.BuiltinMetricResponse) (err error)

agent按照server端的配置，按需采集的metric，比如net.port.listen port=22 或者 proc.num name=zabbix_agentd

func (*Agent) MinePlugins

func (t *Agent) MinePlugins(args model.AgentHeartbeatRequest, reply *model.AgentPluginsResponse) (err error)

func (*Agent) ReportStatus

func (t *Agent) ReportStatus(args *model.AgentReportRequest, reply *model.SimpleRpcResponse) (err error)

type Hbs

type Hbs int

func (*Hbs) GetExpressions

func (t *Hbs) GetExpressions(req model.NullRpcRequest, reply *model.ExpressionResponse) (err error)

func (*Hbs) GetStrategies

func (t *Hbs) GetStrategies(req model.NullRpcRequest, reply *model.StrategiesResponse) (err error)

type NqmAgent

type NqmAgent int

func (*NqmAgent) Task

func (t *NqmAgent) Task(request commonModel.NqmTaskRequest, response *commonModel.NqmTaskResponse) (err error)

Task retrieves the configuration of measurement tasks for certain client

If the NqmTaskRequest.ConnectionId is not existing in database, this function would create one, but the NqmTiskResponse.NeedPing would be value of false.