scheduler

package

v0.0.0-...-e457aa1 Latest Latest Go to latest Published: Sep 9, 2021 License: GPL-3.0 Imports: 3 Imported by: 0

Documentation ¶

Overview ¶

Package for scheduling jobs at specified time.

Index ¶

Constants
type ScheduleTask
type ScheduleTaskType
- func (taskType ScheduleTaskType) Get() ScheduleTaskType
type Scheduler
- func GetScheduler(schedulerName string) *Scheduler

Constants ¶

View Source

const (
	ONE_TIME_TASK         ScheduleTaskType = 1
	REPETITIVE_TASK       ScheduleTaskType = 2
	DEFAULT_NO_OF_WORKERS                  = 8
	QUEUE_CAPACITY                         = 100
)

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type ScheduleTask ¶

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

func (*ScheduleTask) GetInterval ¶

func (schTask *ScheduleTask) GetInterval() int

func (*ScheduleTask) GetJob ¶

func (schTask *ScheduleTask) GetJob() routinepool.Job

func (*ScheduleTask) GetName ¶

func (schTask *ScheduleTask) GetName() string

func (*ScheduleTask) GetType ¶

func (schTask *ScheduleTask) GetType() ScheduleTaskType

func (*ScheduleTask) SetInterval ¶

func (schTask *ScheduleTask) SetInterval(interval int)

func (*ScheduleTask) SetJob ¶

func (schTask *ScheduleTask) SetJob(schJob routinepool.Job)

func (*ScheduleTask) SetName ¶

func (schTask *ScheduleTask) SetName(name string)

func (*ScheduleTask) SetType ¶

func (schTask *ScheduleTask) SetType(taskType ScheduleTaskType)

type ScheduleTaskType ¶

type ScheduleTaskType int

func (ScheduleTaskType) Get ¶

func (taskType ScheduleTaskType) Get() ScheduleTaskType

type Scheduler ¶

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

func GetScheduler ¶

func GetScheduler(schedulerName string) *Scheduler

func (*Scheduler) GetLogger ¶

func (sch *Scheduler) GetLogger() *glog.Logger

func (*Scheduler) GetName ¶

func (sch *Scheduler) GetName() string

func (*Scheduler) PerformanceStats ¶

func (sch *Scheduler) PerformanceStats(schedulerName string)

func (*Scheduler) Schedule ¶

func (sch *Scheduler) Schedule(schTask ScheduleTask)

func (*Scheduler) SetLogger ¶

func (sch *Scheduler) SetLogger(logger *glog.Logger)

func (*Scheduler) SetName ¶

func (sch *Scheduler) SetName(name string)

Source Files ¶

View all Source files

scheduler.go

Directories ¶

Path	Synopsis
scheduler_example

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