taskstore

type DayOfWeek string

type Frequency string

type MonthOfYear string

type NewStoreOptions struct {
	TaskDefinitionTableName string
	TaskQueueTableName      string
	ScheduleTableName       string
	DB                      *sql.DB
	DbDriverName            string
	AutomigrateEnabled      bool
	DebugEnabled            bool
	MaxConcurrency          int                                       // Max concurrent tasks (default: 10, 0 = unlimited)
	ErrorHandler            func(queueName, taskID string, err error) // Optional error callback
}

type RecurrenceRuleInterface interface {
	// GetFrequency returns how often the rule recurs (e.g. daily, weekly).
	GetFrequency() Frequency

	// SetFrequency sets how often the rule recurs.
	SetFrequency(Frequency) RecurrenceRuleInterface

	// GetStartsAt returns the UTC datetime when the rule becomes active.
	GetStartsAt() string

	// SetStartsAt sets the UTC datetime when the rule becomes active.
	SetStartsAt(dateTimeUTC string) RecurrenceRuleInterface

	// GetEndsAt returns the UTC datetime when the rule stops producing occurrences.
	GetEndsAt() string

	// SetEndsAt sets the UTC datetime when the rule stops producing occurrences.
	SetEndsAt(dateTimeUTC string) RecurrenceRuleInterface

	// GetInterval returns the step interval between occurrences (e.g. every N days).
	GetInterval() int

	// SetInterval sets the step interval between occurrences.
	SetInterval(int) RecurrenceRuleInterface

	// GetDaysOfWeek returns the days of the week the rule applies to (for weekly rules).
	GetDaysOfWeek() []DayOfWeek

	// SetDaysOfWeek sets the days of the week the rule applies to (for weekly rules).
	SetDaysOfWeek([]DayOfWeek) RecurrenceRuleInterface

	// GetDaysOfMonth returns the days of the month the rule applies to.
	GetDaysOfMonth() []int

	// SetDaysOfMonth sets the days of the month the rule applies to.
	SetDaysOfMonth([]int) RecurrenceRuleInterface

	// GetMonthsOfYear returns the months of the year the rule applies to.
	GetMonthsOfYear() []MonthOfYear

	// SetMonthsOfYear sets the months of the year the rule applies to.
	SetMonthsOfYear([]MonthOfYear) RecurrenceRuleInterface
}

