rpc

Documentation

Index

• func CalcInheritStrategies(allTpls map[int]*model.Template, tids []int, ...) []model.Strategy
• func DigestBuiltinMetrics(items []*model.BuiltinMetric) string
• func InitPackage(config *viper.Viper)
• func Start()
• func Stop()
• func Tpl2Strategies(strategies map[int]*model.Strategy) map[int][]*model.Strategy
• 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)
  • func (t *Agent) TrustableIps(args *model.NullRpcRequest, ips *string) (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)

Functions

func CalcInheritStrategies

func CalcInheritStrategies(allTpls map[int]*model.Template, tids []int, tpl2Strategies map[int][]*model.Strategy) []model.Strategy

func DigestBuiltinMetrics

func DigestBuiltinMetrics(items []*model.BuiltinMetric) string

func InitPackage

func InitPackage(config *viper.Viper)

func Start

func Start()

func Stop

func Stop()

func Tpl2Strategies

func Tpl2Strategies(strategies map[int]*model.Strategy) map[int][]*model.Strategy

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)

func (*Agent) TrustableIps

func (t *Agent) TrustableIps(args *model.NullRpcRequest, ips *string) (err error)

需要checksum一下来减少网络开销？其实白名单通常只会有一个或者没有，无需checksum

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.