rpc

Documentation

Index

• func CalcInheritStrategies(allTpls map[int]*model.Template, tids []int, ...) []model.Strategy
• func DigestBuiltinMetrics(items []*model.BuiltinMetric) string
• func Start()
• func Tpl2Strategies(strategies map[int]*model.Strategy) map[int][]*model.Strategy
• type Agent
  • func (t *Agent) BuiltinMetrics(args *model.AgentHeartbeatRequest, reply *model.BuiltinMetricResponse) error
  • func (t *Agent) MinePlugins(args model.AgentHeartbeatRequest, reply *model.AgentPluginsResponse) error
  • func (t *Agent) ReportStatus(args *model.AgentReportRequest, reply *model.SimpleRpcResponse) error
  • func (t *Agent) TrustableIps(args *model.NullRpcRequest, ips *string) error
• type Hbs
  • func (t *Hbs) GetExpressions(req model.NullRpcRequest, reply *model.ExpressionResponse) error
  • func (t *Hbs) GetStrategies(req model.NullRpcRequest, reply *model.StrategiesResponse) error
• type NqmAgent
  • func (t *NqmAgent) PingTask(request commonModel.NqmPingTaskRequest, ...) (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 Start

func Start()

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) 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) error

func (*Agent) ReportStatus

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

func (*Agent) TrustableIps

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

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

type Hbs

type Hbs int

func (*Hbs) GetExpressions

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

func (*Hbs) GetStrategies

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

type NqmAgent

type NqmAgent int

func (*NqmAgent) PingTask

func (t *NqmAgent) PingTask(request commonModel.NqmPingTaskRequest, response *commonModel.NqmPingTaskResponse) (err error)

Retrieve the configuration of ping task for certain client

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