taskstore

Jun 21, 2026

Changes in this version

type ScheduleInterface

+ GetCreatedAtCarbon func() *carbon.Carbon

+ GetSoftDeletedAtCarbon func() *carbon.Carbon

+ GetUpdatedAtCarbon func() *carbon.Carbon

type TaskDefinitionInterface

+ GetCreatedAtCarbon func() *carbon.Carbon

+ GetSoftDeletedAtCarbon func() *carbon.Carbon

+ GetUpdatedAtCarbon func() *carbon.Carbon

type TaskQueueInterface

+ GetCompletedAtCarbon func() *carbon.Carbon

+ GetCreatedAtCarbon func() *carbon.Carbon

+ GetSoftDeletedAtCarbon func() *carbon.Carbon

+ GetStartedAtCarbon func() *carbon.Carbon

+ GetUpdatedAtCarbon func() *carbon.Carbon

Jun 21, 2026

Changes in this version

+ const MAX_DATE

+ const NULL_DATE

Jun 18, 2026

Changes in this version

+ const MAX_DATETIME

+ const NULL_DATETIME

type ScheduleInterface

+ CreatedAtCarbon func() *carbon.Carbon

+ SoftDeletedAtCarbon func() *carbon.Carbon

+ UpdatedAtCarbon func() *carbon.Carbon

type Store

+ func (st *Store) GetDB() *sql.DB

+ func (store *Store) GetTaskDefinitionAliasByID(ctx context.Context, id string) string

May 19, 2026

Changes in this version

type Store

+ func (st *Store) GetScheduleTableName() string

+ func (st *Store) GetTaskDefinitionTableName() string

+ func (st *Store) GetTaskQueueTableName() string

+ func (st *Store) MigrateDown(tx ...*sql.Tx) error

+ func (st *Store) MigrateUp(tx ...*sql.Tx) error

+ func (st *Store) SetScheduleTableName(tableName string)

+ func (st *Store) SetTaskDefinitionTableName(tableName string)

+ func (st *Store) SetTaskQueueTableName(tableName string)

+ func (st *Store) SqlDropScheduleTable() (string, error)

+ func (st *Store) SqlDropTaskDefinitionTable() (string, error)

+ func (st *Store) SqlDropTaskQueueTable() (string, error)

type StoreInterface

+ GetScheduleTableName func() string

+ GetTaskDefinitionTableName func() string

+ GetTaskQueueTableName func() string

+ MigrateDown func(tx ...*sql.Tx) error

+ MigrateUp func(tx ...*sql.Tx) error

+ SetScheduleTableName func(tableName string)

+ SetTaskDefinitionTableName func(tableName string)

+ SetTaskQueueTableName func(tableName string)

Dec 9, 2025

Changes in this version

type ScheduleInterface

+ GetCreatedAt func() string

+ GetDescription func() string

+ GetEndAt func() string

+ GetExecutionCount func() int

+ GetID func() string

+ GetLastRunAt func() string

+ GetMaxExecutionCount func() int

+ GetName func() string

+ GetNextRunAt func() string

+ GetQueueName func() string

+ GetRecurrenceRule func() RecurrenceRuleInterface

+ GetSoftDeletedAt func() string

+ GetStartAt func() string

+ GetStatus func() string

+ GetTaskDefinitionID func() string

+ GetTaskParameters func() map[string]any

+ GetUpdatedAt func() string

+ type TaskDefinitionHandlerBase struct

+ func (handler *TaskDefinitionHandlerBase) ErrorMessage() string

+ func (handler *TaskDefinitionHandlerBase) GetLastErrorMessage() string

+ func (handler *TaskDefinitionHandlerBase) GetLastInfoMessage() string

+ func (handler *TaskDefinitionHandlerBase) GetLastSuccessMessage() string

+ func (handler *TaskDefinitionHandlerBase) GetOptions() map[string]string

+ func (handler *TaskDefinitionHandlerBase) GetOutput() string

+ func (handler *TaskDefinitionHandlerBase) GetParam(paramName string) string

+ func (handler *TaskDefinitionHandlerBase) GetParamArray(paramName string) []string

+ func (handler *TaskDefinitionHandlerBase) GetQueuedTask() TaskQueueInterface

+ func (handler *TaskDefinitionHandlerBase) HasQueuedTask() bool

+ func (handler *TaskDefinitionHandlerBase) InfoMessage() string

+ func (handler *TaskDefinitionHandlerBase) LastErrorMessage() string

+ func (handler *TaskDefinitionHandlerBase) LastInfoMessage() string

+ func (handler *TaskDefinitionHandlerBase) LastSuccessMessage() string

+ func (handler *TaskDefinitionHandlerBase) LogError(message string)

+ func (handler *TaskDefinitionHandlerBase) LogInfo(message string)

+ func (handler *TaskDefinitionHandlerBase) LogSuccess(message string)

+ func (handler *TaskDefinitionHandlerBase) Options() map[string]string

+ func (handler *TaskDefinitionHandlerBase) QueuedTask() TaskQueueInterface

+ func (handler *TaskDefinitionHandlerBase) SetOptions(options map[string]string)

+ func (handler *TaskDefinitionHandlerBase) SetOutput(output string)

+ func (handler *TaskDefinitionHandlerBase) SetQueuedTask(queuedTask TaskQueueInterface)

+ func (handler *TaskDefinitionHandlerBase) SuccessMessage() string

+ type TaskDefinitionHandlerInterface interface

+ Alias func() string

+ Description func() string

+ GetLastErrorMessage func() string

+ GetLastInfoMessage func() string

+ GetLastSuccessMessage func() string

+ GetOptions func() map[string]string

+ GetOutput func() string

+ GetParam func(paramName string) string

+ GetParamArray func(paramName string) []string

+ GetQueuedTask func() TaskQueueInterface

+ Handle func() bool

+ HasQueuedTask func() bool

+ LogError func(message string)

+ LogInfo func(message string)

+ LogSuccess func(message string)

+ SetOptions func(options map[string]string)

+ SetOutput func(output string)

