job

Documentation

Index

• func AggregateCheckStatus1d(ctx context.Context) (error, int)
• func AggregateCheckStatus1h(ctx context.Context) (error, int)
• func DeleteOldCheckStatuses(ctx context.Context, retention int) (error, int)
• func DeleteOldCheckStatuses1d(ctx context.Context, retention int) (error, int)
• func DeleteOldCheckStatuses1h(ctx context.Context, retention int) (error, int)
• func RefreshCheckStatusSummary(ctx context.Context) error
• func RefreshCheckStatusSummaryAged(ctx context.Context) error
• type Job
  • func NewJob(ctx context.Context, name string, schedule string, ...) *Job
  • func (j *Job) AddToScheduler(cronRunner *cron.Cron) error
  • func (j Job) GetEntry(cronRunner *cron.Cron) *cron.Entry
  • func (j Job) RemoveFromScheduler(cronRunner *cron.Cron)
  • func (j Job) Run()
  • func (j *Job) RunOnStart() *Job
  • func (j *Job) SetID(id string) *Job
  • func (j *Job) SetTimeout(t time.Duration) *Job
  • func (j *Job) Unschedule()
• type JobRuntime
  • func (j *JobRuntime) Failf(message string, args ...interface{})

Functions

func AggregateCheckStatus1d

func AggregateCheckStatus1d(ctx context.Context) (error, int)

func AggregateCheckStatus1h

func AggregateCheckStatus1h(ctx context.Context) (error, int)

func DeleteOldCheckStatuses

func DeleteOldCheckStatuses(ctx context.Context, retention int) (error, int)

func DeleteOldCheckStatuses1d

func DeleteOldCheckStatuses1d(ctx context.Context, retention int) (error, int)

func DeleteOldCheckStatuses1h

func DeleteOldCheckStatuses1h(ctx context.Context, retention int) (error, int)

func RefreshCheckStatusSummary

func RefreshCheckStatusSummary(ctx context.Context) error

func RefreshCheckStatusSummaryAged

func RefreshCheckStatusSummaryAged(ctx context.Context) error

Types

type Job

type Job struct {
	context.Context
	Name       string
	Schedule   string
	Singleton  bool
	Timeout    time.Duration
	Fn         func(ctx JobRuntime) error
	JobHistory bool
	RunNow     bool
	ID         string
	// contains filtered or unexported fields
}

func NewJob

func NewJob(ctx context.Context, name string, schedule string, fn func(ctx JobRuntime) error) *Job

func (*Job) AddToScheduler

func (j *Job) AddToScheduler(cronRunner *cron.Cron) error

func (Job) GetEntry

func (j Job) GetEntry(cronRunner *cron.Cron) *cron.Entry

func (Job) RemoveFromScheduler

func (j Job) RemoveFromScheduler(cronRunner *cron.Cron)

func (Job) Run

func (j Job) Run()

func (*Job) RunOnStart

func (j *Job) RunOnStart() *Job

func (*Job) SetID

func (j *Job) SetID(id string) *Job

func (*Job) SetTimeout

func (j *Job) SetTimeout(t time.Duration) *Job

func (*Job) Unschedule

func (j *Job) Unschedule()

type JobRuntime

type JobRuntime struct {
	context.Context
	Job       Job
	Span      trace.Span
	History   *models.JobHistory
	Started   time.Time
	Ended     time.Time
	Table, Id string
}

func (*JobRuntime) Failf

func (j *JobRuntime) Failf(message string, args ...interface{})