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) DynamicMonitoring(args *model.AgentReportRequest, ...) error
  • func (t *Agent) MinePlugins(args model.AgentHeartbeatRequest, reply *model.AgentPluginsResponse) error
  • func (t *Agent) ReportStatus(args *model.AgentReportRequest, reply *model.AgentUpgradeRpcResponse) error
  • func (t *Agent) SyncServiceNames(args *model.AgentReportRequest, reply *model.AgentServiceConfigRpcResponse) error
  • func (t *Agent) TrustableIps(args *model.NullRpcRequest, ips *string) error
• type Hbs
  • func (t *Hbs) GetAgents(req model.NullRpcRequest, reply *model.Agents) error
  • func (t *Hbs) GetExpressions(req model.NullRpcRequest, reply *model.ExpressionResponse) error
  • func (t *Hbs) GetOneEndStrategies(req model.SingleEndRpcRequest, reply *model.OneStrategiesResponse) error
  • func (t *Hbs) GetOneUnionStrategies(req model.SingleIdRequest, reply *model.OneStrategiesResponse) error
  • func (t *Hbs) GetStrategies(req model.NullRpcRequest, reply *model.StrategiesResponse) error
  • func (t *Hbs) GetStrategiesOne(req OneReq, reply *model.StrategiesResponse) error
  • func (t *Hbs) GetUnionStrategies(req model.NullRpcRequest, reply *model.UnionStrategiesResponse) error
• type OneReq

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

func (*Agent) DynamicMonitoring

func (t *Agent) DynamicMonitoring(args *model.AgentReportRequest, reply *model.AgentDynamicMonitoringConfigRpcResponse) error

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

func (*Agent) SyncServiceNames

func (t *Agent) SyncServiceNames(args *model.AgentReportRequest, reply *model.AgentServiceConfigRpcResponse) error

send services to agent

func (*Agent) TrustableIps

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

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

type Hbs

type Hbs int

func (*Hbs) GetAgents

func (t *Hbs) GetAgents(req model.NullRpcRequest, reply *model.Agents) error

func (*Hbs) GetExpressions

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

func (*Hbs) GetOneEndStrategies

func (t *Hbs) GetOneEndStrategies(req model.SingleEndRpcRequest, reply *model.OneStrategiesResponse) error

func (*Hbs) GetOneUnionStrategies

func (t *Hbs) GetOneUnionStrategies(req model.SingleIdRequest, reply *model.OneStrategiesResponse) error

func (*Hbs) GetStrategies

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

func (*Hbs) GetStrategiesOne

func (t *Hbs) GetStrategiesOne(req OneReq, reply *model.StrategiesResponse) error

func (*Hbs) GetUnionStrategies

func (t *Hbs) GetUnionStrategies(req model.NullRpcRequest, reply *model.UnionStrategiesResponse) error

type OneReq

type OneReq struct {
	Hostname string `json:"hostname"`
}

TODO 测试获取单个endpoint 的策略列表，后后续去掉