collector

Documentation

Index

• func Run(gl *config.Global, sentC chan tcp.Message, rcvdC chan tcp.Message, ...)

Functions

func Run

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

Run processes the echoes sent and received to compute and report all the metrics desired.