Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
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))
Source Files
Click to show internal directories.
Click to hide internal directories.