+ SetQueuedTask func(queuedTask TaskQueueInterface)

+ Title func() string

type TaskDefinitionInterface

+ GetAlias func() string

+ GetCreatedAt func() string

+ GetDescription func() string

+ GetID func() string

+ GetIsRecurring func() int

+ GetMemo func() string

+ GetRecurrenceRule func() string

+ GetSoftDeletedAt func() string

+ GetStatus func() string

+ GetTitle func() string

+ GetUpdatedAt func() string

type TaskQueueInterface

+ GetAttempts func() int

+ GetCompletedAt func() string

+ GetCreatedAt func() string

+ GetDetails func() string

+ GetID func() string

+ GetOutput func() string

+ GetParameters func() string

+ GetQueueName func() string

+ GetSoftDeletedAt func() string

+ GetStartedAt func() string

+ GetStatus func() string

+ GetTaskID func() string

+ GetUpdatedAt func() string

Nov 26, 2025

Changes in this version

type TaskQueueRunnerOptions

+ MaxConcurrency int

Nov 25, 2025

Changes in this version

+ const COLUMN_END_AT

+ const COLUMN_EXECUTION_COUNT

+ const COLUMN_LAST_RUN_AT

+ const COLUMN_MAX_EXECUTION_COUNT

+ const COLUMN_NAME

+ const COLUMN_NEXT_RUN_AT

+ const COLUMN_START_AT

+ const COLUMN_TASK_DEFINITION_ID

type NewStoreOptions

+ ScheduleTableName string

type ScheduleInterface

+ func NewSchedule() ScheduleInterface

+ CreatedAt func() string

+ Description func() string

+ EndAt func() string

+ ExecutionCount func() int

+ GetNextOccurrence func() (string, error)

+ HasReachedEndDate func() bool

+ HasReachedMaxExecutions func() bool

+ ID func() string

+ IncrementExecutionCount func() ScheduleInterface

+ IsDue func() bool

+ LastRunAt func() string

+ MaxExecutionCount func() int

+ Name func() string

+ NextRunAt func() string

+ QueueName func() string

+ RecurrenceRule func() RecurrenceRuleInterface

+ SetCreatedAt func(string) ScheduleInterface

+ SetDescription func(string) ScheduleInterface

+ SetEndAt func(string) ScheduleInterface

+ SetExecutionCount func(int) ScheduleInterface

+ SetID func(string) ScheduleInterface

+ SetLastRunAt func(string) ScheduleInterface

+ SetMaxExecutionCount func(int) ScheduleInterface

+ SetName func(string) ScheduleInterface

+ SetNextRunAt func(string) ScheduleInterface

+ SetQueueName func(string) ScheduleInterface

+ SetRecurrenceRule func(RecurrenceRuleInterface) ScheduleInterface

+ SetSoftDeletedAt func(string) ScheduleInterface

+ SetStartAt func(string) ScheduleInterface

+ SetStatus func(string) ScheduleInterface

+ SetTaskDefinitionID func(string) ScheduleInterface

+ SetTaskParameters func(map[string]any) ScheduleInterface

+ SetUpdatedAt func(string) ScheduleInterface

+ SoftDeletedAt func() string

+ StartAt func() string

+ Status func() string

+ TaskDefinitionID func() string

+ TaskParameters func() map[string]any

+ UpdateLastRunAt func() ScheduleInterface

+ UpdateNextRunAt func() ScheduleInterface

+ UpdatedAt func() string

+ type ScheduleQuery struct

+ func (q *ScheduleQuery) ID() string

+ func (q *ScheduleQuery) Limit() int

+ func (q *ScheduleQuery) Name() string

+ func (q *ScheduleQuery) Offset() int

+ func (q *ScheduleQuery) QueueName() string

+ func (q *ScheduleQuery) SetID(id string) ScheduleQueryInterface

+ func (q *ScheduleQuery) SetLimit(limit int) ScheduleQueryInterface

+ func (q *ScheduleQuery) SetName(name string) ScheduleQueryInterface

+ func (q *ScheduleQuery) SetOffset(offset int) ScheduleQueryInterface

+ func (q *ScheduleQuery) SetQueueName(queueName string) ScheduleQueryInterface

+ func (q *ScheduleQuery) SetStatus(status string) ScheduleQueryInterface

+ func (q *ScheduleQuery) SetTaskDefinitionID(taskDefinitionID string) ScheduleQueryInterface

+ func (q *ScheduleQuery) Status() string

+ func (q *ScheduleQuery) TaskDefinitionID() string

+ type ScheduleQueryInterface interface

+ ID func() string

+ Limit func() int

+ Name func() string

+ Offset func() int

+ QueueName func() string

+ SetID func(string) ScheduleQueryInterface

+ SetLimit func(int) ScheduleQueryInterface

+ SetName func(string) ScheduleQueryInterface

+ SetOffset func(int) ScheduleQueryInterface

+ SetQueueName func(string) ScheduleQueryInterface

+ SetStatus func(string) ScheduleQueryInterface

+ SetTaskDefinitionID func(string) ScheduleQueryInterface

+ Status func() string

+ TaskDefinitionID func() string

+ func NewScheduleQuery() ScheduleQueryInterface

+ type ScheduleRunnerInterface interface

+ IsRunning func() bool

+ RunOnce func(ctx context.Context) error

+ SetInitialRuns func(ctx context.Context) error

+ Start func(ctx context.Context)

+ Stop func()

+ func NewScheduleRunner(store StoreInterface, opts ScheduleRunnerOptions) ScheduleRunnerInterface

+ type ScheduleRunnerOptions struct

+ IntervalSeconds int

+ Logger *log.Logger

type Store

+ func (st *Store) SqlCreateScheduleTable() string

+ func (store *Store) ScheduleCount(ctx context.Context, options ScheduleQueryInterface) (int64, error)

+ func (store *Store) ScheduleCreate(ctx context.Context, schedule ScheduleInterface) error

+ func (store *Store) ScheduleDelete(ctx context.Context, schedule ScheduleInterface) error

+ func (store *Store) ScheduleDeleteByID(ctx context.Context, id string) error