type ScheduleInterface interface {

	// GetID the unique identifier of the schedule
	GetID() string

	// SetID sets the unique identifier of the schedule
	SetID(string) ScheduleInterface

	// Name the name of the schedule
	GetName() string

	// SetName sets the name of the schedule
	SetName(string) ScheduleInterface

	// Description the description of the schedule
	GetDescription() string

	// SetDescription sets the description of the schedule
	SetDescription(string) ScheduleInterface

	// Status the status of the schedule
	// Valid values are "draft" (default), "active", "inactive"
	GetStatus() string

	// SetStatus sets the status of the schedule
	SetStatus(string) ScheduleInterface

	// RecurrenceRule the recurrence rule that defines when the schedule should run
	GetRecurrenceRule() RecurrenceRuleInterface

	// SetRecurrenceRule sets the recurrence rule that defines when the schedule should run
	SetRecurrenceRule(RecurrenceRuleInterface) ScheduleInterface

	// QueueName the name of the queue that this schedule is associated with
	GetQueueName() string

	// SetQueueName sets the name of the queue that this schedule is associated with
	SetQueueName(string) ScheduleInterface

	// TaskDefinitionID the unique identifier of the task definition
	// that this schedule is associated with
	GetTaskDefinitionID() string

	// SetTaskDefinitionID sets the unique identifier of the task definition
	// that this schedule is associated with
	SetTaskDefinitionID(string) ScheduleInterface

	// TaskParameters the parameters to be passed to the task definition
	// when it is executed
	GetTaskParameters() map[string]any

	// SetTaskParameters sets the parameters to be passed to the task definition
	// when it is executed
	SetTaskParameters(map[string]any) ScheduleInterface

	// StartAt the start date and time of the schedule
	GetStartAt() string

	// SetStartAt sets the start date and time of the schedule
	// If startAt is not set, the schedule will start at the current time
	SetStartAt(string) ScheduleInterface

	// EndAt the end date and time of the schedule
	// The default value is the maximum datetime (never expires)
	GetEndAt() string

	// SetEndAt sets the end date and time of the schedule
	SetEndAt(string) ScheduleInterface

	// ExecutionCount the number of times the schedule has been executed
	GetExecutionCount() int

	// SetExecutionCount sets the number of times the schedule has been executed
	SetExecutionCount(int) ScheduleInterface

	// MaxExecutionCount the maximum number of times the schedule is allowed to be executed
	// The default value is int max (no limit)
	// To execute only once, set maxExecutionCount to 1
	GetMaxExecutionCount() int

	// SetMaxExecutionCount sets the maximum number of times the schedule is allowed to be executed
	SetMaxExecutionCount(int) ScheduleInterface

	// LastRunAt the last date and time the schedule was executed
	GetLastRunAt() string

	// SetLastRunAt sets the last date and time the schedule was executed
	SetLastRunAt(string) ScheduleInterface

	// NextRunAt the next date and time the schedule is scheduled to run
	GetNextRunAt() string

	// SetNextRunAt sets the next date and time the schedule is scheduled to run
	SetNextRunAt(string) ScheduleInterface

	// CreatedAt the date and time the schedule was created
	GetCreatedAt() string

	// SetCreatedAt sets the date and time the schedule was created
	SetCreatedAt(string) ScheduleInterface

	// UpdatedAt the date and time the schedule was last updated
	GetUpdatedAt() string

	// SetUpdatedAt sets the date and time the schedule was last updated
	SetUpdatedAt(string) ScheduleInterface

	// SoftDeletedAt the date and time the schedule was soft deleted
	// The default value is max datetime (not soft deleted, 9999-12-31 23:59:59)
	// To soft delete a schedule, set softDeletedAt to the current time
	// To unsoft delete a schedule, set softDeletedAt to max datetime
	// A soft deleted schedule is when its in the past
	GetSoftDeletedAt() string

	// SetSoftDeletedAt sets the date and time the schedule was soft deleted
	SetSoftDeletedAt(string) ScheduleInterface

	// HasReachedEndDate returns true if the schedule has reached its end date
	HasReachedEndDate() bool

	// HasReachedMaxExecutions returns true if the schedule has reached its maximum number of executions
	HasReachedMaxExecutions() bool

	// GetNextOccurrence returns the next occurrence of the schedule
	// if invalid recurrence rule, returns error
	GetNextOccurrence() (string, error)

	// IncrementExecutionCount increments the execution count of the schedule by one
	IncrementExecutionCount() ScheduleInterface

	// UpdateNextRunAt calculates the next run at of the schedule and updates it
	UpdateNextRunAt() ScheduleInterface

	// UpdateLastRunAt updates the last run at of the schedule with current time
	UpdateLastRunAt() ScheduleInterface

	// IsDue returns true if the schedule is due to run
	IsDue() bool
}

type ScheduleQuery struct {
	// contains filtered or unexported fields
}

