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 DefaultProcCronPeriod + const DefaultSendQueueMaxSize + var SenderConnPools *backend.SafeRpcConnPools + var SenderQueue = nlist.NewSafeListLimited(DefaultSendQueueMaxSize) + var TransferHostnames = make([]string, 0) + var TransferMap = make(map[string]string, 0) + var TransferSendCnt = make(map[string]*nproc.SCounterQps, 0) + var TransferSendFailCnt = make(map[string]*nproc.SCounterQps, 0) + func Push2SendQueue(items []*cmodel.MetaData) + func Start()
Go to main page