+ func (store *Store) ScheduleFindByID(ctx context.Context, id string) (ScheduleInterface, error)

+ func (store *Store) ScheduleList(ctx context.Context, options ScheduleQueryInterface) ([]ScheduleInterface, error)

+ func (store *Store) ScheduleRun(ctx context.Context) error

+ func (store *Store) ScheduleSoftDelete(ctx context.Context, schedule ScheduleInterface) error

+ func (store *Store) ScheduleSoftDeleteByID(ctx context.Context, id string) error

+ func (store *Store) ScheduleUpdate(ctx context.Context, schedule ScheduleInterface) error

type StoreInterface

+ ScheduleCount func(ctx context.Context, options ScheduleQueryInterface) (int64, error)

+ ScheduleCreate func(ctx context.Context, schedule ScheduleInterface) error

+ ScheduleDelete func(ctx context.Context, schedule ScheduleInterface) error

+ ScheduleDeleteByID func(ctx context.Context, id string) error

+ ScheduleFindByID func(ctx context.Context, id string) (ScheduleInterface, error)

+ ScheduleList func(ctx context.Context, options ScheduleQueryInterface) ([]ScheduleInterface, error)

+ ScheduleRun func(ctx context.Context) error

+ ScheduleSoftDelete func(ctx context.Context, schedule ScheduleInterface) error

+ ScheduleSoftDeleteByID func(ctx context.Context, id string) error

+ ScheduleUpdate func(ctx context.Context, schedule ScheduleInterface) error

+ TaskQueueClaimNext func(ctx context.Context, queueName string) (TaskQueueInterface, error)

+ type TaskQueueRunnerInterface interface

+ IsRunning func() bool

+ RunOnce func(ctx context.Context) error

+ Start func(ctx context.Context)

+ Stop func()

+ func NewTaskQueueRunner(store StoreInterface, opts TaskQueueRunnerOptions) TaskQueueRunnerInterface

+ type TaskQueueRunnerOptions struct

+ IntervalSeconds int

+ Logger *log.Logger

+ QueueName string

+ UnstuckMinutes int

Nov 21, 2025

Changes in this version

+ const COLUMN_SOFT_DELETED_AT

type Store

+ func (st *Store) TaskDefinitionEnqueueByAlias(ctx context.Context, queueName string, taskAlias string, ...) (TaskQueueInterface, error)

+ func (store *Store) TaskDefinitionExecuteCli(alias string, args []string) bool

+ func (store *Store) TaskQueueProcessTask(ctx context.Context, queuedTask TaskQueueInterface) (bool, error)

+ func (store *Store) TaskQueueRunConcurrent(ctx context.Context, queueName string, processSeconds int, unstuckMinutes int)

+ func (store *Store) TaskQueueRunDefault(ctx context.Context, processSeconds int, unstuckMinutes int)

+ func (store *Store) TaskQueueRunSerial(ctx context.Context, queueName string, processSeconds int, unstuckMinutes int)

+ func (store *Store) TaskQueueStop()

+ func (store *Store) TaskQueueStopByName(queueName string)

type StoreInterface

+ TaskDefinitionEnqueueByAlias func(ctx context.Context, queueName string, alias string, parameters map[string]any) (TaskQueueInterface, error)

+ TaskDefinitionExecuteCli func(alias string, args []string) bool

+ TaskQueueProcessTask func(ctx context.Context, queuedTask TaskQueueInterface) (bool, error)

+ TaskQueueRunConcurrent func(ctx context.Context, queueName string, processSeconds int, unstuckMinutes int)

+ TaskQueueRunDefault func(ctx context.Context, processSeconds int, unstuckMinutes int)

+ TaskQueueRunSerial func(ctx context.Context, queueName string, processSeconds int, unstuckMinutes int)

+ TaskQueueStop func()

+ TaskQueueStopByName func(queueName string)

Nov 20, 2025

Changes in this version

type TaskDefinitionInterface

+ IsRecurring func() int

+ RecurrenceRule func() string

+ SetIsRecurring func(isRecurring int) TaskDefinitionInterface

+ SetRecurrenceRule func(recurrenceRule string) TaskDefinitionInterface

Nov 19, 2025

Changes in this version

+ const COLUMN_IS_RECURRING

+ const COLUMN_QUEUE_NAME

+ const COLUMN_RECURRENCE_RULE

+ const DefaultQueueName

+ const TaskDefinitionStatusActive

+ const TaskDefinitionStatusCanceled

+ const TaskQueueStatusCanceled

+ const TaskQueueStatusDeleted

+ const TaskQueueStatusFailed

+ const TaskQueueStatusPaused

+ const TaskQueueStatusQueued

+ const TaskQueueStatusRunning

+ const TaskQueueStatusSuccess

type NewStoreOptions

+ ErrorHandler func(queueName, taskID string, err error)

+ MaxConcurrency int

+ TaskDefinitionTableName string

+ TaskQueueTableName string

+ type RecurrenceRuleInterface interface

+ GetDaysOfMonth func() []int

+ GetDaysOfWeek func() []DayOfWeek

+ GetEndsAt func() string

+ GetFrequency func() Frequency

+ GetInterval func() int

+ GetMonthsOfYear func() []MonthOfYear

+ GetStartsAt func() string

+ SetDaysOfMonth func([]int) RecurrenceRuleInterface

+ SetDaysOfWeek func([]DayOfWeek) RecurrenceRuleInterface

+ SetEndsAt func(dateTimeUTC string) RecurrenceRuleInterface

+ SetFrequency func(Frequency) RecurrenceRuleInterface

+ SetInterval func(int) RecurrenceRuleInterface

+ SetMonthsOfYear func([]MonthOfYear) RecurrenceRuleInterface

+ SetStartsAt func(dateTimeUTC string) RecurrenceRuleInterface

type Store

+ func (st *Store) SetErrorHandler(handler func(queueName, taskID string, err error)) StoreInterface

+ func (st *Store) SqlCreateTaskDefinitionTable() string

+ func (st *Store) SqlCreateTaskQueueTable() string

