proletarian

type PoolConfig struct {
	// LobbbySize sets size of input queue, default value is 0
	LobbySize int

	// Size sets size of workers, default value is 1, it is normalized to range [1 .. runtime.GOMAXPROCS(0) * 32]
	Size int

	// Retries limits number of retries for every task. Set this value to something bigger than 0
	Retries int

	// Func is function that will be executed in every worker
	Func func(t Task) error
}

type Pooler interface {
	// Run triggers start of the pool. Must be called only once, can be called without creating new goroutine.
	Run()

	// Queue puts new task in input queue.
	Queue(t Task)

	// Shutdown gracefully stops pool, waiting for all task will be finished (successfully or errored after retries). The pool must not be used after Shutdown
	Shutdown()

	// Cancel stops pool ungracefully. The pool must not be used after Cancel
	Cancel()

	// ErroredTask returns task with error. It waits while such task appears and returns the task or nil if pool was shut down and no more errored task available.
	ErroredTask() Task

	// Wait holds execution and waits until all tasks pool execution queue will be empty
	Wait()
}

type Task interface {
	// SetError sets error and increase error counter if err != nil
	SetError(error)
	// ErrorCount returns number of errors for the task
	ErrorCount() int

	// Err returns last error set by SetError
	Err() error

	// Unwrap is same as Err and returns last error set by SetError
	Unwrap() error
}

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