taskflow

Mar 28, 2025

Changes in this version

type Config

+ DbName string

Mar 8, 2025

Changes in this version

+ type AdvancedJob interface

+ BackoffTime func() time.Duration

+ JobTimeout func() time.Duration

+ RetryCount func() uint

+ Run func(jr JobRecord) (any, error)

+ type AdvancedJobConstructor func() (AdvancedJob, error)

+ type Config struct

+ BackoffTime time.Duration

+ DB *sql.DB

+ ErrorLog func(ev LogEvent)

+ InfoLog func(ev LogEvent)

+ JobTimeout time.Duration

+ PollInterval time.Duration

+ RetryCount uint

+ type JobHandler func(jr JobRecord) (any, error)

+ type JobRecord struct

+ AvailableAt *time.Time

+ CreatedAt time.Time

+ ID uint64

+ LockedBy *string

+ LockedUntil *time.Time

+ Operation Operation

+ Output any

+ RetryCount uint

+ Status JobStatus

+ UpdatedAt time.Time

+ func (jr *JobRecord) GetPayload(input any) error

+ type JobStatus string

+ const JobCompleted

+ const JobFailed

+ const JobInProgress

+ const JobPending

+ type LogEvent struct

+ Duration *time.Duration

+ Err error

+ JobID *uint64

+ Message string

+ Operation *string

+ WorkerID string

+ type Manager struct

+ func (m *Manager) Shutdown(timeout time.Duration)

+ type Operation string

+ type TaskFlow struct

+ func New(cfg Config) *TaskFlow

+ func (tf *TaskFlow) CreateJob(ctx context.Context, operation Operation, payload any, executeAt time.Time) (int64, error)

+ func (tf *TaskFlow) RegisterAdvancedHandler(op Operation, constructor func() AdvancedJob)

+ func (tf *TaskFlow) RegisterHandler(op Operation, handler JobHandler)

+ func (tf *TaskFlow) Shutdown(timeout time.Duration)

+ func (tf *TaskFlow) StartWorkers(ctx context.Context, count int)

+ type Worker struct

+ func (w *Worker) Run(ctx context.Context)

+ type WorkerStatus int

+ const WorkerBusy

+ const WorkerExecFailed

+ const WorkerFailing

+ const WorkerIdle