scheduler

package
v0.0.0-...-9021772 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Sep 19, 2019 License: MIT Imports: 13 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func ClearErrors

func ClearErrors(conf *config.Config, msgFactory storage.MessageFactory)

ClearErrors 清理错误日志

func ClearJobHistory

func ClearJobHistory(conf *config.Config, historyStore storage.JobHistoryStore)

ClearJobHistory 清理任务执行历史纪录

func NewDingdingConsumer

func NewDingdingConsumer(cc *container.Container) period_job.Job

NewDingdingConsumer create a new DingdingConsumer

Types

type DingdingConsumer

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

DingdingConsumer is a job used to consuming dingding jobs

func (*DingdingConsumer) Handle

func (d *DingdingConsumer) Handle()

type ServiceProvider

type ServiceProvider struct{}

func (*ServiceProvider) Boot

func (s *ServiceProvider) Boot(app *glacier.Glacier)

func (*ServiceProvider) Register

func (s *ServiceProvider) Register(app *container.Container)

type SyncRelay

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

func NewSyncRelay

func NewSyncRelay(cc *container.Container) *SyncRelay

func (*SyncRelay) Handle

func (syncRelay *SyncRelay) Handle()

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL