g

package
v0.0.0-...-47734ed Latest Latest
Warning

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

Go to latest
Published: Apr 7, 2016 License: Apache-2.0 Imports: 12 Imported by: 0

Documentation

Index

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 Link(event *model.Event) string

func ParseConfig

func ParseConfig(cfg string)

func PingRedis

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

func ReadCacheFromFile

func ReadCacheFromFile()

func SaveCacheToFile

func SaveCacheToFile()

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"`
	ActionId     int `json:"actionId"`

	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"`
	SaveFile string       `json:"savefile"`
}

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

func (this *SafeEvents) Init(m map[string]*EventDto)

func (*SafeEvents) Len

func (this *SafeEvents) Len() int

func (*SafeEvents) Put

func (this *SafeEvents) Put(event *model.Event)

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL