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 DefaultLogCronPeriod + const DefaultProcCronPeriod + const DefaultSendQueueMaxSize + const DefaultSendTaskSleepInterval + var GraphConnPools *backend.SafeRpcConnPools + var GraphNodeRing *rings.ConsistentHashNodeRing + var GraphQueues = make(map[string]*nlist.SafeListLimited) + var JudgeConnPools *backend.SafeRpcConnPools + var JudgeNodeRing *rings.ConsistentHashNodeRing + var JudgeQueues = make(map[string]*nlist.SafeListLimited) + var MinStep int + var TsdbConnPoolHelper *backend.TsdbConnPoolHelper + var TsdbQueue *nlist.SafeListLimited + func DestroyConnPools() + func Push2GraphSendQueue(items []*cmodel.MetaData) + func Push2JudgeSendQueue(items []*cmodel.MetaData) + func Push2TsdbSendQueue(items []*cmodel.MetaData) + func Start()
Go to main page