Versions in this module Expand all Collapse all v0 v0.1.1 Apr 30, 2024 v0.1.0 Apr 29, 2024 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 RRA10sPointCnt + const RRA180PointCnt + const RRA1hPointCnt + const RRA1mPointCnt + const RRA20PointCnt + const RRA30sPointCnt + const RRA5mPointCnt + const RRA5sPointCnt + 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{}