task

Documentation

Index

• func Entry(entryID cron.EntryID) cron.Entry
• func GetJob(key string) (string, cron.Job, bool)
• func RemoveJob(key string) error
• func UpdateJob(key string, spec string, job cron.Job) error
• type Option
  • func WithSchedule(key string, spec string, job cron.Job) Option
  • func WithStorage(s Storage) Option
• type Server
  • func New(opts ...Option) *Server
  • func (e *Server) Options(opts ...Option)
  • func (e *Server) Shutdown(_ context.Context) error
  • func (e *Server) Start(ctx context.Context) error
  • func (e *Server) String() string
• type Storage

Functions

func Entry

func Entry(entryID cron.EntryID) cron.Entry

Entry get entry

func GetJob

func GetJob(key string) (string, cron.Job, bool)

GetJob get job

func RemoveJob

func RemoveJob(key string) error

RemoveJob remove job

func UpdateJob

func UpdateJob(key string, spec string, job cron.Job) error

UpdateJob update or create job

Types

type Option

type Option func(*options)

Option params set

func WithSchedule

func WithSchedule(key string, spec string, job cron.Job) Option

WithSchedule set schedule

func WithStorage

func WithStorage(s Storage) Option

WithStorage set storage

type Server

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

Server manage

func New

func New(opts ...Option) *Server

New server

func (*Server) Options

func (e *Server) Options(opts ...Option)

Options set options

func (*Server) Shutdown

func (e *Server) Shutdown(_ context.Context) error

Shutdown server

func (*Server) Start

func (e *Server) Start(ctx context.Context) error

Start server

func (*Server) String

func (e *Server) String() string

String server name

type Storage

type Storage interface {
	Get(key string) (entryID cron.EntryID, spec string, job cron.Job, exist bool, err error)
	Set(key string, entryID cron.EntryID, spec string, job cron.Job) error
	Update(key string, entryID cron.EntryID) error
	Remove(key string) error
	ListKeys() ([]string, error)
}

Storage storage interface