sender

Documentation

Index

• Constants
• Variables
• func Push2SendQueue(items []*cmodel.MetaData)
• func Start()

Constants

const (
	DefaultProcCronPeriod = time.Duration(5) * time.Second //ProcCron的周期,默认1s
)

const (
	DefaultSendQueueMaxSize = 1024000 //102.4w
)

Variables

var (
	SenderQueue     = nlist.NewSafeListLimited(DefaultSendQueueMaxSize)
	SenderConnPools *backend.SafeRpcConnPools

	TransferMap         = make(map[string]string, 0)
	TransferHostnames   = make([]string, 0)
	TransferSendCnt     = make(map[string]*nproc.SCounterQps, 0)
	TransferSendFailCnt = make(map[string]*nproc.SCounterQps, 0)
)

Functions

func Push2SendQueue

func Push2SendQueue(items []*cmodel.MetaData)

func Start

func Start()