g

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 EventDto
• type GlobalConfig
  • func Config() *GlobalConfig
• type HttpConfig
• type OrderedEvents
  • func (this OrderedEvents) Len() int
  • func (this OrderedEvents) Less(i, j int) bool
  • func (this OrderedEvents) Swap(i, j int)
• type QueueConfig
• type RedisConfig
• type SafeEvents
  • func (this *SafeEvents) Clone() map[string]*EventDto
  • func (this *SafeEvents) Delete(id string)
  • func (this *SafeEvents) Len() int
  • func (this *SafeEvents) Put(event *model.Event)

Constants

const (
	VERSION = "2.0.2"
)

Variables

var (
	ConfigFile string
)

var Events = &SafeEvents{M: make(map[string]*EventDto)}

var RedisConnPool *redis.Pool

Functions

func InitRedisConnPool

func InitRedisConnPool()

func Link

func Link(event *model.Event) string

func ParseConfig

func ParseConfig(cfg string)

func PingRedis

func PingRedis(c redis.Conn, t time.Time) error

Types

type ApiConfig

type ApiConfig struct {
	Portal string `json:"portal"`
	Uic    string `json:"uic"`
	Links  string `json:"links"`
}

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 GlobalConfig

type GlobalConfig struct {
	Debug    bool         `json:"debug"`
	UicToken string       `json:"uicToken"`
	Http     *HttpConfig  `json:"http"`
	Queue    *QueueConfig `json:"queue"`
	Redis    *RedisConfig `json:"redis"`
	Api      *ApiConfig   `json:"api"`
}

func Config

func Config() *GlobalConfig

type HttpConfig

type HttpConfig struct {
	Enabled bool   `json:"enabled"`
	Listen  string `json:"listen"`
}

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 QueueConfig struct {
	Sms  string `json:"sms"`
	Mail string `json:"mail"`
}

type RedisConfig

type RedisConfig struct {
	Addr          string   `json:"addr"`
	MaxIdle       int      `json:"maxIdle"`
	HighQueues    []string `json:"highQueues"`
	LowQueues     []string `json:"lowQueues"`
	UserSmsQueue  string   `json:"userSmsQueue"`
	UserMailQueue string   `json:"userMailQueue"`
}

type SafeEvents

type SafeEvents struct {
	sync.RWMutex
	M map[string]*EventDto
}

func (*SafeEvents) Clone

func (this *SafeEvents) Clone() map[string]*EventDto

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)