workerPool

Documentation

Index

• type WorkerPool
  • func NewWorkerPool[T any](maxWorkers int, serviceName constants.ServiceName, logger *zap.SugaredLogger) *WorkerPool[T]
  • func (wp *WorkerPool[_]) Error() error
  • func (wp *WorkerPool[T]) GetResponse() []T
  • func (wp *WorkerPool[T]) IncludeZeroValue() *WorkerPool[T]
  • func (wp *WorkerPool[T]) InitializeResponse() *WorkerPool[T]
  • func (wp *WorkerPool[_]) StopWait() error
  • func (wp *WorkerPool[T]) Submit(task func() (T, error))

Types

type WorkerPool

type WorkerPool[T any] struct {
	// contains filtered or unexported fields
}

func NewWorkerPool

func NewWorkerPool[T any](maxWorkers int, serviceName constants.ServiceName, logger *zap.SugaredLogger) *WorkerPool[T]

func (*WorkerPool[_]) Error

func (wp *WorkerPool[_]) Error() error

func (*WorkerPool[T]) GetResponse

func (wp *WorkerPool[T]) GetResponse() []T

func (*WorkerPool[T]) IncludeZeroValue

func (wp *WorkerPool[T]) IncludeZeroValue() *WorkerPool[T]

func (*WorkerPool[T]) InitializeResponse

func (wp *WorkerPool[T]) InitializeResponse() *WorkerPool[T]

func (*WorkerPool[_]) StopWait

func (wp *WorkerPool[_]) StopWait() error

func (*WorkerPool[T]) Submit

func (wp *WorkerPool[T]) Submit(task func() (T, error))