cron

Documentation

Overview

Package cron schedules jobs.

Index

• Variables
• func SetPersistInterval(d time.Duration)
• func Start(ctx context.Context)
• func Stop() error
• func TaskACME() error
• func TaskDataRetention() error
• func TaskEmailReports() error
• func TaskOldExports() error
• func TaskPersistAndStat() error
• func TaskSessions() error
• func TaskVacuumOldSites() error
• func UpdateStats(ctx context.Context, site *goatcounter.Site, siteID int64, ...) error
• func WaitACME()
• func WaitDataRetention()
• func WaitEmailReports()
• func WaitOldExports()
• func WaitPersistAndStat()
• func WaitSessions()
• func WaitVacuumOldSites()
• type Task
  • func (t Task) ID() string

Variables

var Tasks = []Task{
	{"vacuum pageviews (data retention)", dataRetention, 1 * time.Hour},
	{"renew ACME certs", renewACME, 2 * time.Hour},
	{"vacuum soft-deleted sites", vacuumDeleted, 12 * time.Hour},
	{"rm old exports", oldExports, 1 * time.Hour},
	{"cycle sessions", sessions, 1 * time.Minute},
	{"send email reports", emailReports, 1 * time.Hour},
	{"persist hits", persistAndStat, time.Duration(persistInterval.Load())},
}

Functions

func SetPersistInterval

func SetPersistInterval(d time.Duration)

func Start

func Start(ctx context.Context)

Start running tasks in the background.

func Stop

func Stop() error

func TaskACME

func TaskACME() error

func TaskDataRetention

func TaskDataRetention() error

func TaskEmailReports

func TaskEmailReports() error

func TaskOldExports

func TaskOldExports() error

func TaskPersistAndStat

func TaskPersistAndStat() error

func TaskSessions

func TaskSessions() error

func TaskVacuumOldSites

func TaskVacuumOldSites() error

func UpdateStats

func UpdateStats(ctx context.Context, site *goatcounter.Site, siteID int64, hits []goatcounter.Hit) error

UpdateStats updates all the stats tables.

Exported for tests.

func WaitACME

func WaitACME()

func WaitDataRetention

func WaitDataRetention()

func WaitEmailReports

func WaitEmailReports()

func WaitOldExports

func WaitOldExports()

func WaitPersistAndStat

func WaitPersistAndStat()

func WaitSessions

func WaitSessions()

func WaitVacuumOldSites

func WaitVacuumOldSites()

Types

type Task

type Task struct {
	Desc   string
	Fun    func(context.Context) error
	Period time.Duration
}

func (Task) ID

func (t Task) ID() string