app

package

v1.1.2 Latest Latest Go to latest Published: Jun 16, 2022 License: BSD-3-Clause Imports: 9 Imported by: 0

Details

This section is empty.

View Source

var Provides = wire.NewSet(New)

This section is empty.

type App struct {
	*common.Inject
	// contains filtered or unexported fields
}

func New(i *common.Inject) *App

func (x *App) PubSync(key string) (err error)

PubSync 发布同步工作

func (x *App) Remove(key string)

Remove 移除任务

func (x *App) Run() (err error)

Run 启动服务

func (x *App) Set(key string, jobs ...common.Job) (err error)

Set 设置任务发布

func (x *App) Start(key string)

Start 启动任务

func (x *App) State(key string) []cron.Entry

State 任务状态

func (x *App) Stop(key string)

Stop 关闭任务

func (x *App) SubState() (err error)

SubState 返回任务状态

func (x *App) SubSync() (err error)

SubSync 节点时间对齐

type Sync struct {
	Key  string
	Time time.Time
}