sender

Documentation

Overview

Package sender implements the download 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 binary messages and measurement messages coming from |src|. Such 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 Time.Now() + MaxRuntime.