g

Documentation

Index

• Constants
• Variables
• func FormRrdCacheKey(md5 string, dsType string, step int) string
• func GetDbConn(connName string) (c *sql.DB, e error)
• func InitDB()
• func IsRrdFileExist(filename string) bool
• func ParseConfig(cfg string)
• func RrdFileName(baseDir string, md5 string, dsType string, step int) string
• func SplitRrdCacheKey(ckey string) (md5 string, dsType string, step int, err error)
• type DBConfig
• type File
• type GlobalConfig
  • func Config() *GlobalConfig
• type HttpConfig
• type RRDConfig
• type RpcConfig

Constants

const (
	VERSION         = "0.5.6"
	GAUGE           = "GAUGE"
	DERIVE          = "DERIVE"
	COUNTER         = "COUNTER"
	CACHE_TIME      = 1800000 //ms
	FLUSH_DISK_STEP = 1000    //ms
	DEFAULT_STEP    = 60      //s
	MIN_STEP        = 30      //s
)

const (
	GRAPH_F_MISS uint32 = 1 << iota
	GRAPH_F_ERR
	GRAPH_F_SENDING
	GRAPH_F_FETCHING
)

const (
	COMMIT = "b7f3164"
)

Variables

var (
	ConfigFile string
)

var DB *sql.DB

Functions

func FormRrdCacheKey

func FormRrdCacheKey(md5 string, dsType string, step int) string

生成rrd缓存数据的key

func GetDbConn

func GetDbConn(connName string) (c *sql.DB, e error)

func InitDB

func InitDB()

func IsRrdFileExist

func IsRrdFileExist(filename string) bool

rrd文件是否存在

func ParseConfig

func ParseConfig(cfg string)

func RrdFileName

func RrdFileName(baseDir string, md5 string, dsType string, step int) string

RRDTOOL UTILS 监控数据对应的rrd文件名称

func SplitRrdCacheKey

func SplitRrdCacheKey(ckey string) (md5 string, dsType string, step int, err error)

Types

type DBConfig

type DBConfig struct {
	Dsn     string `json:"dsn"`
	MaxIdle int    `json:"maxIdle"`
}

type File

type File struct {
	Filename string
	Body     []byte
}

type GlobalConfig

type GlobalConfig struct {
	Pid         string      `json:"pid"`
	Debug       bool        `json:"debug"`
	Http        *HttpConfig `json:"http"`
	Rpc         *RpcConfig  `json:"rpc"`
	RRD         *RRDConfig  `json:"rrd"`
	DB          *DBConfig   `json:"db"`
	CallTimeout int32       `json:"callTimeout"`
	Migrate     struct {
		Concurrency int               `json:"concurrency"` //number of multiple worker per node
		Enabled     bool              `json:"enabled"`
		Replicas    int               `json:"replicas"`
		Cluster     map[string]string `json:"cluster"`
	} `json:"migrate"`
}

func Config

func Config() *GlobalConfig

type HttpConfig

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

type RRDConfig

type RRDConfig struct {
	Storage string `json:"storage"`
}

type RpcConfig

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