tasker

Documentation

Index

• type DelayTask
  • func NewDelayTask(duration time.Duration, cb interface{}) (*DelayTask, error)
  • func (task *DelayTask) Start(args ...interface{}) error
  • func (task *DelayTask) Stop()
• type DelayTaskManager
  • func NewDelayTaskManager() *DelayTaskManager
  • func (m *DelayTaskManager) AddTask(name string, duration time.Duration, cb interface{}) error
  • func (m *DelayTaskManager) DeleteTask(name string)
  • func (m *DelayTaskManager) Destroy()
  • func (m *DelayTaskManager) GetTask(name string) (*DelayTask, error)

Types

type DelayTask

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

func NewDelayTask

func NewDelayTask(duration time.Duration,
	cb interface{}) (*DelayTask, error)

func (*DelayTask) Start

func (task *DelayTask) Start(args ...interface{}) error

func (*DelayTask) Stop

func (task *DelayTask) Stop()

type DelayTaskManager

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

func NewDelayTaskManager

func NewDelayTaskManager() *DelayTaskManager

func (*DelayTaskManager) AddTask

func (m *DelayTaskManager) AddTask(name string, duration time.Duration, cb interface{}) error

func (*DelayTaskManager) DeleteTask

func (m *DelayTaskManager) DeleteTask(name string)

func (*DelayTaskManager) Destroy

func (m *DelayTaskManager) Destroy()

func (*DelayTaskManager) GetTask

func (m *DelayTaskManager) GetTask(name string) (*DelayTask, error)