worker

Documentation

Index

• type Worker
  • func NewWorker(f WorkerFunc, opts ...WorkerOption) (*Worker, error)
  • func (w *Worker) AddParallelism(parallelism int32)
  • func (w *Worker) Process(ctx context.Context)
  • func (w *Worker) SetLoopCount(count int32)
  • func (w *Worker) SetParallelism(parallelism int32)
  • func (w *Worker) Wait()
• type WorkerFunc
• type WorkerOption
  • func WithInfinityLoop() WorkerOption
  • func WithLoopCount(count int32) WorkerOption
  • func WithMaxParallelism(parallelism int32) WorkerOption
  • func WithUnlimitedParallelism() WorkerOption

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 (w *Worker) AddParallelism(parallelism int32)

func (*Worker) Process

func (w *Worker) Process(ctx context.Context)

func (*Worker) SetLoopCount

func (w *Worker) SetLoopCount(count int32)

func (*Worker) SetParallelism

func (w *Worker) SetParallelism(parallelism int32)

func (*Worker) Wait

func (w *Worker) Wait()

type WorkerFunc

type WorkerFunc func(context.Context, int)

type WorkerOption

type WorkerOption func(*Worker) error

func WithInfinityLoop

func WithInfinityLoop() WorkerOption

func WithLoopCount

func WithLoopCount(count int32) WorkerOption

func WithMaxParallelism

func WithMaxParallelism(parallelism int32) WorkerOption

func WithUnlimitedParallelism

func WithUnlimitedParallelism() WorkerOption