cronserver

Documentation

Index

• func RegisterCron(cronName string, cron Interface)
• func Run(ctx context.Context, configPath string)
• type Base
  • func (b *Base) AddBaseTaskList(task func(context.Context))
  • func (b *Base) AddProcessAddTaskList(task func(context.Context))
  • func (b *Base) Before(name string, maxConcurrencyCnt int)
  • func (b *Base) Defer(ctx context.Context)
  • func (b *Base) GetIsRun(context.Context) bool
  • func (b *Base) Init(_ Interface)
  • func (b *Base) Process(context.Context)
  • func (b *Base) Run(ctx context.Context)
• type Config
• type ConfigItem
• type CronJobParams
• type DurationJobParams
• type DurationRandomJobParams
• type Interface

Functions

func RegisterCron

func RegisterCron(cronName string, cron Interface)

func Run

func Run(ctx context.Context, configPath string)

Types

type Base

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

func (*Base) AddBaseTaskList

func (b *Base) AddBaseTaskList(task func(context.Context))

func (*Base) AddProcessAddTaskList

func (b *Base) AddProcessAddTaskList(task func(context.Context))

func (*Base) Before

func (b *Base) Before(name string, maxConcurrencyCnt int)

func (*Base) Defer

func (b *Base) Defer(ctx context.Context)

func (*Base) GetIsRun

func (b *Base) GetIsRun(context.Context) bool

func (*Base) Init

func (b *Base) Init(_ Interface)

func (*Base) Process

func (b *Base) Process(context.Context)

func (*Base) Run

func (b *Base) Run(ctx context.Context)

type Config

type Config struct {
	IsRunCron bool
	CronList  []ConfigItem
}

type ConfigItem

type ConfigItem struct {
	Name              string
	MaxConcurrencyCnt int

	JobType                 string
	CronJobParams           CronJobParams
	DurationJobParams       DurationJobParams
	DurationRandomJobParams DurationRandomJobParams
}

type CronJobParams

type CronJobParams struct {
	Crontab string
}

type DurationJobParams

type DurationJobParams struct {
	EveryMillisecond int64
}

type DurationRandomJobParams

type DurationRandomJobParams struct {
	MinMillisecond int64
	MaxMillisecond int64
}

type Interface

type Interface interface {
	GetIsRun(context.Context) bool
	AddBaseTaskList(task func(context.Context))
	AddProcessAddTaskList(task func(context.Context))

	// Init 初始化只会执行一次
	Init(base Interface)
	Process(context.Context)

	Before(name string, maxConcurrencyCnt int)
	Run(context.Context)
	Defer(context.Context)
}

Interface 执行顺序 Before->Process->Run->Defer 只建议重写 Init 和 Process Init 添加固定执行的脚本，使用 AddBaseTaskList 添加，尽量通过该方法添加 Process 添加运行中才能确定执行的脚本，使用 AddProcessAddTaskList 添加