type ScheduleQueryInterface interface {
	// ID the unique identifier of the schedule to filter by
	ID() string

	// SetID sets the unique identifier of the schedule to filter by
	SetID(string) ScheduleQueryInterface

	// Name the name of the schedule to filter by
	Name() string

	// SetName sets the name of the schedule to filter by
	SetName(string) ScheduleQueryInterface

	// Status the status of the schedule to filter by
	Status() string

	// SetStatus sets the status of the schedule to filter by
	SetStatus(string) ScheduleQueryInterface

	// QueueName the name of the queue that schedules are associated with to filter by
	QueueName() string

	// SetQueueName sets the name of the queue that schedules are associated with to filter by
	SetQueueName(string) ScheduleQueryInterface

	// TaskDefinitionID the unique identifier of the task definition that schedules are associated with to filter by
	TaskDefinitionID() string

	// SetTaskDefinitionID sets the unique identifier of the task definition that schedules are associated with to filter by
	SetTaskDefinitionID(string) ScheduleQueryInterface

	// Limit the maximum number of schedules to return
	Limit() int

	// SetLimit sets the maximum number of schedules to return
	SetLimit(int) ScheduleQueryInterface

	// Offset the number of schedules to skip before starting to return results
	Offset() int

	// SetOffset sets the number of schedules to skip before starting to return results
	SetOffset(int) ScheduleQueryInterface
}

type ScheduleRunnerInterface interface {
	Start(ctx context.Context)
	Stop()
	IsRunning() bool
	RunOnce(ctx context.Context) error
	SetInitialRuns(ctx context.Context) error
}

type ScheduleRunnerOptions struct {
	IntervalSeconds int
	Logger          *log.Logger
}

type Store struct {
	// contains filtered or unexported fields
}

type StoreInterface interface {
	AutoMigrate() error
	EnableDebug(debug bool) StoreInterface
	SetErrorHandler(handler func(queueName, taskID string, err error)) StoreInterface

	TaskQueueCount(ctx context.Context, options TaskQueueQueryInterface) (int64, error)
	TaskQueueCreate(ctx context.Context, TaskQueue TaskQueueInterface) error
	TaskQueueDelete(ctx context.Context, TaskQueue TaskQueueInterface) error
	TaskQueueDeleteByID(ctx context.Context, id string) error
	TaskQueueFindByID(ctx context.Context, TaskQueueID string) (TaskQueueInterface, error)
	TaskQueueList(ctx context.Context, query TaskQueueQueryInterface) ([]TaskQueueInterface, error)
	TaskQueueSoftDelete(ctx context.Context, TaskQueue TaskQueueInterface) error
	TaskQueueSoftDeleteByID(ctx context.Context, id string) error
	TaskQueueUpdate(ctx context.Context, TaskQueue TaskQueueInterface) error
	TaskQueueClaimNext(ctx context.Context, queueName string) (TaskQueueInterface, error)

	// Deprecated: Use NewTaskQueueRunner instead. These methods will be removed in a future version.
	// See docs/runners.md for the recommended approach.
	TaskQueueRunDefault(ctx context.Context, processSeconds int, unstuckMinutes int)
	// Deprecated: Use NewTaskQueueRunner instead. These methods will be removed in a future version.
	// See docs/runners.md for the recommended approach.
	TaskQueueRunSerial(ctx context.Context, queueName string, processSeconds int, unstuckMinutes int)
	// Deprecated: Use NewTaskQueueRunner instead. These methods will be removed in a future version.
	// See docs/runners.md for the recommended approach.
	TaskQueueRunConcurrent(ctx context.Context, queueName string, processSeconds int, unstuckMinutes int)
	// Deprecated: Use TaskQueueRunner.Stop() instead. These methods will be removed in a future version.
	// See docs/runners.md for the recommended approach.
	TaskQueueStop()
	// Deprecated: Use TaskQueueRunner.Stop() instead. These methods will be removed in a future version.
	// See docs/runners.md for the recommended approach.
	TaskQueueStopByName(queueName string)
	TaskQueueProcessTask(ctx context.Context, queuedTask TaskQueueInterface) (bool, error)

	TaskDefinitionCount(ctx context.Context, options TaskDefinitionQueryInterface) (int64, error)
	TaskDefinitionCreate(ctx context.Context, TaskDefinition TaskDefinitionInterface) error
	TaskDefinitionDelete(ctx context.Context, TaskDefinition TaskDefinitionInterface) error
	TaskDefinitionDeleteByID(ctx context.Context, id string) error
	TaskDefinitionFindByAlias(ctx context.Context, alias string) (TaskDefinitionInterface, error)
	TaskDefinitionFindByID(ctx context.Context, id string) (TaskDefinitionInterface, error)
	TaskDefinitionList(ctx context.Context, options TaskDefinitionQueryInterface) ([]TaskDefinitionInterface, error)
	TaskDefinitionSoftDelete(ctx context.Context, TaskDefinition TaskDefinitionInterface) error
	TaskDefinitionSoftDeleteByID(ctx context.Context, id string) error
	TaskDefinitionUpdate(ctx context.Context, TaskDefinition TaskDefinitionInterface) error

	// TaskDefinition Operations
	TaskDefinitionEnqueueByAlias(ctx context.Context, queueName string, alias string, parameters map[string]any) (TaskQueueInterface, error)
	TaskDefinitionExecuteCli(alias string, args []string) bool

	TaskHandlerList() []TaskDefinitionHandlerInterface
	TaskHandlerAdd(ctx context.Context, taskHandler TaskDefinitionHandlerInterface, createIfMissing bool) error

	ScheduleCount(ctx context.Context, options ScheduleQueryInterface) (int64, error)
	ScheduleCreate(ctx context.Context, schedule ScheduleInterface) error
	ScheduleDelete(ctx context.Context, schedule ScheduleInterface) error
	ScheduleDeleteByID(ctx context.Context, id string) error
	ScheduleFindByID(ctx context.Context, id string) (ScheduleInterface, error)
	ScheduleList(ctx context.Context, options ScheduleQueryInterface) ([]ScheduleInterface, error)
	ScheduleSoftDelete(ctx context.Context, schedule ScheduleInterface) error
	ScheduleSoftDeleteByID(ctx context.Context, id string) error
	ScheduleUpdate(ctx context.Context, schedule ScheduleInterface) error
	ScheduleRun(ctx context.Context) error
}