+ func (st *Store) TaskQueueDeleteByID(id string) error

+ func (st *Store) TaskQueueFail(queue TaskQueueInterface) error

+ func (st *Store) TaskQueueSuccess(queue TaskQueueInterface) error

+ func (store *Store) QueueRunConcurrent(ctx context.Context, queueName string, processSeconds int, unstuckMinutes int)

+ func (store *Store) QueueRunDefault(ctx context.Context, processSeconds int, unstuckMinutes int)

+ func (store *Store) QueueRunSerial(ctx context.Context, queueName string, processSeconds int, unstuckMinutes int)

+ func (store *Store) QueueStopByName(queueName string)

+ func (store *Store) QueuedTaskProcessWithContext(ctx context.Context, queuedTask TaskQueueInterface) (bool, error)

+ func (store *Store) TaskDefinitionCount(options TaskDefinitionQueryInterface) (int64, error)

+ func (store *Store) TaskDefinitionCreate(task TaskDefinitionInterface) error

+ func (store *Store) TaskDefinitionDelete(task TaskDefinitionInterface) error

+ func (store *Store) TaskDefinitionDeleteByID(id string) error

+ func (store *Store) TaskDefinitionFindByAlias(alias string) (task TaskDefinitionInterface, err error)

+ func (store *Store) TaskDefinitionFindByID(id string) (task TaskDefinitionInterface, err error)

+ func (store *Store) TaskDefinitionList(query TaskDefinitionQueryInterface) ([]TaskDefinitionInterface, error)

+ func (store *Store) TaskDefinitionSoftDelete(task TaskDefinitionInterface) error

+ func (store *Store) TaskDefinitionSoftDeleteByID(id string) error

+ func (store *Store) TaskDefinitionUpdate(task TaskDefinitionInterface) error

+ func (store *Store) TaskQueueClaimNext(ctx context.Context, queueName string) (TaskQueueInterface, error)

+ func (store *Store) TaskQueueCount(options TaskQueueQueryInterface) (int64, error)

+ func (store *Store) TaskQueueCreate(queue TaskQueueInterface) error

+ func (store *Store) TaskQueueDelete(queue TaskQueueInterface) error

+ func (store *Store) TaskQueueFindByID(id string) (TaskQueueInterface, error)

+ func (store *Store) TaskQueueFindNextQueuedTask() (TaskQueueInterface, error)

+ func (store *Store) TaskQueueFindNextQueuedTaskByQueue(queueName string) (TaskQueueInterface, error)

+ func (store *Store) TaskQueueFindRunning(limit int) []TaskQueueInterface

+ func (store *Store) TaskQueueFindRunningByQueue(queueName string, limit int) []TaskQueueInterface

+ func (store *Store) TaskQueueList(query TaskQueueQueryInterface) ([]TaskQueueInterface, error)

+ func (store *Store) TaskQueueProcessNext() error

+ func (store *Store) TaskQueueProcessNextAsyncByQueue(queueName string) error

+ func (store *Store) TaskQueueProcessNextByQueue(queueName string) error

+ func (store *Store) TaskQueueSoftDelete(queue TaskQueueInterface) error

+ func (store *Store) TaskQueueSoftDeleteByID(id string) error

+ func (store *Store) TaskQueueUnstuck(waitMinutes int)

+ func (store *Store) TaskQueueUnstuckByQueue(queueName string, waitMinutes int)

+ func (store *Store) TaskQueueUpdate(queue TaskQueueInterface) error

type StoreInterface

+ QueueRunConcurrent func(ctx context.Context, queueName string, processSeconds int, unstuckMinutes int)

+ QueueRunDefault func(ctx context.Context, processSeconds int, unstuckMinutes int)

+ QueueRunSerial func(ctx context.Context, queueName string, processSeconds int, unstuckMinutes int)

+ QueueStop func()

+ QueueStopByName func(queueName string)

+ SetErrorHandler func(handler func(queueName, taskID string, err error)) StoreInterface

+ TaskDefinitionCount func(options TaskDefinitionQueryInterface) (int64, error)

+ TaskDefinitionCreate func(TaskDefinition TaskDefinitionInterface) error

+ TaskDefinitionDelete func(TaskDefinition TaskDefinitionInterface) error

+ TaskDefinitionDeleteByID func(id string) error

+ TaskDefinitionFindByAlias func(alias string) (TaskDefinitionInterface, error)

+ TaskDefinitionFindByID func(id string) (TaskDefinitionInterface, error)

+ TaskDefinitionList func(options TaskDefinitionQueryInterface) ([]TaskDefinitionInterface, error)

+ TaskDefinitionSoftDelete func(TaskDefinition TaskDefinitionInterface) error

+ TaskDefinitionSoftDeleteByID func(id string) error

+ TaskDefinitionUpdate func(TaskDefinition TaskDefinitionInterface) error

+ TaskQueueCount func(options TaskQueueQueryInterface) (int64, error)

+ TaskQueueCreate func(TaskQueue TaskQueueInterface) error

+ TaskQueueDelete func(TaskQueue TaskQueueInterface) error

+ TaskQueueDeleteByID func(id string) error

+ TaskQueueFindByID func(TaskQueueID string) (TaskQueueInterface, error)

+ TaskQueueList func(query TaskQueueQueryInterface) ([]TaskQueueInterface, error)

+ TaskQueueSoftDelete func(TaskQueue TaskQueueInterface) error

+ TaskQueueSoftDeleteByID func(id string) error

+ TaskQueueUpdate func(TaskQueue TaskQueueInterface) error

+ type TaskDefinitionInterface interface

+ Alias func() string

+ CreatedAt func() string

+ CreatedAtCarbon func() *carbon.Carbon

+ Data func() map[string]string

+ DataChanged func() map[string]string

+ Description func() string

+ ID func() string

+ IsActive func() bool

+ IsCanceled func() bool

+ IsSoftDeleted func() bool

+ MarkAsNotDirty func()

+ Memo func() string

+ SetAlias func(alias string) TaskDefinitionInterface

