taskqueue

type Interface interface {
	QueueController
	// AddTask adds a task to the tasks queue and increase wg counter
	// returns true if the task is added and false if it is skipped
	// (e.g. if the TaskQueue is stopped or failFast situation)
	AddTask(task interface{}) bool
}

type QueueController interface {
	// Start initializes worker's goroutines. The provided context ctx is used by worker goroutines
	Start(ctx context.Context)
	// Stop stops the worker's goroutines, it could be triggered internally on context cancellation or failFast situation
	Stop()
	// GetErrorList returns the errors, occurred during task processing
	GetErrorList() *multierror.Error
	// Name used when logging information
	Name() string
	// GetProcessedTasksCount returns the processed tasks count
	GetProcessedTasksCount() int
	// GetWaitingTasksCount returns waiting tasks count
	GetWaitingTasksCount() int
}

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

type WorkerFunc func(ctx context.Context, task interface{}) error