task

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

type Status uint8

type Task struct {
	Id          int
	CreatedAt   time.Time
	Func        string
	Args        any
	IsProcessed bool
	StartedAt   *time.Time
	FinishedAt  *time.Time
	IsSuccess   *bool
	Result      any
	Error       *string
}

type TaskHandler func(tx *sql.Tx, task *Task) error

type TaskQueryConfig struct {
	TableName        string
	IdField          string
	CreatedAtField   string
	FuncField        string
	ArgsField        string
	IsProcessedField string
	StartedAtField   string
	FinishedAtField  string
	IsSuccessField   string
	ResultField      string
	ErrorField       string
}

type TaskRepository interface {
	FindNext(tx *sql.Tx) (*Task, error)
	Create(tx *sql.Tx, task *Task) error
	Save(tx *sql.Tx, task *Task) error
	DeleteOld(tx *sql.Tx, t time.Time) (int, error)
}

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

type WorkerConfig struct {
	Log        *slog.Logger
	Repository TaskRepository
	Cron       string
	Handler    TaskHandler
}