tasker

package module

Go to main page

Versions in this module

v1

v1.2.0

Jun 30, 2025

Changes in this version

type Config

+ Collector MetricsCollector

+ Logger Logger

+ type Logger interface

+ Debugf func(format string, args ...any)

+ Errorf func(format string, args ...any)

+ Infof func(format string, args ...any)

+ Warnf func(format string, args ...any)

+ type Manager struct

+ func (r *Manager[R, E]) Kill() error

+ func (r *Manager[R, E]) Metrics() TaskMetrics

+ func (r *Manager[R, E]) QueueTask(taskFunc func(R) (E, error)) (E, error)

+ func (r *Manager[R, E]) QueueTaskOnce(taskFunc func(R) (E, error)) (E, error)

+ func (r *Manager[R, E]) QueueTaskWithPriority(taskFunc func(R) (E, error)) (E, error)

+ func (r *Manager[R, E]) QueueTaskWithPriorityOnce(taskFunc func(R) (E, error)) (E, error)

+ func (r *Manager[R, E]) RunTask(taskFunc func(R) (E, error)) (E, error)

+ func (r *Manager[R, E]) Stats() TaskStats

+ func (r *Manager[R, E]) Stop() error

+ type MetricsCollector interface

+ Metrics func() TaskMetrics

+ RecordArrival func()

+ RecordCompletion func(stamps TaskLifecycleTimestamps)

+ RecordFailure func(stamps TaskLifecycleTimestamps)

+ RecordRetry func()

+ func NewCollector() MetricsCollector

+ type TaskLifecycleTimestamps struct

+ FinishedAt time.Time

+ QueuedAt time.Time

+ StartedAt time.Time

type TaskManager

+ func NewTaskManager[R any, E any](config Config[R]) (TaskManager[R, E], error)

+ Metrics func() TaskMetrics

+ type TaskMetrics struct

+ AverageExecutionTime time.Duration

+ AverageWaitTime time.Duration

+ FailureRate float64

+ MaxExecutionTime time.Duration

+ MinExecutionTime time.Duration

+ P95ExecutionTime time.Duration

+ P99ExecutionTime time.Duration

+ SuccessRate float64

+ TaskArrivalRate float64

+ TaskCompletionRate float64

+ TotalTasksCompleted uint64

+ TotalTasksFailed uint64

+ TotalTasksRetried uint64

v1.1.0

Jun 30, 2025

Changes in this version

type Runner

+ func (r *Runner[R, E]) Kill() error

+ func (r *Runner[R, E]) QueueTaskOnce(taskFunc func(R) (E, error)) (E, error)

+ func (r *Runner[R, E]) QueueTaskWithPriorityOnce(taskFunc func(R) (E, error)) (E, error)

type TaskManager

+ Kill func() error

+ QueueTaskOnce func(task func(R) (E, error)) (E, error)

+ QueueTaskWithPriorityOnce func(task func(R) (E, error)) (E, error)

v1.0.0

Jun 14, 2025

Changes in this version

+ type Config struct

+ BurstInterval time.Duration

+ BurstTaskThreshold int

+ BurstWorkerCount int

+ CheckHealth func(error) bool

+ Ctx context.Context

+ MaxRetries int

+ MaxWorkerCount int

+ OnCreate func() (R, error)

+ OnDestroy func(R) error

+ ResourcePoolSize int

+ WorkerCount int

+ type Runner struct

+ func (r *Runner[R, E]) QueueTask(taskFunc func(R) (E, error)) (E, error)

+ func (r *Runner[R, E]) QueueTaskWithPriority(taskFunc func(R) (E, error)) (E, error)

+ func (r *Runner[R, E]) RunTask(taskFunc func(R) (E, error)) (E, error)

+ func (r *Runner[R, E]) Stats() TaskStats

+ func (r *Runner[R, E]) Stop() error

+ type Task struct

+ type TaskManager interface

+ QueueTask func(task func(R) (E, error)) (E, error)

+ QueueTaskWithPriority func(task func(R) (E, error)) (E, error)

+ RunTask func(task func(R) (E, error)) (E, error)

+ Stats func() TaskStats

+ Stop func() error

+ func NewRunner[R any, E any](config Config[R]) (TaskManager[R, E], error)

+ type TaskStats struct

+ ActiveWorkers int32

+ AvailableResources int32

+ BaseWorkers int32

+ BurstWorkers int32

+ PriorityTasks int32

+ QueuedTasks int32

+ type Tasker interface

+ Execute func(ctx context.Context, resource any) (any, error)

Other modules containing this package

github.com/asaidimu/tasker/v2

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