cron

README

cron

infra.go cron module.

Documentation

Index

• Constants
• type Config
• type Context
  • func (ctx *Context) Next()
• type Filter
• type Instance
  • func (this *Instance) Serve(name string)
• type Job
• type Module
  • func (this *Module) Configure(global Map)
  • func (this *Module) Connect()
  • func (this *Module) Filter(name string, config Filter)
  • func (this *Module) Initialize()
  • func (this *Module) Job(name string, config Job)
  • func (this *Module) Launch()
  • func (this *Module) Register(name string, value Any)
  • func (this *Module) Terminate()

Constants

const (
	NAME = "CRON"
)

Types

type Config

type Config struct {
	Setting Map
}

type Context

type Context struct {
	infra.Meta

	// 以下几个字段必须独立
	// 要不然，Invoke的时候，会被修改掉
	// 因为invoke是同一个 *Meta 对象
	Name    string
	Config  *Job
	Value   Map
	Args    Map
	Setting Map

	Body Any
	// contains filtered or unexported fields
}

func (*Context) Next

func (ctx *Context) Next()

type Filter

type Filter struct {
	Name   string  `json:"name"`
	Text   string  `json:"text"`
	Action ctxFunc `json:"-"`
}

Filter 拦截器

type Instance

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

func (*Instance) Serve

func (this *Instance) Serve(name string)

type Job

type Job struct {
	Name    string
	Text    string
	Time    string
	Times   []string
	Setting Map  `json:"-"`
	Coding  bool `json:"-"`

	Action  ctxFunc   `json:"-"`
	Actions []ctxFunc `json:"-"`
}

type Module

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

func (*Module) Configure

func (this *Module) Configure(global Map)

func (*Module) Connect

func (this *Module) Connect()

func (*Module) Filter

func (this *Module) Filter(name string, config Filter)

Filter 注册 拦截器

func (*Module) Initialize

func (this *Module) Initialize()

func (*Module) Job

func (this *Module) Job(name string, config Job)

func (*Module) Launch

func (this *Module) Launch()

func (*Module) Register

func (this *Module) Register(name string, value Any)

func (*Module) Terminate

func (this *Module) Terminate()