Versions in this module Expand all Collapse all v2 v2.0.0 Apr 26, 2022 Changes in this version + type PipelinePool struct + func NewPipelinePool(pipeline chan interfaces.Worker, logger interfaces.Logger) *PipelinePool + func (p *PipelinePool) AddTask(task interfaces.Task) (err error) + func (p *PipelinePool) AddWorker(worker interfaces.Worker) (err error) + func (p *PipelinePool) Close() (err error) + type PipelineWorker struct + func NewPipelineWorker(pipeline chan<- interfaces.Worker) *PipelineWorker + func (w *PipelineWorker) Close() (err error) + func (w *PipelineWorker) Do(task interfaces.Task) (err error) + type StickyPool struct + func NewStickyPool(logger interfaces.Logger) *StickyPool + func (p *StickyPool) AddTask(task interfaces.Task) (err error) + func (p *StickyPool) AddWorker(worker interfaces.Worker) (err error) + func (p *StickyPool) Close() (err error) + type Worker struct + func NewWorker(buffSize int) *Worker + func (w *Worker) Close() error + func (w *Worker) Do(task interfaces.Task) (err error) + type ZerologAdapter struct + func NewZerologAdapter(logger zerolog.Logger) *ZerologAdapter + func (l ZerologAdapter) Errorf(err error, msg string, args ...interface{}) + func (l ZerologAdapter) Infof(msg string, args ...interface{}) Other modules containing this package github.com/egnd/go-wpool