cron

Cron

• Upstream: https://github.com/vmkteam/cron
• Обёртка над robfig/cron: context-aware jobs, web UI, ручной запуск, middleware, метрики
• Сигнатура задачи: func(ctx context.Context) error

Воркеры не живут в пакете домена. Расписание — pkg/app/cron.go (newCron(), CronConfig), задача — метод менеджера домена func(ctx) error. Пакет <domain>/cron и свой генерик Job поверх vmkteam/cron не нужны: менеджер уже даёт DI, middleware — метрики, логи и Sentry.

Базовый шаблон

m := cron.NewManager()
m.Use(
    cron.WithMetrics("mysrv"),
    cron.WithDevel(cfg.IsDevel),
    cron.WithSLog(logger),
    cron.WithMaintenance(log.Printf),
    cron.WithSkipActive(),
    cron.WithRecover(),
    cron.WithSentry(),
)

m.AddFunc("sync-users", "*/5 * * * *", func(ctx context.Context) error { ... })
m.AddMaintenanceFunc("db-vacuum", "0 4 * * 0", ...)   // эксклюзивный, блокирует остальные
m.AddFunc("manual-import", "", ...)                    // "" = только ручной запуск

go m.Run(ctx)
http.HandleFunc("/debug/cron", m.Handler)

Middleware

MW	Назначение
WithMetrics(serverName)	Prometheus (count/duration/active)
WithSLog(logger)	structured logging
WithLogger(printf, serverName)	legacy Printf
WithSentry()	ошибки + panic recovery → Sentry
WithRecover()	panic recovery (альтернатива WithSentry)
WithDevel(isDevel)	dev-флаг в ctx
WithSkipActive()	обязателен для длинных задач — пропуск если предыдущий запуск ещё идёт
WithMaintenance(printf)	эксклюзивное выполнение maintenance-задач

Метрики

• app_cron_evaluated_total — counter выполнений по состояниям
• app_cron_active — gauge активных задач
• app_cron_evaluated_duration_seconds — summary длительности

UI / API

• GET /debug/cron — HTML расписание (имя, паттерн, next, state, duration)
• GET /debug/cron с Accept: application/json — JSON
• GET /debug/cron?start=<name> — ручной запуск (follow redirect)