task

Documentation

Index

• 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
• 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

Functions

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)

func WithSchedule

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

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

func (*Server) Start

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

Start server

func (*Server) String

func (e *Server) String() string

String server name