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 DefaultLogCronPeriod + const DefaultProcCronPeriod + const DefaultSendQueueMaxSize + const DefaultSendTaskSleepInterval + var TransferConnPools *backend.SafeRpcConnPools + var TransferHostnames = make([]string, 0) + var TransferMap = make(map[string]string, 0) + var TransferQueue *nlist.SafeListLimited + var TrendConnPools *backend.SafeRpcConnPools + var TrendNodeRing *rings.ConsistentHashNodeRing + var TrendQueues = make(map[string]*nlist.SafeListLimited) + func DestroyConnPools() + func Push2TransferSendQueue(item *model.TrendItem) + func Push2TrendSendQueue(val string) + func Start()
Go to main page