cronjobs

Documentation

Index

• type Service
  • func New(ctx context.Context, key model.ControllerKey, requestSource string, ...) *Service
  • func NewForTesting(ctx context.Context, key model.ControllerKey, requestSource string, ...) *Service
  • func (s *Service) CreatedOrReplacedDeloyment(ctx context.Context) error
  • func (s *Service) DeleteCronJobsForDeployment(ctx context.Context, key model.DeploymentKey) error
  • func (s *Service) NewCronJobsForModule(ctx context.Context, module *schema.Module) ([]model.CronJob, error)
  • func (s *Service) OnJobCompletion(ctx context.Context, key model.CronJobKey, failed bool) (err error)
  • func (s *Service) ScheduleCronJobs(ctx context.Context) (err error)

Types

type Service

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

func New

func New(ctx context.Context, key model.ControllerKey, requestSource string, encryption *encryptionsvc.Service, timeline *timeline.Service, conn *sql.DB) *Service

func NewForTesting

func NewForTesting(ctx context.Context, key model.ControllerKey, requestSource string, encryption *encryptionsvc.Service, timeline *timeline.Service, dal dal.DAL, clock clock.Clock) *Service

func (*Service) CreatedOrReplacedDeloyment

func (s *Service) CreatedOrReplacedDeloyment(ctx context.Context) error

CreatedOrReplacedDeloyment is called by the responsible controller to its cron service, we can schedule all cron jobs here since the cron_jobs rows are locked within the transaction and the controllers won't step on each other.

func (*Service) DeleteCronJobsForDeployment

func (s *Service) DeleteCronJobsForDeployment(ctx context.Context, key model.DeploymentKey) error

func (*Service) NewCronJobsForModule

func (s *Service) NewCronJobsForModule(ctx context.Context, module *schema.Module) ([]model.CronJob, error)

func (*Service) OnJobCompletion

func (s *Service) OnJobCompletion(ctx context.Context, key model.CronJobKey, failed bool) (err error)

OnJobCompletion is called by the controller when a cron job async call completes. We schedule the next execution of the cron job here.

func (*Service) ScheduleCronJobs

func (s *Service) ScheduleCronJobs(ctx context.Context) (err error)

scheduleCronJobs schedules all cron jobs that are not already scheduled.