type TaskDefinitionHandlerBase struct {
	// contains filtered or unexported fields
}

type TaskDefinitionHandlerInterface interface {

	// Alias returns the unique identifier used to reference the task
	// definition when enqueuing or executing it.
	Alias() string

	// Title returns a short human-readable name for the task.
	Title() string

	// Description returns a longer human-readable description of what the
	// task does.
	Description() string

	// Handle executes the task logic and returns true on success.
	Handle() bool

	// HasQueuedTask reports whether the handler is currently associated with a
	// queued task.
	HasQueuedTask() bool

	// LogError records an error message for the handler and either appends it
	// to the queued task details or logs it directly.
	LogError(message string)

	// LogInfo records an informational message for the handler and either
	// appends it to the queued task details or logs it directly.
	LogInfo(message string)

	// LogSuccess records a success message for the handler and either appends
	// it to the queued task details or logs it directly.
	LogSuccess(message string)

	// GetQueuedTask returns the currently associated queued task, if any.
	GetQueuedTask() TaskQueueInterface

	// SetQueuedTask associates the handler with a queued task instance when
	// invoked as part of background processing.
	SetQueuedTask(queuedTask TaskQueueInterface)

	// GetOptions returns the options map used when the handler is executed
	// directly without an associated queued task.
	GetOptions() map[string]string

	// SetOptions provides key-value options when the handler is executed
	// directly, without an associated queued task.
	SetOptions(options map[string]string)

	// GetOutput returns the current output value for the handler. When a
	// queued task is associated, this typically reflects the queued task's
	// output; otherwise it is a handler-local value.
	GetOutput() string

	// SetOutput stores the output value for the handler. When a queued task is
	// associated, implementations should propagate this value to the queued
	// task's output as well.
	SetOutput(output string)

	// GetLastErrorMessage returns the last error message recorded during
	// handler execution.
	GetLastErrorMessage() string

	// GetLastInfoMessage returns the last informational message recorded during
	// handler execution.
	GetLastInfoMessage() string

	// GetLastSuccessMessage returns the last success message recorded during
	// handler execution.
	GetLastSuccessMessage() string

	// GetParam returns the value of a named parameter for the current
	// execution, reading from the queued task parameters when present or from
	// the handler options otherwise.
	GetParam(paramName string) string

	// GetParamArray returns the named parameter split on semicolons into a
	// slice. If the parameter is missing or empty, it returns an empty slice.
	GetParamArray(paramName string) []string
}

