Documentation ¶
Index ¶
- func CheckErr(label string, err error)
- func NewStatCounter(label string, interval int) chan int
- func RemovePidFile(filename string) (err error)
- func WorkerAmqpConsumer(worker *Worker, uri string, queue string, msgChan chan string) (err error)
- func WorkerAmqpPublisher(worker *Worker, uri string, exchange string, msgChan chan string, ...) (err error)
- func WorkerStringFilter(worker *Worker, inputChan chan string, outputChan chan string, ...) (err error)
- func WritePidFile(filename string) (pid int, err error)
- type Worker
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewStatCounter ¶
func RemovePidFile ¶
func WorkerAmqpConsumer ¶
func WorkerAmqpPublisher ¶
func WorkerStringFilter ¶
func WritePidFile ¶
Types ¶
Click to show internal directories.
Click to hide internal directories.