+ SetCreatedAt func(createdAt string) TaskDefinitionInterface

+ SetDescription func(description string) TaskDefinitionInterface

+ SetID func(id string) TaskDefinitionInterface

+ SetMemo func(memo string) TaskDefinitionInterface

+ SetSoftDeletedAt func(deletedAt string) TaskDefinitionInterface

+ SetStatus func(status string) TaskDefinitionInterface

+ SetTitle func(title string) TaskDefinitionInterface

+ SetUpdatedAt func(updatedAt string) TaskDefinitionInterface

+ SoftDeletedAt func() string

+ SoftDeletedAtCarbon func() *carbon.Carbon

+ Status func() string

+ Title func() string

+ UpdatedAt func() string

+ UpdatedAtCarbon func() *carbon.Carbon

+ func NewTaskDefinition() TaskDefinitionInterface

+ func NewTaskDefinitionFromExistingData(data map[string]string) TaskDefinitionInterface

+ type TaskDefinitionQueryInterface interface

+ Alias func() string

+ Columns func() []string

+ CreatedAtGte func() string

+ CreatedAtLte func() string

+ HasAlias func() bool

+ HasCountOnly func() bool

+ HasCreatedAtGte func() bool

+ HasCreatedAtLte func() bool

+ HasID func() bool

+ HasIDIn func() bool

+ HasLimit func() bool

+ HasOffset func() bool

+ HasOrderBy func() bool

+ HasSoftDeletedIncluded func() bool

+ HasSortOrder func() bool

+ HasStatus func() bool

+ HasStatusIn func() bool

+ ID func() string

+ IDIn func() []string

+ IsCountOnly func() bool

+ Limit func() int

+ Offset func() int

+ OrderBy func() string

+ SetAlias func(alias string) TaskDefinitionQueryInterface

+ SetColumns func(columns []string) TaskDefinitionQueryInterface

+ SetCountOnly func(countOnly bool) TaskDefinitionQueryInterface

+ SetCreatedAtGte func(createdAtGte string) TaskDefinitionQueryInterface

+ SetCreatedAtLte func(createdAtLte string) TaskDefinitionQueryInterface

+ SetID func(id string) TaskDefinitionQueryInterface

+ SetIDIn func(idIn []string) TaskDefinitionQueryInterface

+ SetLimit func(limit int) TaskDefinitionQueryInterface

+ SetOffset func(offset int) TaskDefinitionQueryInterface

+ SetOrderBy func(orderBy string) TaskDefinitionQueryInterface

+ SetSoftDeletedIncluded func(withDeleted bool) TaskDefinitionQueryInterface

+ SetSortOrder func(sortOrder string) TaskDefinitionQueryInterface

+ SetStatus func(status string) TaskDefinitionQueryInterface

+ SetStatusIn func(statusIn []string) TaskDefinitionQueryInterface

+ SoftDeletedIncluded func() bool

+ SortOrder func() string

+ Status func() string

+ StatusIn func() []string

+ Validate func() error

+ func TaskDefinitionQuery() TaskDefinitionQueryInterface

+ type TaskHandlerWithContext interface

+ HandleWithContext func(ctx context.Context) bool

+ type TaskQueueInterface interface

+ AppendDetails func(details string) TaskQueueInterface

+ Attempts func() int

+ CompletedAt func() string

+ CompletedAtCarbon func() *carbon.Carbon

+ CreatedAt func() string

+ CreatedAtCarbon func() *carbon.Carbon

+ Data func() map[string]string

+ DataChanged func() map[string]string

+ Details func() string

+ ID func() string

+ IsCanceled func() bool

+ IsDeleted func() bool

+ IsFailed func() bool

+ IsPaused func() bool

+ IsQueued func() bool

+ IsRunning func() bool

+ IsSoftDeleted func() bool

+ IsSuccess func() bool

+ MarkAsNotDirty func()

+ Output func() string

+ Parameters func() string

+ ParametersMap func() (map[string]string, error)

+ QueueName func() string

+ SetAttempts func(attempts int) TaskQueueInterface

+ SetCompletedAt func(completedAt string) TaskQueueInterface

+ SetCreatedAt func(createdAt string) TaskQueueInterface

+ SetDetails func(details string) TaskQueueInterface

+ SetID func(id string) TaskQueueInterface

+ SetOutput func(output string) TaskQueueInterface

+ SetParameters func(parameters string) TaskQueueInterface

+ SetParametersMap func(parameters map[string]string) (TaskQueueInterface, error)

+ SetQueueName func(queueName string) TaskQueueInterface

+ SetSoftDeletedAt func(deletedAt string) TaskQueueInterface

+ SetStartedAt func(startedAt string) TaskQueueInterface

+ SetStatus func(status string) TaskQueueInterface

+ SetTaskID func(taskID string) TaskQueueInterface

+ SetUpdatedAt func(updatedAt string) TaskQueueInterface

+ SoftDeletedAt func() string

+ SoftDeletedAtCarbon func() *carbon.Carbon

+ StartedAt func() string

+ StartedAtCarbon func() *carbon.Carbon

+ Status func() string

+ TaskID func() string

+ UpdatedAt func() string

+ UpdatedAtCarbon func() *carbon.Carbon

+ func NewTaskQueue(queueName ...string) TaskQueueInterface

+ func NewTaskQueueFromExistingData(data map[string]string) TaskQueueInterface

+ type TaskQueueQueryInterface interface

+ Columns func() []string

+ CreatedAtGte func() string

+ CreatedAtLte func() string

+ HasCountOnly func() bool

+ HasCreatedAtGte func() bool

+ HasCreatedAtLte func() bool

+ HasID func() bool

+ HasIDIn func() bool

+ HasLimit func() bool

+ HasOffset func() bool

+ HasOrderBy func() bool

+ HasQueueName func() bool

+ HasSoftDeletedIncluded func() bool

+ HasSortOrder func() bool

+ HasStatus func() bool

+ HasStatusIn func() bool

+ HasTaskID func() bool

+ ID func() string

+ IDIn func() []string

+ IsCountOnly func() bool

+ Limit func() int

