scheduler

Documentation

Index

• func DumpData(file string, data interface{}, overwrite bool)
• type SchedulerPool
  • func (pool *SchedulerPool) Init()
  • func (pool *SchedulerPool) Interrupt()
  • func (pool *SchedulerPool) IsJobActive(id string) bool
  • func (pool *SchedulerPool) IsPaused() bool
  • func (pool *SchedulerPool) IsRunning() bool
  • func (pool *SchedulerPool) IsWorking() bool
  • func (pool *SchedulerPool) NumberOfWorkers() int
  • func (pool *SchedulerPool) Pause()
  • func (pool *SchedulerPool) Resume()
  • func (pool *SchedulerPool) Start(callback func())
  • func (pool *SchedulerPool) Stop()

Functions

func DumpData

func DumpData(file string, data interface{}, overwrite bool)

Types

type SchedulerPool

type SchedulerPool struct {
	Id          string
	Tasks       chan tasks.SchedulerTask
	MaxParallel int
	WG          sync.WaitGroup
	KeepAlive   bool
	PostExecute bool
	Callback    func(task tasks.SchedulerTask)
	State       tasks.SchedulerState
}

func (*SchedulerPool) Init

func (pool *SchedulerPool) Init()

func (*SchedulerPool) Interrupt

func (pool *SchedulerPool) Interrupt()

func (*SchedulerPool) IsJobActive

func (pool *SchedulerPool) IsJobActive(id string) bool

func (*SchedulerPool) IsPaused

func (pool *SchedulerPool) IsPaused() bool

func (*SchedulerPool) IsRunning

func (pool *SchedulerPool) IsRunning() bool

func (*SchedulerPool) IsWorking

func (pool *SchedulerPool) IsWorking() bool

func (*SchedulerPool) NumberOfWorkers

func (pool *SchedulerPool) NumberOfWorkers() int

func (*SchedulerPool) Pause

func (pool *SchedulerPool) Pause()

func (*SchedulerPool) Resume

func (pool *SchedulerPool) Resume()

func (*SchedulerPool) Start

func (pool *SchedulerPool) Start(callback func())

func (*SchedulerPool) Stop

func (pool *SchedulerPool) Stop()