func batchWorker()

in collector/collector.go [245:256]

• 12 lines of code
• 1 McCabe index (conditional complexity)

func batchWorker(
	gl *config.Global,
	sentC chan tcp.Message,
	rcvdC chan tcp.Message,
	remotes config.RemoteStore,
	ms messageStore,
	rs resultStore,
	currentDSCP *ip.DSCPValue,
	sfn statsUploader,
	sr metrics.Reporter,
	completeCycleUpload chan bool,
	kill chan struct{},