measurer

Documentation

Overview

Package measurer collects metrics from a socket connection and returns them for consumption.

Index

• func Start(ctx context.Context, conn *websocket.Conn, UUID string) <-chan model.Measurement

Functions

func Start

func Start(
	ctx context.Context, conn *websocket.Conn, UUID string,
) <-chan model.Measurement

Start runs the measurement loop in a background goroutine and emits the measurements on the returned channel.

Liveness guarantee: the measurer will always terminate after a timeout of DefaultRuntime seconds, provided that the consumer continues reading from the returned channel.