cache

package
v0.0.0-...-a9119a5 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jan 18, 2022 License: Apache-2.0, Apache-2.0 Imports: 11 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	HostMaintainCache      = cache.New(g.GlobalCacheTtl, g.GlobalCacheTtl)
	HostSSCache            = cache.New(g.GlobalCacheTtl, g.GlobalCacheTtl)
	UnionStrategiesCache   = cache.New(g.GlobalCacheTtl, g.GlobalCacheTtl)
	HostSpecialMetricCache = cache.New(g.GlobalCacheTtl, g.GlobalCacheTtl)
	HostPluginCache        = cache.New(g.GlobalCacheTtl, g.GlobalCacheTtl)
)
View Source 
var (
	Strategies      = &SafeStrategies{M: make(map[int]*model.Strategy)}
	UnionStrategies = &SafeUnionStrategies{M: make(map[int][]*model.Strategy)}
)
View Source 
var Agents = NewSafeAgents()
View Source 
var DynamicConfig = &SafeDynamicConfig{M: make(map[string][]*model.DynamicConfig)}
View Source 
var ExpressionCache = &SafeExpressionCache{}
View Source 
var GroupPlugins = &SafeGroupPlugins{M: make(map[int][]string)}
View Source 
var GroupTemplates = &SafeGroupTemplates{M: make(map[int][]int)}
View Source 
var HostGroupsMap = &SafeHostGroupsMap{M: make(map[int][]int)}
View Source 
var HostMap = &SafeHostMap{M: make(map[string]int)}
View Source 
var HostTemplateIds = &SafeHostTemplateIds{M: make(map[int][]int)}
View Source 
var MonitoredHosts = &SafeMonitoredHosts{M: make(map[int]*model.Host)}
View Source 
var NewAgentUpgradeArgs = &model.AgentUpgradeArgs{WgetUrl: "", Version: ""}
View Source 
var NowAgentVersionMap = sync.Map{}
View Source 
var Services = &SafeServices{M: make(map[string]string)}
View Source 
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 JudgeHostMaintain 

func JudgeHostMaintain(hostname string) bool

func JudgeHostPlugin 

func JudgeHostPlugin(hostname string) []string

func JudgeHostSpecialMetric 

func JudgeHostSpecialMetric(hostname string) []*model.BuiltinMetric

func JudgeHostStrategies 

func JudgeHostStrategies(hostname string) []*model.Strategy

func JudgeUnionStrategies 

func JudgeUnionStrategies(unionId int) []*model.Strategy

func ParentIds 

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

查找父模板id

Types

type SafeAgents 

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

func NewSafeAgents 

func NewSafeAgents() *SafeAgents

func (*SafeAgents) AgentVersions 

func (this *SafeAgents) AgentVersions() map[string]string

func (*SafeAgents) AgentVersionsNew 

func (this *SafeAgents) AgentVersionsNew() map[string]string

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 SafeDynamicConfig 

type SafeDynamicConfig struct {
	sync.RWMutex
	M map[string][]*model.DynamicConfig
}

func (*SafeDynamicConfig) Get 

func (this *SafeDynamicConfig) Get() map[string][]*model.DynamicConfig

func (*SafeDynamicConfig) Init 

func (this *SafeDynamicConfig) Init()

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

func (this *SafeHostMap) Get() map[string]int

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 SafeServices 

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

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

func (*SafeServices) Get 

func (this *SafeServices) Get() map[string]string

func (*SafeServices) Init 

func (this *SafeServices) Init()

map[hid][]svsid

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

type SafeUnionStrategies 

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

func (*SafeUnionStrategies) Get 

func (this *SafeUnionStrategies) Get() map[int][]*model.Strategy

func (*SafeUnionStrategies) Init 

func (this *SafeUnionStrategies) Init(unM map[int][]*model.Strategy)

type UpgradeAgent 

type UpgradeAgent struct {
	Timestamp   int64  `json:"timestamp"`
	LastVersion string `json:"lastversion"`
	ThisVersion string `json:"thisversion"`
}

type UpgradeAgents 

type UpgradeAgents struct {
	Map sync.Map
}

func NewUpgradeAgents 

func NewUpgradeAgents() *UpgradeAgents

func (*UpgradeAgents) UpgradeAgentKeys 

func (this *UpgradeAgents) UpgradeAgentKeys() (len int, keys []string)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.