redi

Documentation

Index

• Constants
• Variables
• func GetDynamicConfigRedis() (map[string][]*model.DynamicConfig, error)
• func GetExpressionsFromRedis() ([]*model.Expression, error)
• func GetGroupTemplateFromRedis() (map[int][]int, error)
• func GetHostFromRedis() (map[string]int, error)
• func GetHostGroupFromRedis() (map[int][]int, error)
• func GetHostServiceFromRedis() (map[string]string, error)
• func GetHostTemplateFromRedis() (map[int][]int, error)
• func GetLock(LockKey string, Timeout int64) bool
• func GetMonitoredHostFromRedis() (map[int]*model.Host, error)
• func GetPluginsFromRedis() (map[int][]string, error)
• func GetStrategiesFromRedis() (map[int]*model.Strategy, error)
• func GetTPLFromRedis() (map[int]*model.Template, error)
• func GetUnionStrategiesFromRedis() (map[int][]*model.Strategy, error)
• func Init()
• func SetDynamicConfig2Redis(m map[string][]*model.DynamicConfig)
• func SetExpressions2Redis(m []*model.Expression)
• func SetGroupTemplate2Redis(m map[int][]int)
• func SetHost2Redis(m map[string]int)
• func SetHostGroup2Redis(m map[int][]int)
• func SetHostService2Redis(m map[string]string)
• func SetHostTemplate2Redis(m map[int][]int)
• func SetMonitoredHost2Redis(m map[int]*model.Host)
• func SetPlugins2Redis(m map[int][]string)
• func SetStrategies2Redis(m map[int]*model.Strategy)
• func SetTPL2Redis(m map[int]*model.Template)
• func SetUnionStrategies2Redis(m map[int][]*model.Strategy)
• func WLock(LockKey string, Timeout int64) error
• func WUnlock(LockKey string)

Constants

const (
	HostKey          = "host"           //
	MonitoredHostKey = "monitored_host" //
)

const (
	GroupPluginsLockKey    = "GroupPluginsLock"
	GroupTemplatesLockKey  = "GroupTemplatesLock"
	HostGroupsMapLockKey   = "HostGroupsMapLock"
	HostMapLockKey         = "HostMapLock"
	TemplateCacheLockKey   = "TemplateCacheLock"
	StrategiesLockKey      = "StrategiesLock"
	HostTemplateIdsLockKey = "HostTemplateIdsLock"
	ExpressionCacheLockKey = "ExpressionCacheLock"
	MonitoredHostsLockKey  = "MonitoredHostsLock"
	DynamicConfigLockKey   = "DynamicConfigLock"
	HostServiceIdsLockKey  = "HostServiceIdsLockKey"

	RedisDisTLockTimeOut = 55

	GroupPluginsWLockKey    = "GroupPluginsWLock"
	GroupTemplatesWLockKey  = "GroupTemplatesWLock"
	HostGroupsMapWLockKey   = "HostGroupsMapWLock"
	HostMapWLockKey         = "HostMapWLock"
	TemplateCacheWLockKey   = "TemplateCacheWLock"
	StrategiesWLockKey      = "StrategiesWLock"
	HostTemplateIdsWLockKey = "HostTemplateIdsWLock"
	ExpressionCacheWLockKey = "ExpressionCacheWLock"
	MonitoredHostsWLockKey  = "MonitoredHostsWLock"
	DynamicConfigWLockKey   = "DynamicConfigWLock"
	HostServiceIdsWLockKey  = "HostServiceIdsLockKey"
)

const (
	TemplateKey     = "template" //
	TPLKey          = "tpl"      //
	HostTemplateKey = "host_template"
)

const DynamicConfigKey = "dynamic_config" //

const ExpressionsKey = "expressions"

const GroupKeyPerfix = "group" //

const HostServiceKey = "host_Service"

const LockKey = "lock"

const PluginKey = "plugin" //

const SEP = "|||"

const StrategiesKey = "strategies" //

const TIMEOUT = 60 * 20

const UnionStrategiesKey = "union_strategies"

Variables

var RedisCluster *redis.Cluster

Functions

func GetDynamicConfigRedis

func GetDynamicConfigRedis() (map[string][]*model.DynamicConfig, error)

从redis中获取hash map

func GetExpressionsFromRedis

func GetExpressionsFromRedis() ([]*model.Expression, error)

从redis中获取hash map

func GetGroupTemplateFromRedis

func GetGroupTemplateFromRedis() (map[int][]int, error)

从redis中获取hash map

func GetHostFromRedis

func GetHostFromRedis() (map[string]int, error)

从redis中获取hash map

func GetHostGroupFromRedis

func GetHostGroupFromRedis() (map[int][]int, error)

从redis中获取hash map

func GetHostServiceFromRedis

func GetHostServiceFromRedis() (map[string]string, error)

从redis中获取hash map

func GetHostTemplateFromRedis

func GetHostTemplateFromRedis() (map[int][]int, error)

从redis中获取hash map

func GetLock

func GetLock(LockKey string, Timeout int64) bool

获取redis分布式锁

func GetMonitoredHostFromRedis

func GetMonitoredHostFromRedis() (map[int]*model.Host, error)

从redis中获取hash map

func GetPluginsFromRedis

func GetPluginsFromRedis() (map[int][]string, error)

从redis中获取hash map

func GetStrategiesFromRedis

func GetStrategiesFromRedis() (map[int]*model.Strategy, error)

从redis中获取hash map

func GetTPLFromRedis

func GetTPLFromRedis() (map[int]*model.Template, error)

从redis中获取hash map

func GetUnionStrategiesFromRedis

func GetUnionStrategiesFromRedis() (map[int][]*model.Strategy, error)

func Init

func Init()

初始化redis集群

func SetDynamicConfig2Redis

func SetDynamicConfig2Redis(m map[string][]*model.DynamicConfig)

设置插件map到redis hash，数量级10，直接设置hash

func SetExpressions2Redis

func SetExpressions2Redis(m []*model.Expression)

设置插件map到redis hash，数量级10，直接设置hash

func SetGroupTemplate2Redis

func SetGroupTemplate2Redis(m map[int][]int)

设置插件map到redis hash，数量级10，直接设置hash

func SetHost2Redis

func SetHost2Redis(m map[string]int)

设置插件map到redis hash，数量级10，直接设置hash

func SetHostGroup2Redis

func SetHostGroup2Redis(m map[int][]int)

设置插件map到redis hash，数量级10，直接设置hash

func SetHostService2Redis

func SetHostService2Redis(m map[string]string)

func SetHostTemplate2Redis

func SetHostTemplate2Redis(m map[int][]int)

func SetMonitoredHost2Redis

func SetMonitoredHost2Redis(m map[int]*model.Host)

设置插件map到redis hash，数量级10，直接设置hash

func SetPlugins2Redis

func SetPlugins2Redis(m map[int][]string)

设置插件map到redis hash，数量级10，直接设置hash

func SetStrategies2Redis

func SetStrategies2Redis(m map[int]*model.Strategy)

设置插件map到redis hash，数量级10，直接设置hash

func SetTPL2Redis

func SetTPL2Redis(m map[int]*model.Template)

func SetUnionStrategies2Redis

func SetUnionStrategies2Redis(m map[int][]*model.Strategy)

func WLock

func WLock(LockKey string, Timeout int64) error

加写锁

func WUnlock

func WUnlock(LockKey string)

解锁