type TaskDefinitionInterface interface {
	Data() map[string]string
	DataChanged() map[string]string
	MarkAsNotDirty()

	IsActive() bool
	IsCanceled() bool
	IsSoftDeleted() bool

	GetAlias() string

	// Alias alias is kept for backwards compatibility.
	// Deprecated: use GetAlias instead. Will be removed after 2026-11-30.
	Alias() string
	SetAlias(alias string) TaskDefinitionInterface

	GetCreatedAt() string

	// CreatedAt alias is kept for backwards compatibility.
	// Deprecated: use GetCreatedAt instead. Will be removed after 2026-11-30.
	CreatedAt() string
	CreatedAtCarbon() *carbon.Carbon
	SetCreatedAt(createdAt string) TaskDefinitionInterface

	GetDescription() string

	// Description alias is kept for backwards compatibility.
	// Deprecated: use GetDescription instead. Will be removed after 2026-11-30.
	Description() string
	SetDescription(description string) TaskDefinitionInterface

	GetID() string

	// ID alias is kept for backwards compatibility.
	// Deprecated: use GetID instead. Will be removed after 2026-11-30.
	ID() string
	SetID(id string) TaskDefinitionInterface

	GetMemo() string

	// Memo alias is kept for backwards compatibility.
	// Deprecated: use GetMemo instead. Will be removed after 2026-11-30.
	Memo() string
	SetMemo(memo string) TaskDefinitionInterface

	GetIsRecurring() int

	// IsRecurring alias is kept for backwards compatibility.
	// Deprecated: use GetIsRecurring instead. Will be removed after 2026-11-30.
	IsRecurring() int
	SetIsRecurring(isRecurring int) TaskDefinitionInterface

	GetRecurrenceRule() string

	// RecurrenceRule alias is kept for backwards compatibility.
	// Deprecated: use GetRecurrenceRule instead. Will be removed after 2026-11-30.
	RecurrenceRule() string
	SetRecurrenceRule(recurrenceRule string) TaskDefinitionInterface

	GetSoftDeletedAt() string

	// SoftDeletedAt alias is kept for backwards compatibility.
	// Deprecated: use GetSoftDeletedAt instead. Will be removed after 2026-11-30.
	SoftDeletedAt() string
	SoftDeletedAtCarbon() *carbon.Carbon
	SetSoftDeletedAt(deletedAt string) TaskDefinitionInterface

	GetStatus() string

	// Status alias is kept for backwards compatibility.
	// Deprecated: use GetStatus instead. Will be removed after 2026-11-30.
	Status() string
	SetStatus(status string) TaskDefinitionInterface

	GetTitle() string

	// Title alias is kept for backwards compatibility.
	// Deprecated: use GetTitle instead. Will be removed after 2026-11-30.
	Title() string
	SetTitle(title string) TaskDefinitionInterface

	GetUpdatedAt() string

	// UpdatedAt alias is kept for backwards compatibility.
	// Deprecated: use GetUpdatedAt instead. Will be removed after 2026-11-30.
	UpdatedAt() string
	UpdatedAtCarbon() *carbon.Carbon
	SetUpdatedAt(updatedAt string) TaskDefinitionInterface
}