+ Offset func() int

+ OrderBy func() string

+ QueueName func() string

+ SetColumns func(columns []string) TaskQueueQueryInterface

+ SetCountOnly func(countOnly bool) TaskQueueQueryInterface

+ SetCreatedAtGte func(createdAtGte string) TaskQueueQueryInterface

+ SetCreatedAtLte func(createdAtLte string) TaskQueueQueryInterface

+ SetID func(id string) TaskQueueQueryInterface

+ SetIDIn func(idIn []string) TaskQueueQueryInterface

+ SetLimit func(limit int) TaskQueueQueryInterface

+ SetOffset func(offset int) TaskQueueQueryInterface

+ SetOrderBy func(orderBy string) TaskQueueQueryInterface

+ SetQueueName func(queueName string) TaskQueueQueryInterface

+ SetSoftDeletedIncluded func(withDeleted bool) TaskQueueQueryInterface

+ SetSortOrder func(sortOrder string) TaskQueueQueryInterface

+ SetStatus func(status string) TaskQueueQueryInterface

+ SetStatusIn func(statusIn []string) TaskQueueQueryInterface

+ SetTaskID func(taskID string) TaskQueueQueryInterface

+ SoftDeletedIncluded func() bool

+ SortOrder func() string

+ Status func() string

+ StatusIn func() []string

+ TaskID func() string

+ Validate func() error

+ func TaskQueueQuery() TaskQueueQueryInterface

Nov 8, 2025

Changes in this version

type Store

+ func (store *Store) QueueStop()

Sep 1, 2025

Changes in this version

+ const ASC

+ const COLUMN_ALIAS

+ const COLUMN_ATTEMPTS

+ const COLUMN_COMPLETED_AT

+ const COLUMN_CREATED_AT

+ const COLUMN_DELETED_AT

+ const COLUMN_DESCRIPTION

+ const COLUMN_DETAILS

+ const COLUMN_ID

+ const COLUMN_MEMO

+ const COLUMN_METAS

+ const COLUMN_OUTPUT

+ const COLUMN_PARAMETERS

+ const COLUMN_STARTED_AT

+ const COLUMN_STATUS

+ const COLUMN_TASK_ID

+ const COLUMN_TITLE

+ const COLUMN_UPDATED_AT

+ const DESC

+ const QueueStatusCanceled

+ const QueueStatusDeleted

+ const QueueStatusFailed

+ const QueueStatusPaused

+ const QueueStatusQueued

+ const QueueStatusRunning

+ const QueueStatusSuccess

+ const TaskStatusActive

+ const TaskStatusCanceled

+ func NextRunAt(rule RecurrenceRule, now *carbon.Carbon) (*carbon.Carbon, error)

+ type DayOfWeek string

+ const DayOfWeekFriday

+ const DayOfWeekMonday

+ const DayOfWeekSaturday

+ const DayOfWeekSunday

+ const DayOfWeekThursday

+ const DayOfWeekTuesday

+ const DayOfWeekWednesday

+ type Frequency string

+ const FrequencyDaily

+ const FrequencyHourly

+ const FrequencyMinutely

+ const FrequencyMonthly

+ const FrequencyNone

+ const FrequencySecondly

+ const FrequencyWeekly

+ const FrequencyYearly

+ type MonthOfYear string

+ const MonthOfYearApril

+ const MonthOfYearAugust

+ const MonthOfYearDecember

+ const MonthOfYearFebruary

+ const MonthOfYearJanuary

+ const MonthOfYearJuly

+ const MonthOfYearJune

+ const MonthOfYearMarch

+ const MonthOfYearMay

+ const MonthOfYearNovember

+ const MonthOfYearOctober

+ const MonthOfYearSeptember

+ type NewStoreOptions struct

+ AutomigrateEnabled bool

+ DB *sql.DB

+ DbDriverName string

+ DebugEnabled bool

+ QueueTableName string

+ TaskTableName string

+ type QueueInterface interface

+ AppendDetails func(details string) QueueInterface

+ Attempts func() int

+ CompletedAt func() string

+ CompletedAtCarbon func() *carbon.Carbon

+ CreatedAt func() string

+ CreatedAtCarbon func() *carbon.Carbon

+ Data func() map[string]string

+ DataChanged func() map[string]string

+ Details func() string

+ ID func() string

+ IsCanceled func() bool

+ IsDeleted func() bool

+ IsFailed func() bool

+ IsPaused func() bool

+ IsQueued func() bool

+ IsRunning func() bool

+ IsSoftDeleted func() bool

+ IsSuccess func() bool

+ MarkAsNotDirty func()

+ Output func() string

+ Parameters func() string

+ ParametersMap func() (map[string]string, error)

+ SetAttempts func(attempts int) QueueInterface

+ SetCompletedAt func(completedAt string) QueueInterface

+ SetCreatedAt func(createdAt string) QueueInterface

+ SetDetails func(details string) QueueInterface

+ SetID func(id string) QueueInterface

+ SetOutput func(output string) QueueInterface

+ SetParameters func(parameters string) QueueInterface

+ SetParametersMap func(parameters map[string]string) (QueueInterface, error)

+ SetSoftDeletedAt func(deletedAt string) QueueInterface

+ SetStartedAt func(startedAt string) QueueInterface

+ SetStatus func(status string) QueueInterface

+ SetTaskID func(taskID string) QueueInterface

+ SetUpdatedAt func(updatedAt string) QueueInterface

+ SoftDeletedAt func() string

+ SoftDeletedAtCarbon func() *carbon.Carbon

+ StartedAt func() string

+ StartedAtCarbon func() *carbon.Carbon

+ Status func() string

+ TaskID func() string

+ UpdatedAt func() string

+ UpdatedAtCarbon func() *carbon.Carbon

+ func NewQueue() QueueInterface

+ func NewQueueFromExistingData(data map[string]string) QueueInterface

+ type QueueQueryInterface interface

+ Columns func() []string

+ CreatedAtGte func() string

+ CreatedAtLte func() string

+ HasCountOnly func() bool

+ HasCreatedAtGte func() bool

