cron

Documentation

Index

• func CalcNewNext(schedule string, now time.Time) (time.Time, error)
• func CreatePipeline(ctx context.Context, store store.Store, cron *model.Cron) (*model.Repo, *model.Pipeline, error)
• func Run(ctx context.Context, store store.Store) error

Functions

func CalcNewNext

func CalcNewNext(schedule string, now time.Time) (time.Time, error)

CalcNewNext parses a cron string and calculates the next exec time based on it.

func CreatePipeline

func CreatePipeline(ctx context.Context, store store.Store, cron *model.Cron) (*model.Repo, *model.Pipeline, error)

func Run

func Run(ctx context.Context, store store.Store) error

Run starts the cron scheduler loop.