worker

package module

Go to main page

Versions in this module

v0

v0.0.8

May 19, 2023

Changes in this version

type Task

+ Result atomic.Value

v0.0.7

May 19, 2023

Changes in this version

+ const Completed

+ const Invalid

+ var ErrInvalidTaskContext = errors.New("invalid task context")

type Service

+ GetCancelledTasks func() <-chan Task

type Task

+ Execute TaskFunc

+ func NewTask(fn TaskFunc, ctx context.Context) (*Task, error)

type TaskManager

+ func (tm *TaskManager) GetCancelledTasks() <-chan Task

+ func (tm *TaskManager) IsEmpty() bool

v0.0.6

May 18, 2023

v0.0.5

May 17, 2023

Changes in this version

type Service

+ StreamResults func() <-chan Result

type Task

+ func (task *Task) ShouldSchedule() error

type TaskManager

+ func NewTaskManagerWithDefaults() *TaskManager

+ func (tm *TaskManager) StreamResults() <-chan Result

v0.0.4

Mar 6, 2023

Changes in this version

+ const DefaultMaxRetries

+ const DefaultMaxTasks

+ const DefaultRetryDelay

+ const DefaultTasksPerSecond

+ const DefaultTimeout

+ const Failed

+ const Queued

+ const Running

+ var ErrTaskAlreadyStarted = errors.New("task already started")

+ var ErrTaskCancelled = errors.New("task cancelled")

+ var ErrTaskCompleted = errors.New("task completed")

+ var ErrTaskTimeout = errors.New("task timeout")

+ type Result struct

+ Error error

+ Result interface{}

+ Task *Task

+ func (r *Result) String() string

type Service

+ CancelAllAndWait func()

+ Close func()

+ GetActiveTasks func() int

+ GetCancelled func() <-chan Task

+ RegisterTasks func(ctx context.Context, tasks ...Task)

+ StartWorkers func()

+ Wait func(timeout time.Duration)

type Task

+ CancelFunc context.CancelFunc

+ Description string

+ Name string

+ Retries int

+ RetryDelay time.Duration

+ Status TaskStatus

+ func (task *Task) CancelledChan() <-chan struct{}

+ func (task *Task) ShouldExecute() error

+ func (task *Task) WaitCancelled()

type TaskManager

+ Cancelled chan Task

+ MaxRetries int

+ MaxTasks int

+ MaxWorkers int

+ RetryDelay time.Duration

+ Tasks chan Task

+ Timeout time.Duration

+ func (tm *TaskManager) CancelAllAndWait()

+ func (tm *TaskManager) Close()

+ func (tm *TaskManager) GetActiveTasks() int

+ func (tm *TaskManager) GetCancelled() <-chan Task

+ func (tm *TaskManager) RegisterTasks(ctx context.Context, tasks ...Task)

+ func (tm *TaskManager) StartWorkers()

+ func (tm *TaskManager) Wait(timeout time.Duration)

+ type TaskStatus uint8

+ func (ts TaskStatus) String() string

v0.0.3

Jan 29, 2023

v0.0.2

Jan 29, 2023

Changes in this version

+ const Cancelled

+ const ContextDeadlineReached

+ const RateLimited

+ var ErrInvalidTaskFunc = errors.New("invalid task function")

+ var ErrInvalidTaskID = errors.New("invalid task id")

+ var ErrTaskNotFound = errors.New("task not found")

+ type CancelReason uint8

type Service

+ ExecuteTask func(id uuid.UUID) (interface{}, error)

type Task

+ CancelReason CancelReason

+ Error atomic.Value

+ func (t *Task) IsValid() (err error)

+ type TaskFunc func() interface

type TaskManager

+ func (tm *TaskManager) ExecuteTask(id uuid.UUID) (interface{}, error)

v0.0.1

Jan 28, 2023

Changes in this version

+ type Middleware func(Service) Service

+ type Service interface

+ CancelAll func()

+ CancelTask func(id uuid.UUID)

+ GetResults func() <-chan interface{}

+ GetTask func(id uuid.UUID) (task Task, ok bool)

+ GetTasks func() []Task

+ RegisterTask func(tasks ...Task)

+ Start func(numWorkers int)

+ Stop func()

+ func NewTaskManager(maxTasks int, limit float64) Service

+ func RegisterMiddleware(svc Service, mw ...Middleware) Service

+ type Task struct

+ Cancel context.CancelFunc

+ Cancelled atomic.Int64

+ Completed atomic.Int64

+ Ctx context.Context

+ Fn func() interface{}

+ ID uuid.UUID

+ Priority int

+ Started atomic.Int64

+ type TaskManager struct

+ Registry sync.Map

+ Results chan interface{}

+ func (tm *TaskManager) CancelAll()

+ func (tm *TaskManager) CancelTask(id uuid.UUID)

+ func (tm *TaskManager) GetResults() <-chan interface{}

+ func (tm *TaskManager) GetTask(id uuid.UUID) (task Task, ok bool)

+ func (tm *TaskManager) GetTasks() []Task

+ func (tm *TaskManager) RegisterTask(tasks ...Task)

+ func (tm *TaskManager) Start(numWorkers int)

+ func (tm *TaskManager) Stop()

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL