scheduler

Documentation

Index

• type Manager
  • func NewManager(ctx context.Context, dao dao.Storage) (*Manager, error)
  • func (m *Manager) InitSchedulers(schedules ...Scheduler) error
  • func (m *Manager) Schedule() error
  • func (m *Manager) Stop()
• type Scheduler

Types

type Manager

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

func NewManager

func NewManager(ctx context.Context, dao dao.Storage) (*Manager, error)

NewManager create schedule manager

func (*Manager) InitSchedulers

func (m *Manager) InitSchedulers(schedules ...Scheduler) error

func (*Manager) Schedule

func (m *Manager) Schedule() error

func (*Manager) Stop

func (m *Manager) Stop()

type Scheduler

type Scheduler interface {
	GetName() string
	Init(taskTypes.InitConfigs) error
	Schedule(ctx context.Context, task *taskTypes.Task) error
}