Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type WorkerPond ¶
type WorkerPond struct {
// contains filtered or unexported fields
}
WorkerPond Worker wrapper for Pond API
func (*WorkerPond) Callback ¶
func (w *WorkerPond) Callback(cb func(interface{}))
Callback set function to process data
func (*WorkerPond) CallbackOnError ¶
func (w *WorkerPond) CallbackOnError(cb func(interface{}))
CallbackOnError set function to process error data
func (*WorkerPond) Init ¶
func (w *WorkerPond) Init(worker, bufferedTask int, options ...pond.Option)
Init function to init pond API
func (*WorkerPond) Submit ¶
func (w *WorkerPond) Submit(params ...interface{})
Submit function to submit parameter
Source Files
Click to show internal directories.
Click to hide internal directories.