cron

package
v0.14.2 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Nov 30, 2024 License: MIT Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func ScheduleJob

func ScheduleJob(fn func(context.Context) error) sutureext.ServiceFunc

ScheduleJob is used to defer job scheduling after the Scheduler has been started by Suture. Any error will kill the parent supervisor tree.

Types

type AttachmentOrphan

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

AttachmentOrphan

func NewAttachmentOrphan

func NewAttachmentOrphan(app core.App) AttachmentOrphan

func (AttachmentOrphan) Description

func (AttachmentOrphan) Description() string

func (AttachmentOrphan) Execute

func (r AttachmentOrphan) Execute(ctx context.Context)

func (AttachmentOrphan) Key

func (r AttachmentOrphan) Key() int

type DatabaseVacuum

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

DatabaseVacuum

func NewDatabaseVacuum

func NewDatabaseVacuum(app core.App) DatabaseVacuum

func (DatabaseVacuum) Description

func (DatabaseVacuum) Description() string

func (DatabaseVacuum) Execute

func (r DatabaseVacuum) Execute(ctx context.Context)

func (DatabaseVacuum) Key

func (r DatabaseVacuum) Key() int

type Healthcheck

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

Healthcheck

func NewHealthcheck

func NewHealthcheck(app core.App, url string) Healthcheck

func (Healthcheck) Description

func (Healthcheck) Description() string

func (Healthcheck) Execute

func (r Healthcheck) Execute(ctx context.Context)

func (Healthcheck) Key

func (r Healthcheck) Key() int

type RetentionPolicy

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

RetentionPolicy

func NewRetentionPolicy

func NewRetentionPolicy(app core.App) RetentionPolicy

func (RetentionPolicy) Description

func (RetentionPolicy) Description() string

func (RetentionPolicy) Execute

func (r RetentionPolicy) Execute(ctx context.Context)

func (RetentionPolicy) Key

func (r RetentionPolicy) Key() int

type Scheduler

type Scheduler struct {
	*quartz.StdScheduler
}

func NewScheduler

func NewScheduler() Scheduler

func (Scheduler) Serve

func (s Scheduler) Serve(ctx context.Context) error

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL