Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Worker ¶
type Worker struct {
// contains filtered or unexported fields
}
func NewWorker ¶
func NewWorker(f WorkerFunc, opts ...WorkerOption) (*Worker, error)
func (*Worker) AddParallelism ¶
func (*Worker) SetLoopCount ¶
func (*Worker) SetParallelism ¶
type WorkerFunc ¶
type WorkerOption ¶
func WithInfinityLoop ¶
func WithInfinityLoop() WorkerOption
func WithLoopCount ¶
func WithLoopCount(count int32) WorkerOption
func WithMaxParallelism ¶
func WithMaxParallelism(parallelism int32) WorkerOption
func WithUnlimitedParallelism ¶
func WithUnlimitedParallelism() WorkerOption
Click to show internal directories.
Click to hide internal directories.