pipe

Documentation

Index

• Variables
• func Consume(quit qu.C, handler func([]byte) error, args ...string) *worker.Worker
• func Serve(quit qu.C, handler func([]byte) error) *stdconn.StdConn

Variables

var F, E, W, I, D, T logg.LevelPrinter = logg.GetLogPrinterSet(subsystem)

Functions

func Consume

func Consume(quit qu.C, handler func([]byte) error, args ...string) *worker.Worker

Consume listens for messages from a child process over a stdio pipe.

func Serve

func Serve(quit qu.C, handler func([]byte) error) *stdconn.StdConn

Serve runs a goroutine processing the FEC encoded packets, gathering them and decoding them to be delivered to a handler function