scheduler

Documentation

Index

• Variables
• type Driver
  • func NewDiscard() Driver
  • func NewScheduler(storage Storage, runEvery time.Duration, concurrency int) Driver
• type JobExecutor
• type Storage
  • func NewFileScheduler() Storage
  • func NewRedisStorage(client *redis.Client) Storage
  • func NewSQLStorage(db *sqlx.DB) Storage

Variables

var ErrExecutorNotDefined = errors.New("executor not defined for this task")

Types

type Driver

type Driver interface {
	ScheduleTask(ctx context.Context, task string, scheduleAt time.Time, payload []byte) error
	Start(ctx context.Context) <-chan error
	RegisterExecutor(task string, executor JobExecutor)
}

func NewDiscard

func NewDiscard() Driver

func NewScheduler

func NewScheduler(storage Storage, runEvery time.Duration, concurrency int) Driver

type JobExecutor

type JobExecutor func(ctx context.Context, payload []byte) error

type Storage

type Storage interface {
	Store(ctx context.Context, taskName string, scheduleAt time.Time, payload []byte) error
	Retrieve(ctx context.Context) (taskID, taskName string, data []byte, err error)
	Failure(ctx context.Context, taskID string) error
	Done(ctx context.Context, taskID string) error
}

func NewFileScheduler

func NewFileScheduler() Storage

func NewRedisStorage

func NewRedisStorage(client *redis.Client) Storage

func NewSQLStorage

func NewSQLStorage(db *sqlx.DB) Storage