core

Documentation

Index

• Variables
• type Core
  • func New(opt ...CoreOption) (core *Core, e error)
  • func (c *Core) Add(spec string) (cron.EntryID, error)
  • func (c *Core) GenerateDescription() error
  • func (c *Core) Serve() (e error)
  • func (c *Core) Stop() (e error)
  • func (c *Core) UnsafeJob() error
• type CoreOption
  • func WithAuth(username, password string) CoreOption
  • func WithBackend(backend backend.Backend) CoreOption
  • func WithDescription(description bool) CoreOption
  • func WithImmediate(immediate bool) CoreOption
  • func WithOutput(output string) CoreOption
  • func WithServer(host string, port uint16) CoreOption

Variables

var ErrAlreadyClosed = errors.New(`core already closed`)

Types

type Core

type Core struct {
	*cron.Cron
	// contains filtered or unexported fields
}

Core core

func New

func New(opt ...CoreOption) (core *Core, e error)

New new Core

func (*Core) Add

func (c *Core) Add(spec string) (cron.EntryID, error)

Add add a job for crontab

func (*Core) GenerateDescription

func (c *Core) GenerateDescription() error

func (*Core) Serve

func (c *Core) Serve() (e error)

Serve Perform scheduled tasks

func (*Core) Stop

func (c *Core) Stop() (e error)

Stop Serve

func (*Core) UnsafeJob

func (c *Core) UnsafeJob() error

UnsafeJob .

type CoreOption

type CoreOption interface {
	// contains filtered or unexported methods
}

func WithAuth

func WithAuth(username, password string) CoreOption

func WithBackend

func WithBackend(backend backend.Backend) CoreOption

func WithDescription

func WithDescription(description bool) CoreOption

func WithImmediate

func WithImmediate(immediate bool) CoreOption

func WithOutput

func WithOutput(output string) CoreOption

func WithServer

func WithServer(host string, port uint16) CoreOption