+ HasCreatedAtLte func() bool

+ HasID func() bool

+ HasIDIn func() bool

+ HasLimit func() bool

+ HasOffset func() bool

+ HasOrderBy func() bool

+ HasSoftDeletedIncluded func() bool

+ HasSortOrder func() bool

+ HasStatus func() bool

+ HasStatusIn func() bool

+ HasTaskID func() bool

+ ID func() string

+ IDIn func() []string

+ IsCountOnly func() bool

+ Limit func() int

+ Offset func() int

+ OrderBy func() string

+ SetColumns func(columns []string) QueueQueryInterface

+ SetCountOnly func(countOnly bool) QueueQueryInterface

+ SetCreatedAtGte func(createdAtGte string) QueueQueryInterface

+ SetCreatedAtLte func(createdAtLte string) QueueQueryInterface

+ SetID func(id string) QueueQueryInterface

+ SetIDIn func(idIn []string) QueueQueryInterface

+ SetLimit func(limit int) QueueQueryInterface

+ SetOffset func(offset int) QueueQueryInterface

+ SetOrderBy func(orderBy string) QueueQueryInterface

+ SetSoftDeletedIncluded func(withDeleted bool) QueueQueryInterface

+ SetSortOrder func(sortOrder string) QueueQueryInterface

+ SetStatus func(status string) QueueQueryInterface

+ SetStatusIn func(statusIn []string) QueueQueryInterface

+ SetTaskID func(taskID string) QueueQueryInterface

+ SoftDeletedIncluded func() bool

+ SortOrder func() string

+ Status func() string

+ StatusIn func() []string

+ TaskID func() string

+ Validate func() error

+ func QueueQuery() QueueQueryInterface

+ type RecurrenceRule interface

+ GetDaysOfMonth func() []int

+ GetDaysOfWeek func() []DayOfWeek

+ GetEndsAt func() string

+ GetFrequency func() Frequency

+ GetInterval func() int

+ GetMonthsOfYear func() []MonthOfYear

+ GetStartsAt func() string

+ SetDaysOfMonth func([]int) RecurrenceRule

+ SetDaysOfWeek func([]DayOfWeek) RecurrenceRule

+ SetEndsAt func(dateTimeUTC string) RecurrenceRule

+ SetFrequency func(Frequency) RecurrenceRule

+ SetInterval func(int) RecurrenceRule

+ SetMonthsOfYear func([]MonthOfYear) RecurrenceRule

+ SetStartsAt func(dateTimeUTC string) RecurrenceRule

+ func NewRecurrenceRule() RecurrenceRule

+ type ScheduleDefinition interface

+ GetEndsAt func() string

+ GetID func() string

+ GetNextRunTime func(string) (string, error)

+ GetRecurrenceRule func() string

+ GetStartsAt func() string

+ IsValid func() bool

+ SetEndsAt func(string)

+ SetID func(string) ScheduleDefinition

+ SetRecurrenceRule func(dateTimeUtc string) ScheduleDefinition

+ SetStartsAt func(dateTimeUtc string)

+ type ScheduleInterface interface

+ ScheduleDefinitionID func() string

+ SetScheduleDefinition func(ScheduleDefinition)

+ type Store struct

+ func NewStore(opts NewStoreOptions) (*Store, error)

+ func (st *Store) AutoMigrate() error

+ func (st *Store) EnableDebug(debugEnabled bool) StoreInterface

+ func (st *Store) QueueDeleteByID(id string) error

+ func (st *Store) QueueFail(queue QueueInterface) error

+ func (st *Store) QueueSuccess(queue QueueInterface) error

+ func (st *Store) SqlCreateQueueTable() string

+ func (st *Store) SqlCreateTaskTable() string

+ func (st *Store) TaskEnqueueByAlias(taskAlias string, parameters map[string]interface{}) (QueueInterface, error)

+ func (store *Store) QueueCount(options QueueQueryInterface) (int64, error)

+ func (store *Store) QueueCreate(queue QueueInterface) error

+ func (store *Store) QueueDelete(queue QueueInterface) error

+ func (store *Store) QueueFindByID(id string) (QueueInterface, error)

+ func (store *Store) QueueFindNextQueuedTask() (QueueInterface, error)

+ func (store *Store) QueueFindRunning(limit int) []QueueInterface

+ func (store *Store) QueueList(query QueueQueryInterface) ([]QueueInterface, error)

+ func (store *Store) QueueProcessNext() error

+ func (store *Store) QueueRunGoroutine(processSeconds int, unstuckMinutes int)

+ func (store *Store) QueueSoftDelete(queue QueueInterface) error

+ func (store *Store) QueueSoftDeleteByID(id string) error

+ func (store *Store) QueueUnstuck(waitMinutes int)

+ func (store *Store) QueueUpdate(queue QueueInterface) error

+ func (store *Store) QueuedTaskForceFail(queuedTask QueueInterface, waitMinutes int) error

+ func (store *Store) QueuedTaskProcess(queuedTask QueueInterface) (bool, error)

+ func (store *Store) TaskCount(options TaskQueryInterface) (int64, error)

+ func (store *Store) TaskCreate(task TaskInterface) error

+ func (store *Store) TaskDelete(task TaskInterface) error

+ func (store *Store) TaskDeleteByID(id string) error

+ func (store *Store) TaskExecuteCli(alias string, args []string) bool

+ func (store *Store) TaskFindByAlias(alias string) (task TaskInterface, err error)

+ func (store *Store) TaskFindByID(id string) (task TaskInterface, err error)

+ func (store *Store) TaskHandlerAdd(taskHandler TaskHandlerInterface, createIfMissing bool) error

+ func (store *Store) TaskHandlerList() []TaskHandlerInterface

+ func (store *Store) TaskList(query TaskQueryInterface) ([]TaskInterface, error)

+ func (store *Store) TaskSoftDelete(task TaskInterface) error

+ func (store *Store) TaskSoftDeleteByID(id string) error

+ func (store *Store) TaskUpdate(task TaskInterface) error

+ type StoreInterface interface

