taskworker

Documentation

Index

• Variables
• type Result
• type SingleTaskWorker
  • func NewSingleTaskWorker(ctx context.Context, maxConcurrency uint8, work SingleWork, total int) *SingleTaskWorker
  • func (t *SingleTaskWorker) Do(input interface{})
  • func (t *SingleTaskWorker) Results() []Result
• type SingleWork
• type TaskWorker
  • func NewTaskWorker(maxConcurrency uint8) *TaskWorker
  • func (t *TaskWorker) Register(work Work)
  • func (t *TaskWorker) Run(ctx context.Context) []Result
• type Work

Variables

var ErrornvalidObject = errors.New("InvalidObject")

Types

type Result

type Result struct {
	Result interface{}
	Err    error
}

type SingleTaskWorker

type SingleTaskWorker struct {
	// contains filtered or unexported fields
}

func NewSingleTaskWorker

func NewSingleTaskWorker(ctx context.Context, maxConcurrency uint8, work SingleWork, total int) *SingleTaskWorker

func (*SingleTaskWorker) Do

func (t *SingleTaskWorker) Do(input interface{})

func (*SingleTaskWorker) Results

func (t *SingleTaskWorker) Results() []Result

type SingleWork

type SingleWork func(ctx context.Context, input interface{}) (interface{}, error)

type TaskWorker

type TaskWorker struct {
	// contains filtered or unexported fields
}

func NewTaskWorker

func NewTaskWorker(maxConcurrency uint8) *TaskWorker

func (*TaskWorker) Register

func (t *TaskWorker) Register(work Work)

func (*TaskWorker) Run

func (t *TaskWorker) Run(ctx context.Context) []Result

type Work

type Work func(ctx context.Context) (interface{}, error)