scheduler

Documentation

Index

• type Options
  • func NewOptions() *Options
• type Scheduler
  • func NewScheduler(options *Options) *Scheduler
  • func (scheduler *Scheduler) AddTask(taskID uint64, privData interface{}, fn func(*Task, interface{}) TaskState) *Task
  • func (scheduler *Scheduler) DeleteTask(taskID uint64)
  • func (scheduler *Scheduler) GetAllTasks() []*Task
  • func (scheduler *Scheduler) GetState() SchedulerState
  • func (scheduler *Scheduler) GetTask(taskID uint64) *Task
  • func (scheduler *Scheduler) Start()
  • func (scheduler *Scheduler) Stop()
  • func (scheduler *Scheduler) Trigger(signal SignalType)
• type SchedulerState
• type SignalType
• type Task
  • func NewTask(id uint64, privData interface{}, fn func(*Task, interface{}) TaskState) *Task
  • func (task *Task) Execute()
  • func (task *Task) GetState() TaskState
  • func (task *Task) SetState(state TaskState)
• type TaskState

Types

type Options

type Options struct {
	WorkerCount int
}

func NewOptions

func NewOptions() *Options

type Scheduler

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

func NewScheduler

func NewScheduler(options *Options) *Scheduler

func (*Scheduler) AddTask

func (scheduler *Scheduler) AddTask(taskID uint64, privData interface{}, fn func(*Task, interface{}) TaskState) *Task

func (*Scheduler) DeleteTask

func (scheduler *Scheduler) DeleteTask(taskID uint64)

func (*Scheduler) GetAllTasks

func (scheduler *Scheduler) GetAllTasks() []*Task

func (*Scheduler) GetState

func (scheduler *Scheduler) GetState() SchedulerState

func (*Scheduler) GetTask

func (scheduler *Scheduler) GetTask(taskID uint64) *Task

func (*Scheduler) Start

func (scheduler *Scheduler) Start()

func (*Scheduler) Stop

func (scheduler *Scheduler) Stop()

func (*Scheduler) Trigger

func (scheduler *Scheduler) Trigger(signal SignalType)

type SchedulerState

type SchedulerState int32

const (
	STATE_IDLE SchedulerState = iota
	STATE_AWAKE
)

type SignalType

type SignalType int32

const (
	SIGNAL_AWAKE SignalType = iota
)

type Task

type Task struct {
	ID       uint64
	State    TaskState
	PrivData interface{}
	Handler  func(*Task, interface{}) TaskState
	// contains filtered or unexported fields
}

func NewTask

func NewTask(id uint64, privData interface{}, fn func(*Task, interface{}) TaskState) *Task

func (*Task) Execute

func (task *Task) Execute()

func (*Task) GetState

func (task *Task) GetState() TaskState

func (*Task) SetState

func (task *Task) SetState(state TaskState)

type TaskState

type TaskState int32

const (
	TASK_STATE_IDLE TaskState = iota
	TASK_STATE_PREPARED
	TASK_STATE_RUNNING
)