pipe

package

v0.0.0-...-fb1def1 Latest Latest Go to latest Published: Apr 1, 2021 License: Unlicense Imports: 8 Imported by: 0

Details

This section is empty.

View Source

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

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(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

This section is empty.

Path	Synopsis
consume Package consume turns off and on the Serve logging messages and provides a way to receive and process the log messages	Package consume turns off and on the Serve logging messages and provides a way to receive and process the log messages
example
serve
serve Package serve receives log.Entry messages on a channel and sends them when it has been told to Run by Consume, and pauses when it is told Pause	Package serve receives log.Entry messages on a channel and sends them when it has been told to Run by Consume, and pauses when it is told Pause
stdconn
example
example/hello
example/hello/hello
worker