sender

Documentation

Overview

Package sender implements the upload sender.

Index

• func Start(conn *websocket.Conn, src <-chan model.Measurement) <-chan model.Measurement

Functions

func Start

func Start(conn *websocket.Conn, src <-chan model.Measurement) <-chan model.Measurement

Start starts the sender in a background goroutine. The sender will send to the client the measurement messages coming from |src|. These messages will also be emitted to the returned channel.

Liveness guarantee: the sender will not be stuck sending for more then the MaxRuntime of the subtest, provided that the consumer will continue reading from the returned channel. This is enforced by setting the write deadline to MaxRuntime + time.Now.