pipe

package
v1.9.25 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Mar 25, 2021 License: Unlicense Imports: 7 Imported by: 4

Documentation

Index

Constants

This section is empty.

Variables

View Source
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

Types

This section is empty.

Directories

Path Synopsis
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
Package serve receives logg.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 logg.Entry messages on a channel and sends them when it has been told to Run by Consume, and pauses when it is told Pause

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL