barngo

type FieldMeta struct {
	Name       string // a barn's name
	AttrName   string // a field name in a user structure
	ColumnName string // a name in a DB
}

type Schedule struct {
	Id        int            `barn:""`
	Name      string         `barn:""`
	IsActive  bool           `barn:""`
	Cron      *string        `barn:""`
	NextRunAt *time.Time     `barn:""`
	LastRunAt *time.Time     `barn:""`
	Func      string         `barn:""`
	Args      map[string]any `barn:""`
}

type Scheduler[S any] struct {
	// contains filtered or unexported fields
}

type SchedulerConfig[S any] struct {
	Log     *slog.Logger
	Cron    string
	Handler SchedulerHandler[S]
}

type SchedulerHandler[S any] func(tx *sql.Tx, schedule *S) error

type Status string

type TableMeta struct {
	TableName    string
	Fields       []*FieldMeta
	FieldsByName map[string]*FieldMeta
}

type Tabler interface {
	TableName() string
}

type Task struct {
	Id         int            `barn:""`
	RunAt      time.Time      `barn:""`
	Func       string         `barn:""`
	Args       map[string]any `barn:""`
	Status     Status         `barn:""`
	StartedAt  *time.Time     `barn:""`
	FinishedAt *time.Time     `barn:""`
	Result     any            `barn:""`
	Error      *string        `barn:""`
}

type TaskFunc func(tx *sql.Tx, args any) (any, error)

type TaskHandler[T any] func(tx *sql.Tx, task *T) (any, error)

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

type Worker[T any] struct {
	// contains filtered or unexported fields
}

type WorkerConfig[T any] struct {
	Log     *slog.Logger
	Cron    string
	Handler TaskHandler[T]
}