collector

func Run(
	gl *config.Global,
	sentC chan tcp.Message,
	rcvdC chan tcp.Message,
	remotes config.RemoteStore,
	currentDSCP *ip.DSCPValue,
	sr metrics.Reporter,
	completeCycleUpload chan bool,
	wg *sync.WaitGroup,
	kill chan struct{},
	logger *log.Logger,
)