Documentation
¶
Overview ¶
Package sender implements the upload sender.
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
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.
Types ¶
This section is empty.
Click to show internal directories.
Click to hide internal directories.