cron

Documentation

Index

• type Engine
  • func New(configOptions ...Options) *Engine
  • func (eg *Engine) RegisterScheduler(pattern string, handler HandlerFunc)
  • func (eg *Engine) Start()
  • func (eg *Engine) Stop()
  • func (eg *Engine) Wrap(wrapper Wrapper)
• type HandlerFunc
• type Options
  • func WithTimeZone(timeZone string) Options
• type Response
  • func NewResponse() *Response
  • func (r *Response) SetError(err error) *Response
  • func (r *Response) SetProcessName(name string) *Response
• type Wrapper

Types

type Engine

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

func New

func New(configOptions ...Options) *Engine

func (*Engine) RegisterScheduler

func (eg *Engine) RegisterScheduler(pattern string, handler HandlerFunc)

func (*Engine) Start

func (eg *Engine) Start()

func (*Engine) Stop

func (eg *Engine) Stop()

func (*Engine) Wrap

func (eg *Engine) Wrap(wrapper Wrapper)

type HandlerFunc

type HandlerFunc func(ctx context.Context) *Response

type Options

type Options func(*option)

func WithTimeZone

func WithTimeZone(timeZone string) Options

type Response

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

func NewResponse

func NewResponse() *Response

func (*Response) SetError

func (r *Response) SetError(err error) *Response

func (*Response) SetProcessName

func (r *Response) SetProcessName(name string) *Response

type Wrapper

type Wrapper interface {
	WrapToContext(ctx context.Context) context.Context
}