workerpoolv2

type HandleWorkError struct {
	ErrorMessage string
	WorkerID     int
	Data         []interface{}
}

type Pool interface {
}

type WorkConfiguration struct {
	Handler    WorkHandler
	MaxRetries int
	Retriever  WorkRetriever
}

type WorkHandler interface {
	ProcessWork(workerID int, data []interface{}, limiter ratelimit.Limiter) error
}

type WorkItem struct {
	Data    interface{}
	Handler WorkHandler
}

type WorkItemCollection []WorkItem

type WorkRetriever interface {
	RetrieveWork(handler WorkHandler) ([]WorkItem, error)
}

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

type WorkerPoolConfig struct {
	Logger             *logrus.Entry
	NumWorkers         int
	RateLimitPerSecond int
	TickFrequency      time.Duration
}