Documentation
¶
Index ¶
Constants ¶
View Source
const (
DefaultProcCronPeriod = time.Duration(10) * time.Second //ProcCron的周期,默认1s
)
View Source
const (
DefaultSendQueueMaxSize = 102400 //10.24w
)
View Source
const (
DefaultSendTaskSleepInterval = time.Millisecond * 50 //默认睡眠间隔为50ms
)
send
Variables ¶
View Source
var (
InfluxdbConnPools *cpool.InfluxdbConnPoolHelper
)
连接池 node_address -> connection_pool
View Source
var (
InfluxdbQueues = make(map[string]*nlist.SafeListLimited)
)
发送缓存队列 node -> queue_of_data
Functions ¶
func DestroyConnPools ¶
func DestroyConnPools()
func Push2TsdbSendQueue ¶
将数据 打入所有的Tsdb的发送缓存队列, 相互备份
Types ¶
This section is empty.
Source Files
¶
Directories
Click to show internal directories.
Click to hide internal directories.