cache

Documentation

Index

• Variables
• func DeleteStaleAgents()
• func GetBuiltinMetrics(hostname string) ([]*model.BuiltinMetric, error)
• func GetPlugins(hostname string) []string
• func Init()
• func LoopInit()
• func ParentIds(allTpls map[int]*model.Template, tid int) (ret []int)
• type SafeAgents
  • func NewSafeAgents() *SafeAgents
  • func (this *SafeAgents) Delete(hostname string)
  • func (this *SafeAgents) Get(hostname string) (*model.AgentUpdateInfo, bool)
  • func (this *SafeAgents) Keys() []string
  • func (this *SafeAgents) Put(req *model.AgentReportRequest)
• type SafeExpressionCache
  • func (this *SafeExpressionCache) Get() []*model.Expression
  • func (this *SafeExpressionCache) Init()
• type SafeGroupPlugins
  • func (this *SafeGroupPlugins) GetPlugins(gid int) ([]string, bool)
  • func (this *SafeGroupPlugins) Init()
• type SafeGroupTemplates
  • func (this *SafeGroupTemplates) GetTemplateIds(gid int) ([]int, bool)
  • func (this *SafeGroupTemplates) Init()
• type SafeHostGroupsMap
  • func (this *SafeHostGroupsMap) GetGroupIds(hid int) ([]int, bool)
  • func (this *SafeHostGroupsMap) Init()
• type SafeHostMap
  • func (this *SafeHostMap) GetID(hostname string) (int, bool)
  • func (this *SafeHostMap) Init()
• type SafeHostTemplateIds
  • func (this *SafeHostTemplateIds) GetMap() map[int][]int
  • func (this *SafeHostTemplateIds) Init()
• type SafeMonitoredHosts
  • func (this *SafeMonitoredHosts) Get() map[int]*model.Host
  • func (this *SafeMonitoredHosts) Init()
• type SafeStrategies
  • func (this *SafeStrategies) GetMap() map[int]*model.Strategy
  • func (this *SafeStrategies) Init(tpls map[int]*model.Template)
• type SafeTemplateCache
  • func (this *SafeTemplateCache) GetMap() map[int]*model.Template
  • func (this *SafeTemplateCache) Init()

Variables

var Agents = NewSafeAgents()

var ExpressionCache = &SafeExpressionCache{}

var GroupPlugins = &SafeGroupPlugins{M: make(map[int][]string)}

var GroupTemplates = &SafeGroupTemplates{M: make(map[int][]int)}

var HostGroupsMap = &SafeHostGroupsMap{M: make(map[int][]int)}

var HostMap = &SafeHostMap{M: make(map[string]int)}

var HostTemplateIds = &SafeHostTemplateIds{M: make(map[int][]int)}

var MonitoredHosts = &SafeMonitoredHosts{M: make(map[int]*model.Host)}

var Strategies = &SafeStrategies{M: make(map[int]*model.Strategy)}

var TemplateCache = &SafeTemplateCache{M: make(map[int]*model.Template)}

Functions

func DeleteStaleAgents

func DeleteStaleAgents()

func GetBuiltinMetrics

func GetBuiltinMetrics(hostname string) ([]*model.BuiltinMetric, error)

func GetPlugins

func GetPlugins(hostname string) []string

根据hostname获取关联的插件

func Init

func Init()

func LoopInit

func LoopInit()

func ParentIds

func ParentIds(allTpls map[int]*model.Template, tid int) (ret []int)

Types

type SafeAgents

type SafeAgents struct {
	sync.RWMutex
	M map[string]*model.AgentUpdateInfo
}

func NewSafeAgents

func NewSafeAgents() *SafeAgents

func (*SafeAgents) Delete

func (this *SafeAgents) Delete(hostname string)

func (*SafeAgents) Get

func (this *SafeAgents) Get(hostname string) (*model.AgentUpdateInfo, bool)

func (*SafeAgents) Keys

func (this *SafeAgents) Keys() []string

func (*SafeAgents) Put

func (this *SafeAgents) Put(req *model.AgentReportRequest)

type SafeExpressionCache

type SafeExpressionCache struct {
	sync.RWMutex
	L []*model.Expression
}

func (*SafeExpressionCache) Get

func (this *SafeExpressionCache) Get() []*model.Expression

func (*SafeExpressionCache) Init

func (this *SafeExpressionCache) Init()

type SafeGroupPlugins

type SafeGroupPlugins struct {
	sync.RWMutex
	M map[int][]string
}

一个HostGroup可以绑定多个Plugin

func (*SafeGroupPlugins) GetPlugins

func (this *SafeGroupPlugins) GetPlugins(gid int) ([]string, bool)

func (*SafeGroupPlugins) Init

func (this *SafeGroupPlugins) Init()

type SafeGroupTemplates

type SafeGroupTemplates struct {
	sync.RWMutex
	M map[int][]int
}

一个HostGroup对应多个Template

func (*SafeGroupTemplates) GetTemplateIds

func (this *SafeGroupTemplates) GetTemplateIds(gid int) ([]int, bool)

func (*SafeGroupTemplates) Init

func (this *SafeGroupTemplates) Init()

type SafeHostGroupsMap

type SafeHostGroupsMap struct {
	sync.RWMutex
	M map[int][]int
}

一个机器可能在多个group下，做一个map缓存hostid与groupid的对应关系

func (*SafeHostGroupsMap) GetGroupIds

func (this *SafeHostGroupsMap) GetGroupIds(hid int) ([]int, bool)

func (*SafeHostGroupsMap) Init

func (this *SafeHostGroupsMap) Init()

type SafeHostMap

type SafeHostMap struct {
	sync.RWMutex
	M map[string]int
}

每次心跳的时候agent把hostname汇报上来，经常要知道这个机器的hostid，把此信息缓存 key: hostname value: hostid

func (*SafeHostMap) GetID

func (this *SafeHostMap) GetID(hostname string) (int, bool)

func (*SafeHostMap) Init

func (this *SafeHostMap) Init()

type SafeHostTemplateIds

type SafeHostTemplateIds struct {
	sync.RWMutex
	M map[int][]int
}

func (*SafeHostTemplateIds) GetMap

func (this *SafeHostTemplateIds) GetMap() map[int][]int

func (*SafeHostTemplateIds) Init

func (this *SafeHostTemplateIds) Init()

type SafeMonitoredHosts

type SafeMonitoredHosts struct {
	sync.RWMutex
	M map[int]*model.Host
}

func (*SafeMonitoredHosts) Get

func (this *SafeMonitoredHosts) Get() map[int]*model.Host

func (*SafeMonitoredHosts) Init

func (this *SafeMonitoredHosts) Init()

type SafeStrategies

type SafeStrategies struct {
	sync.RWMutex
	M map[int]*model.Strategy
}

func (*SafeStrategies) GetMap

func (this *SafeStrategies) GetMap() map[int]*model.Strategy

func (*SafeStrategies) Init

func (this *SafeStrategies) Init(tpls map[int]*model.Template)

type SafeTemplateCache

type SafeTemplateCache struct {
	sync.RWMutex
	M map[int]*model.Template
}

func (*SafeTemplateCache) GetMap

func (this *SafeTemplateCache) GetMap() map[int]*model.Template

func (*SafeTemplateCache) Init

func (this *SafeTemplateCache) Init()