schedule

Documentation

Overview

package schedule provides utilities for managing template and workspace autostart and autostop schedules. This includes utilities for parsing and deserializing cron-style expressions.

Index

• type MockTemplateScheduleStore
  • func (m MockTemplateScheduleStore) GetTemplateScheduleOptions(ctx context.Context, db database.Store, templateID uuid.UUID) (TemplateScheduleOptions, error)
  • func (m MockTemplateScheduleStore) SetTemplateScheduleOptions(ctx context.Context, db database.Store, template database.Template, ...) (database.Template, error)
• type Schedule
  • func Weekly(raw string) (*Schedule, error)
  • func (s Schedule) Cron() string
  • func (s Schedule) DaysOfWeek() string
  • func (s Schedule) Location() *time.Location
  • func (s Schedule) Min() time.Duration
  • func (s Schedule) Next(t time.Time) time.Time
  • func (s Schedule) String() string
  • func (s Schedule) Time() string
• type TemplateScheduleOptions
• type TemplateScheduleStore
  • func NewAGPLTemplateScheduleStore() TemplateScheduleStore

Types

type MockTemplateScheduleStore

type MockTemplateScheduleStore struct {
	GetFn func(ctx context.Context, db database.Store, templateID uuid.UUID) (TemplateScheduleOptions, error)
	SetFn func(ctx context.Context, db database.Store, template database.Template, options TemplateScheduleOptions) (database.Template, error)
}

func (MockTemplateScheduleStore) GetTemplateScheduleOptions

func (m MockTemplateScheduleStore) GetTemplateScheduleOptions(ctx context.Context, db database.Store, templateID uuid.UUID) (TemplateScheduleOptions, error)

func (MockTemplateScheduleStore) SetTemplateScheduleOptions

func (m MockTemplateScheduleStore) SetTemplateScheduleOptions(ctx context.Context, db database.Store, template database.Template, options TemplateScheduleOptions) (database.Template, error)

type Schedule

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

Schedule represents a cron schedule. It's essentially a wrapper for robfig/cron/v3 that has additional convenience methods.

func Weekly

func Weekly(raw string) (*Schedule, error)

Weekly parses a Schedule from spec scoped to a recurring weekly event. Spec consists of the following space-delimited fields, in the following order: - timezone e.g. CRON_TZ=US/Central (optional) - minutes of hour e.g. 30 (required) - hour of day e.g. 9 (required) - day of month (must be *) - month (must be *) - day of week e.g. 1 (required)

Example Usage:

local_sched, _ := schedule.Weekly("59 23 *")
fmt.Println(sched.Next(time.Now().Format(time.RFC3339)))
// Output: 2022-04-04T23:59:00Z

us_sched, _ := schedule.Weekly("CRON_TZ=US/Central 30 9 1-5")
fmt.Println(sched.Next(time.Now()).Format(time.RFC3339))
// Output: 2022-04-04T14:30:00Z

func (Schedule) Cron

func (s Schedule) Cron() string

Cron returns the cron spec for the schedule with the leading CRON_TZ stripped, if present.

func (Schedule) DaysOfWeek

func (s Schedule) DaysOfWeek() string

DaysOfWeek returns a humanized form of the day-of-week field.

func (Schedule) Location

func (s Schedule) Location() *time.Location

Location returns the IANA location for the schedule.

func (Schedule) Min

func (s Schedule) Min() time.Duration

Min returns the minimum duration of the schedule. This is calculated as follows:

• Let t(0) be a given point in time (1970-01-01T01:01:01Z00:00)
• Let t(max) be 168 hours after t(0).
• Let t(1) be the next scheduled time after t(0).
• Let t(n) be the next scheduled time after t(n-1).
• Then, the minimum duration of s d(min) = min( t(n) - t(n-1) ∀ n ∈ N, t(n) < t(max) )

func (Schedule) Next

func (s Schedule) Next(t time.Time) time.Time

Next returns the next time in the schedule relative to t.

func (Schedule) String

func (s Schedule) String() string

String serializes the schedule to its original human-friendly format. The leading CRON_TZ is maintained.

func (Schedule) Time

func (s Schedule) Time() string

Time returns a humanized form of the minute and hour fields.

type TemplateScheduleOptions

type TemplateScheduleOptions struct {
	UserAutostartEnabled bool          `json:"user_autostart_enabled"`
	UserAutostopEnabled  bool          `json:"user_autostop_enabled"`
	DefaultTTL           time.Duration `json:"default_ttl"`
	// If MaxTTL is set, the workspace must be stopped before this time or it
	// will be stopped automatically.
	//
	// If set, users cannot disable automatic workspace shutdown.
	MaxTTL time.Duration `json:"max_ttl"`
	// FailureTTL dictates the duration after which failed workspaces will be stopped automatically.
	FailureTTL time.Duration `json:"failure_ttl"`
	// InactivityTTL dictates the duration after which inactive workspaces will be locked.
	InactivityTTL time.Duration `json:"inactivity_ttl"`
	// LockedTTL dictates the duration after which locked workspaces will be permanently deleted.
	LockedTTL time.Duration `json:"locked_ttl"`
}

type TemplateScheduleStore

type TemplateScheduleStore interface {
	GetTemplateScheduleOptions(ctx context.Context, db database.Store, templateID uuid.UUID) (TemplateScheduleOptions, error)
	SetTemplateScheduleOptions(ctx context.Context, db database.Store, template database.Template, opts TemplateScheduleOptions) (database.Template, error)
}

TemplateScheduleStore provides an interface for retrieving template scheduling options set by the template/site admin.

func NewAGPLTemplateScheduleStore

func NewAGPLTemplateScheduleStore() TemplateScheduleStore