type TaskDefinitionQueryInterface interface {
	Validate() error

	Columns() []string
	SetColumns(columns []string) TaskDefinitionQueryInterface

	HasCountOnly() bool
	IsCountOnly() bool
	SetCountOnly(countOnly bool) TaskDefinitionQueryInterface

	HasAlias() bool
	Alias() string
	SetAlias(alias string) TaskDefinitionQueryInterface

	HasCreatedAtGte() bool
	CreatedAtGte() string
	SetCreatedAtGte(createdAtGte string) TaskDefinitionQueryInterface

	HasCreatedAtLte() bool
	CreatedAtLte() string
	SetCreatedAtLte(createdAtLte string) TaskDefinitionQueryInterface

	HasID() bool
	ID() string
	SetID(id string) TaskDefinitionQueryInterface

	HasIDIn() bool
	IDIn() []string
	SetIDIn(idIn []string) TaskDefinitionQueryInterface

	HasLimit() bool
	Limit() int
	SetLimit(limit int) TaskDefinitionQueryInterface

	HasOffset() bool
	Offset() int
	SetOffset(offset int) TaskDefinitionQueryInterface

	HasSortOrder() bool
	SortOrder() string
	SetSortOrder(sortOrder string) TaskDefinitionQueryInterface

	HasOrderBy() bool
	OrderBy() string
	SetOrderBy(orderBy string) TaskDefinitionQueryInterface

	HasSoftDeletedIncluded() bool
	SoftDeletedIncluded() bool
	SetSoftDeletedIncluded(withDeleted bool) TaskDefinitionQueryInterface

	HasStatus() bool
	Status() string
	SetStatus(status string) TaskDefinitionQueryInterface

	HasStatusIn() bool
	StatusIn() []string
	SetStatusIn(statusIn []string) TaskDefinitionQueryInterface
}

type TaskHandlerBase = TaskDefinitionHandlerBase

type TaskHandlerInterface = TaskDefinitionHandlerInterface

type TaskHandlerWithContext interface {
	TaskDefinitionHandlerInterface
	HandleWithContext(ctx context.Context) bool
}

type TaskQueueInterface interface {
	Data() map[string]string
	DataChanged() map[string]string
	MarkAsNotDirty()

	IsCanceled() bool
	IsDeleted() bool
	IsFailed() bool
	IsQueued() bool
	IsPaused() bool
	IsRunning() bool
	IsSuccess() bool
	IsSoftDeleted() bool

	GetAttempts() int

	// Attempts alias is kept for backwards compatibility.
	// Deprecated: use GetAttempts instead. Will be removed after 2026-11-30.
	Attempts() int
	SetAttempts(attempts int) TaskQueueInterface

	GetCompletedAt() string

	// CompletedAt alias is kept for backwards compatibility.
	// Deprecated: use GetCompletedAt instead. Will be removed after 2026-11-30.
	CompletedAt() string
	CompletedAtCarbon() *carbon.Carbon
	SetCompletedAt(completedAt string) TaskQueueInterface

	GetCreatedAt() string

	// CreatedAt alias is kept for backwards compatibility.
	// Deprecated: use GetCreatedAt instead. Will be removed after 2026-11-30.
	CreatedAt() string
	CreatedAtCarbon() *carbon.Carbon
	SetCreatedAt(createdAt string) TaskQueueInterface

	GetDetails() string

	// Details alias is kept for backwards compatibility.
	// Deprecated: use GetDetails instead. Will be removed after 2026-11-30.
	Details() string
	AppendDetails(details string) TaskQueueInterface
	SetDetails(details string) TaskQueueInterface

	GetID() string

	// ID alias is kept for backwards compatibility.
	// Deprecated: use GetID instead. Will be removed after 2026-11-30.
	ID() string
	SetID(id string) TaskQueueInterface

	GetOutput() string

	// Output alias is kept for backwards compatibility.
	// Deprecated: use GetOutput instead. Will be removed after 2026-11-30.
	Output() string
	SetOutput(output string) TaskQueueInterface

	GetParameters() string

	// Parameters alias is kept for backwards compatibility.
	// Deprecated: use GetParameters instead. Will be removed after 2026-11-30.
	Parameters() string
	SetParameters(parameters string) TaskQueueInterface
	ParametersMap() (map[string]string, error)
	SetParametersMap(parameters map[string]string) (TaskQueueInterface, error)

	GetSoftDeletedAt() string

	// SoftDeletedAt alias is kept for backwards compatibility.
	// Deprecated: use GetSoftDeletedAt instead. Will be removed after 2026-11-30.
	SoftDeletedAt() string
	SoftDeletedAtCarbon() *carbon.Carbon
	SetSoftDeletedAt(deletedAt string) TaskQueueInterface

	GetStartedAt() string

	// StartedAt alias is kept for backwards compatibility.
	// Deprecated: use GetStartedAt instead. Will be removed after 2026-11-30.
	StartedAt() string
	StartedAtCarbon() *carbon.Carbon
	SetStartedAt(startedAt string) TaskQueueInterface

	GetStatus() string

	// Status alias is kept for backwards compatibility.
	// Deprecated: use GetStatus instead. Will be removed after 2026-11-30.
	Status() string
	SetStatus(status string) TaskQueueInterface

	GetTaskID() string

	// TaskID alias is kept for backwards compatibility.
	// Deprecated: use GetTaskID instead. Will be removed after 2026-11-30.
	TaskID() string
	SetTaskID(taskID string) TaskQueueInterface

	GetUpdatedAt() string

	// UpdatedAt alias is kept for backwards compatibility.
	// Deprecated: use GetUpdatedAt instead. Will be removed after 2026-11-30.
	UpdatedAt() string
	UpdatedAtCarbon() *carbon.Carbon
	SetUpdatedAt(updatedAt string) TaskQueueInterface

	GetQueueName() string

	// QueueName alias is kept for backwards compatibility.
	// Deprecated: use GetQueueName instead. Will be removed after 2026-11-30.
	QueueName() string
	SetQueueName(queueName string) TaskQueueInterface
}

