Documentation
¶
Index ¶
- Constants
- func Errors() (chan<- error, *sync.WaitGroup)
- func IDs(db *badger.DB, newProto NewProto, ids []uint, errs chan<- error) <-chan proto.Message
- func NewProtoWork() chan proto.Message
- func RunProto(parallel int, job Proto, work <-chan proto.Message, errs chan<- error) *sync.WaitGroup
- type NewProto
- type Page
- type Proto
- type Run
- type Runner
Constants ¶
View Source
const WorkBuffer = 1000
Variables ¶
This section is empty.
Functions ¶
func Errors ¶
Errors creates an input for errors to print and a bool of whether any errors have been printed.
Calls Done on the WaitGroup once the channel has been closed and all errors have been printed.
The returned channel must be closed before the WaitGroup is waited upon.
func NewProtoWork ¶
Types ¶
Click to show internal directories.
Click to hide internal directories.