Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func Process ¶
func Process(inputChan <-chan *OrderedInput, wf WorkFunction, options *Options) <-chan *OrderedOutput
Process processes work function based on input. It Accepts an OrderedInput read channel, work function and concurrent go routine pool size. It Returns an OrderedOutput channel.
Types ¶
type OrderedInput ¶
type OrderedInput struct {
Value interface{}
}
OrderedInput input for Processing
type OrderedOutput ¶
type OrderedOutput struct {
Value interface{}
}
OrderedOutput is the output channel type from Process
type WorkFunction ¶
type WorkFunction func(interface{}) interface{}
WorkFunction the function which performs work
Click to show internal directories.
Click to hide internal directories.