Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var Log *logging.Logger
Functions ¶
This section is empty.
Types ¶
type HandleInput ¶
type HandleInput func()
type HandleTimeout ¶
type HandleTimeout func(int64)
type Scheduler ¶
type Scheduler struct {
// contains filtered or unexported fields
}
func NewScheduler ¶
func (*Scheduler) AddTaskAction ¶
func (self *Scheduler) AddTaskAction(taskAction TaskAction)
*
- @brief Adds a taskAction to the Workers processing channel *
- @param taskAction Action to be enqueued *
type SchedulerProcessor ¶
type SchedulerProcessor struct {
// contains filtered or unexported fields
}
type Task ¶
type Task struct {
// contains filtered or unexported fields
}
func (*Task) DequeuePacket ¶
func (*Task) EnqueuePacket ¶
func (*Task) HandleInput ¶
func (self *Task) HandleInput()
func (*Task) HandleTimeout ¶
type TaskAction ¶
type TaskAction struct {
// contains filtered or unexported fields
}
func NewTaskAction ¶
func NewTaskAction(task ITask) *TaskAction
func (*TaskAction) Execute ¶
func (self *TaskAction) Execute()
func (*TaskAction) SetTimeoutId ¶
func (self *TaskAction) SetTimeoutId(timeoutId int64)
func (*TaskAction) TimeoutId ¶
func (self *TaskAction) TimeoutId() int64
Source Files
Click to show internal directories.
Click to hide internal directories.