type TaskQueueQueryInterface interface {
	Validate() error

	Columns() []string
	SetColumns(columns []string) TaskQueueQueryInterface

	HasCountOnly() bool
	IsCountOnly() bool
	SetCountOnly(countOnly bool) TaskQueueQueryInterface

	HasCreatedAtGte() bool
	CreatedAtGte() string
	SetCreatedAtGte(createdAtGte string) TaskQueueQueryInterface

	HasCreatedAtLte() bool
	CreatedAtLte() string
	SetCreatedAtLte(createdAtLte string) TaskQueueQueryInterface

	HasID() bool
	ID() string
	SetID(id string) TaskQueueQueryInterface

	HasIDIn() bool
	IDIn() []string
	SetIDIn(idIn []string) TaskQueueQueryInterface

	HasLimit() bool
	Limit() int
	SetLimit(limit int) TaskQueueQueryInterface

	HasOffset() bool
	Offset() int
	SetOffset(offset int) TaskQueueQueryInterface

	HasSortOrder() bool
	SortOrder() string
	SetSortOrder(sortOrder string) TaskQueueQueryInterface

	HasOrderBy() bool
	OrderBy() string
	SetOrderBy(orderBy string) TaskQueueQueryInterface

	HasSoftDeletedIncluded() bool
	SoftDeletedIncluded() bool
	SetSoftDeletedIncluded(withDeleted bool) TaskQueueQueryInterface

	HasStatus() bool
	Status() string
	SetStatus(status string) TaskQueueQueryInterface

	HasStatusIn() bool
	StatusIn() []string
	SetStatusIn(statusIn []string) TaskQueueQueryInterface

	HasTaskID() bool
	TaskID() string
	SetTaskID(taskID string) TaskQueueQueryInterface

	HasQueueName() bool
	QueueName() string
	SetQueueName(queueName string) TaskQueueQueryInterface
}

type TaskQueueRunnerInterface interface {
	Start(ctx context.Context)
	Stop()
	IsRunning() bool
	RunOnce(ctx context.Context) error
}

type TaskQueueRunnerOptions struct {
	IntervalSeconds int
	UnstuckMinutes  int
	QueueName       string
	Logger          *log.Logger
	MaxConcurrency  int // 0 or 1 = serial, >1 = concurrent (default: 1)
}