utils

Documentation

Index

• type JobResult
• type WorkerPool
  • func NewWorkerPool(workers int, jobBuffer int, ...) WorkerPool
  • func (wp *WorkerPool) AddJob(job interface{})
  • func (wp *WorkerPool) Start(ctx context.Context)
  • func (wp *WorkerPool) Stop()

Types

type JobResult

type JobResult struct {
	Logs         string
	Error        error
	Job          interface{}
	ReturnValues interface{}
}

type WorkerPool

type WorkerPool struct {
	ResultChan chan JobResult
	// contains filtered or unexported fields
}

func NewWorkerPool

func NewWorkerPool(workers int, jobBuffer int,
	work func(context.Context, *log.Logger, interface{}) (interface{}, error), debug bool) WorkerPool

func (*WorkerPool) AddJob

func (wp *WorkerPool) AddJob(job interface{})

func (*WorkerPool) Start

func (wp *WorkerPool) Start(ctx context.Context)

func (*WorkerPool) Stop

func (wp *WorkerPool) Stop()