schedulesvc

Documentation

Index

• type ExecuteFunc
• type ScheduleMission
  • func NewMission(missionId, spec string, once bool, runner, before, after ExecuteFunc) *ScheduleMission
• type ScheduleServer
  • func (s *ScheduleServer) AddMission(mission *ScheduleMission) (err error)
  • func (s *ScheduleServer) AppendMission(mission *ScheduleMission) (err error)
  • func (s *ScheduleServer) GetEntries() []SimEntries
  • func (s *ScheduleServer) Init() error
  • func (s *ScheduleServer) RemoveMission(missionId string) error
  • func (s *ScheduleServer) Start() (err error)
• type SimEntries

Types

type ExecuteFunc

type ExecuteFunc func(string)

type ScheduleMission

type ScheduleMission struct {
	// 任务id
	MissionId string

	// 定时 cron 语句
	Spec string

	// 执行函数
	Execute       ExecuteFunc
	ExecuteBefore ExecuteFunc
	ExecuteAfter  ExecuteFunc
	// contains filtered or unexported fields
}

func NewMission

func NewMission(missionId, spec string, once bool, runner, before, after ExecuteFunc) *ScheduleMission

type ScheduleServer

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

var Schedule *ScheduleServer

func (*ScheduleServer) AddMission

func (s *ScheduleServer) AddMission(mission *ScheduleMission) (err error)

服务启动前添加

func (*ScheduleServer) AppendMission

func (s *ScheduleServer) AppendMission(mission *ScheduleMission) (err error)

服务启动后追加

func (*ScheduleServer) GetEntries

func (s *ScheduleServer) GetEntries() []SimEntries

func (*ScheduleServer) Init

func (s *ScheduleServer) Init() error

func (*ScheduleServer) RemoveMission

func (s *ScheduleServer) RemoveMission(missionId string) error

func (*ScheduleServer) Start

func (s *ScheduleServer) Start() (err error)

type SimEntries

type SimEntries struct {
	ID   int
	Next time.Time
	Prev time.Time
}