Versions in this module Expand all Collapse all v0 v0.2.1 Aug 15, 2017 v0.2.0 Jun 18, 2017 Changes in this version + const CONN_S_DIAL + const CONN_S_ERR + const FETCH_S_ERR + const FETCH_S_ISNOTEXIST + const FETCH_S_SUCCESS + const IO_TASK_M_FETCH + const IO_TASK_M_FLUSH + const IO_TASK_M_READ + const IO_TASK_M_WRITE + const NET_TASK_M_PULL + const NET_TASK_M_QUERY + const NET_TASK_M_SEND + const QUERY_S_ERR + const QUERY_S_SUCCESS + const RRA180PointCnt + const RRA1PointCnt + const RRA20PointCnt + const RRA5PointCnt + const RRA720PointCnt + const SEND_S_ERR + const SEND_S_SUCCESS + const STAT_SIZE + var Consistent *consistent.Consistent + var Net_task_ch map[string]chan *Net_task_t + var Out_done_chan chan int + func CommitByKey(key string) + func Fetch(filename string, cf string, start, end int64, step int) ([]*cmodel.RRDData, error) + func FlushAll(force bool) + func FlushFile(filename string, items []*cmodel.GraphItem) error + func FlushRRD(idx int, force bool) + func GetCounter() (ret string) + func PullByKey(key string) + func ReadFile(filename string) ([]byte, error) + func Start() + type Net_task_t struct + Args interface{} + Done chan error + Key string + Method int + Reply interface{}