Documentation ¶
Overview ¶
Package collect implements fan-in from local plugin programs.
Index ¶
Constants ¶
View Source
const ( // MaxQueue limits the number of points queued in a Pool. MaxQueue = 10000 // MaxProc limits the number of processes running in parallel. MaxProc = 128 )
Variables ¶
View Source
var Debug *log.Logger
Functions ¶
This section is empty.
Types ¶
type Pool ¶
Pool represents a pool of plugin processes.
func NewPool ¶
NewPool creates a pool of plugin processes corresponding to programs held in the given directory. Pool automatically starts/terminates processes in response to directory events.
The pool has bounded process count, see MaxProc. An attempt to create additional process is logged and ignored.
Click to show internal directories.
Click to hide internal directories.