scheduler

Documentation

Index

• type Scheduler
  • func NewScheduler() Scheduler
  • func (s *Scheduler) MoveDataUntilExit(conf *config.ImportConfig, db *sql.DB, query *config.QueryModel, ...)

Types

type Scheduler

type Scheduler struct {
	Done chan os.Signal
}

func NewScheduler

func NewScheduler() Scheduler

func (*Scheduler) MoveDataUntilExit

func (s *Scheduler) MoveDataUntilExit(conf *config.ImportConfig, db *sql.DB, query *config.QueryModel, finished chan bool)