+ AutoMigrate func() error

+ EnableDebug func(debug bool) StoreInterface

+ QueueCount func(options QueueQueryInterface) (int64, error)

+ QueueCreate func(Queue QueueInterface) error

+ QueueDelete func(Queue QueueInterface) error

+ QueueDeleteByID func(id string) error

+ QueueFindByID func(QueueID string) (QueueInterface, error)

+ QueueList func(query QueueQueryInterface) ([]QueueInterface, error)

+ QueueRunGoroutine func(processSeconds int, unstuckMinutes int)

+ QueueSoftDelete func(Queue QueueInterface) error

+ QueueSoftDeleteByID func(id string) error

+ QueueUpdate func(Queue QueueInterface) error

+ QueuedTaskProcess func(queuedTask QueueInterface) (bool, error)

+ TaskCount func(options TaskQueryInterface) (int64, error)

+ TaskCreate func(Task TaskInterface) error

+ TaskDelete func(Task TaskInterface) error

+ TaskDeleteByID func(id string) error

+ TaskEnqueueByAlias func(alias string, parameters map[string]interface{}) (QueueInterface, error)

+ TaskExecuteCli func(alias string, args []string) bool

+ TaskFindByAlias func(alias string) (TaskInterface, error)

+ TaskFindByID func(id string) (TaskInterface, error)

+ TaskHandlerAdd func(taskHandler TaskHandlerInterface, createIfMissing bool) error

+ TaskHandlerList func() []TaskHandlerInterface

+ TaskList func(options TaskQueryInterface) ([]TaskInterface, error)

+ TaskSoftDelete func(Task TaskInterface) error

+ TaskSoftDeleteByID func(id string) error

+ TaskUpdate func(Task TaskInterface) error

+ type TaskHandlerBase struct

+ func (handler *TaskHandlerBase) ErrorMessage() string

+ func (handler *TaskHandlerBase) GetParam(paramName string) string

+ func (handler *TaskHandlerBase) GetParamArray(paramName string) []string

+ func (handler *TaskHandlerBase) HasQueuedTask() bool

+ func (handler *TaskHandlerBase) InfoMessage() string

+ func (handler *TaskHandlerBase) LogError(message string)

+ func (handler *TaskHandlerBase) LogInfo(message string)

+ func (handler *TaskHandlerBase) LogSuccess(message string)

+ func (handler *TaskHandlerBase) Options() map[string]string

+ func (handler *TaskHandlerBase) QueuedTask() QueueInterface

+ func (handler *TaskHandlerBase) SetOptions(options map[string]string)

+ func (handler *TaskHandlerBase) SetQueuedTask(queuedTask QueueInterface)

+ func (handler *TaskHandlerBase) SuccessMessage() string

+ type TaskHandlerInterface interface

+ Alias func() string

+ Description func() string

+ Handle func() bool

+ SetOptions func(options map[string]string)

+ SetQueuedTask func(queuedTask QueueInterface)

+ Title func() string

+ type TaskInterface interface

+ Alias func() string

+ CreatedAt func() string

+ CreatedAtCarbon func() *carbon.Carbon

+ Data func() map[string]string

+ DataChanged func() map[string]string

+ Description func() string

+ ID func() string

+ IsActive func() bool

+ IsCanceled func() bool

+ IsSoftDeleted func() bool

+ MarkAsNotDirty func()

+ Memo func() string

+ SetAlias func(alias string) TaskInterface

+ SetCreatedAt func(createdAt string) TaskInterface

+ SetDescription func(description string) TaskInterface

+ SetID func(id string) TaskInterface

+ SetMemo func(memo string) TaskInterface

+ SetSoftDeletedAt func(deletedAt string) TaskInterface

+ SetStatus func(status string) TaskInterface

+ SetTitle func(title string) TaskInterface

+ SetUpdatedAt func(updatedAt string) TaskInterface

+ SoftDeletedAt func() string

+ SoftDeletedAtCarbon func() *carbon.Carbon

+ Status func() string

+ Title func() string

+ UpdatedAt func() string

+ UpdatedAtCarbon func() *carbon.Carbon

+ func NewTask() TaskInterface

+ func NewTaskFromExistingData(data map[string]string) TaskInterface

+ type TaskQueryInterface interface

+ Alias func() string

+ Columns func() []string

+ CreatedAtGte func() string

+ CreatedAtLte func() string

+ HasAlias func() bool

+ HasCountOnly func() bool

+ HasCreatedAtGte func() bool

+ HasCreatedAtLte func() bool

+ HasID func() bool

+ HasIDIn func() bool

+ HasLimit func() bool

+ HasOffset func() bool

+ HasOrderBy func() bool

+ HasSoftDeletedIncluded func() bool

+ HasSortOrder func() bool

+ HasStatus func() bool

+ HasStatusIn func() bool

+ ID func() string

+ IDIn func() []string

+ IsCountOnly func() bool

+ Limit func() int

+ Offset func() int

+ OrderBy func() string

+ SetAlias func(alias string) TaskQueryInterface

+ SetColumns func(columns []string) TaskQueryInterface

+ SetCountOnly func(countOnly bool) TaskQueryInterface

+ SetCreatedAtGte func(createdAtGte string) TaskQueryInterface

+ SetCreatedAtLte func(createdAtLte string) TaskQueryInterface

+ SetID func(id string) TaskQueryInterface

+ SetIDIn func(idIn []string) TaskQueryInterface

+ SetLimit func(limit int) TaskQueryInterface

+ SetOffset func(offset int) TaskQueryInterface

+ SetOrderBy func(orderBy string) TaskQueryInterface

+ SetSoftDeletedIncluded func(withDeleted bool) TaskQueryInterface

+ SetSortOrder func(sortOrder string) TaskQueryInterface

+ SetStatus func(status string) TaskQueryInterface

+ SetStatusIn func(statusIn []string) TaskQueryInterface

+ SoftDeletedIncluded func() bool

+ SortOrder func() string

+ Status func() string

+ StatusIn func() []string

+ Validate func() error

+ func TaskQuery() TaskQueryInterface