tasker

README

tasker

A handy tool for streaming perform many tasks

Disclaimer

This library is just a prototype at the moment. It's not ready for you to use. ... work in progress.

Dependencies

NONE

Install

go get gopkg.in/webnice/tasker.v1

Example

Documentation

Index

• type BootstrapFunc
• type Tasker
  • func NewTasker() Tasker
• type WorkerFunc

Types

type BootstrapFunc

type BootstrapFunc func([]interface{}) error

BootstrapFunc Тип функции которая будет запущена до начала выполнения задач

type Tasker

type Tasker interface {
	AddTasks(tasks []interface{}) error // Добавление среза объектов задач в очередь выполнения
	AddTask(task interface{}) error     // Добавление одного объектов задач в очередь выполнения
	Bootstrap(BootstrapFunc) Tasker     // Установка функции которая будет запущена до начала выполнения задач
	Concurrent(int) Tasker              // Concurrent Number of concurent task
	Clean() Tasker                      // Очистка всех задач в очереди за исключением выполняющихся в текущее время
	Error() error                       // Последняя возникшая ошибка
	GetTasksNumber() int                // Возвращает количество не завершенных задач (ожидающих выполнения или еще выполняющихся)
	Interrupt() Tasker                  // Прерывания выполнения задач. Новые задачи перестают запускаться на выполнение, уже запущенные задачи будут выполнены
	IsWork() bool                       // =true - tasker выполняет задачи, =false - tasker закончил выполнение всех задач, все goroutines навершены
	Run() Tasker                        // Запуск выполнения задач без ожидания, функция возвращает выполнение после запуска контроллера задач в отдельном процессе
	RetryIfError(int) Tasker            // Повторить запуск задачи если Worker вернул ошибку, но не более N раз. По умолчанию не повторять
	Worker(WorkerFunc) Tasker           // Установка функции обрабатывающей задачи
	Wait() Tasker                       // Ожидание окончания выполнения всех задач, функция блокируется до окончания выполнени всех задач
}

Tasker is an interface

func NewTasker

func NewTasker() Tasker

NewTasker Function create new tasker implementation

type WorkerFunc

type WorkerFunc func(interface{}) error

WorkerFunc Тип функции выполняющей задачу