Documentation
¶
Index ¶
- Constants
- Variables
- func InitRedisConnPool()
- func Link(event *model.Event) string
- func ParseConfig(cfg string)
- func PingRedis(c redis.Conn, t time.Time) error
- type ApiConfig
- type BossConfig
- type ErrorQueueSt
- type EventDto
- type ExternalQueueSt
- type FalconPortalConfig
- type GlobalConfig
- type HttpConfig
- type OrderedEvents
- type QueueConfig
- type RedisConfig
- type SafeEvents
- type ShortcutConfig
- type UicConfig
Constants ¶
View Source
const (
VERSION = "2.0.2"
)
Variables ¶
View Source
var (
ConfigFile string
)
View Source
var Events = &SafeEvents{M: make(map[string]*EventDto)}
View Source
var RedisConnPool *redis.Pool
Functions ¶
func InitRedisConnPool ¶
func InitRedisConnPool()
func ParseConfig ¶
func ParseConfig(cfg string)
Types ¶
type BossConfig ¶
type ErrorQueueSt ¶
type EventDto ¶
type EventDto struct {
Id string `json:"id"`
Endpoint string `json:"endpoint"`
Metric string `json:"metric"`
Counter string `json:"counter"`
Func string `json:"func"`
LeftValue string `json:"leftValue"`
Operator string `json:"operator"`
RightValue string `json:"rightValue"`
Note string `json:"note"`
MaxStep int `json:"maxStep"`
CurrentStep int `json:"currentStep"`
Priority int `json:"priority"`
Status string `json:"status"`
Timestamp int64 `json:"timestamp"`
ExpressionId int `json:"expressionId"`
StrategyId int `json:"strategyId"`
TemplateId int `json:"templateId"`
Link string `json:"link"`
}
type ExternalQueueSt ¶
type FalconPortalConfig ¶
type GlobalConfig ¶
type GlobalConfig struct {
Debug bool `json:"debug"`
UicToken string `json:"uicToken"`
Http *HttpConfig `json:"http"`
FalconPortal *FalconPortalConfig `json:"falcon_portal"`
BossConfig *BossConfig `json:"boss"`
Queue *QueueConfig `json:"queue"`
Redis *RedisConfig `json:"redis"`
Api *ApiConfig `json:"api"`
Shortcut *ShortcutConfig `json:"shortcut"`
Uic *UicConfig `json:"uic"`
RedirectUrl string `json:"redirectUrl"`
}
func Config ¶
func Config() *GlobalConfig
type HttpConfig ¶
type OrderedEvents ¶
type OrderedEvents []*EventDto
func (OrderedEvents) Len ¶
func (this OrderedEvents) Len() int
func (OrderedEvents) Less ¶
func (this OrderedEvents) Less(i, j int) bool
func (OrderedEvents) Swap ¶
func (this OrderedEvents) Swap(i, j int)
type QueueConfig ¶
type RedisConfig ¶
type RedisConfig struct {
Addr string `json:"addr"`
MaxIdle int `json:"maxIdle"`
HighQueues []string `json:"highQueues"`
LowQueues []string `json:"lowQueues"`
ExternalQueues ExternalQueueSt `json:"externalQueues"`
ErrorQueue ErrorQueueSt `json:"errorQueues"`
UserSmsQueue string `json:"userSmsQueue"`
UserMailQueue string `json:"userMailQueue"`
UserQQQueue string `json:"userQQQueue"`
UserServerchanQueue string `json:"userServerchanQueue"`
}
type SafeEvents ¶
func (*SafeEvents) Clone ¶
func (this *SafeEvents) Clone() map[string]*EventDto
func (*SafeEvents) CloneToOrderedEvents ¶
func (this *SafeEvents) CloneToOrderedEvents() OrderedEvents
func (*SafeEvents) Delete ¶
func (this *SafeEvents) Delete(id string)
func (*SafeEvents) Len ¶
func (this *SafeEvents) Len() int
func (*SafeEvents) Put ¶
func (this *SafeEvents) Put(event *model.Event)
type ShortcutConfig ¶
Click to show internal directories.
Click to hide internal directories.