v1

Documentation

Index

• Constants
• Variables
• func Generator() lib.TaskManager
• func NewTaskManager() lib.TaskManager
• type Config
  • func NewConfig() *Config
• type TaskManager
  • func (tm *TaskManager) ExportConfig() ([]byte, error)
  • func (tm *TaskManager) ImportConfig(raw []byte) error
  • func (tm *TaskManager) Initialize() error
  • func (tm *TaskManager) IoC() lib.IoC
  • func (tm *TaskManager) ModuleName() string
  • func (tm *TaskManager) Process(task *models.Task)
  • func (tm *TaskManager) Run()
  • func (tm *TaskManager) SetIoC(ioc lib.IoC)

Constants

const (
	MODULE_NAME = "task_manager/croncache/v1"
)

Variables

var (
	TaskTimeoutError error = errors.New("Task is timed out")
)

Functions

func Generator

func Generator() lib.TaskManager

func NewTaskManager

func NewTaskManager() lib.TaskManager

Types

type Config

type Config struct {
	Tasks map[string]string
}

func NewConfig

func NewConfig() *Config

type TaskManager

type TaskManager struct {
	lib.TaskManager
	// contains filtered or unexported fields
}

func (*TaskManager) ExportConfig

func (tm *TaskManager) ExportConfig() ([]byte, error)

func (*TaskManager) ImportConfig

func (tm *TaskManager) ImportConfig(raw []byte) error

func (*TaskManager) Initialize

func (tm *TaskManager) Initialize() error

func (*TaskManager) IoC

func (tm *TaskManager) IoC() lib.IoC

func (*TaskManager) ModuleName

func (tm *TaskManager) ModuleName() string

func (*TaskManager) Process

func (tm *TaskManager) Process(task *models.Task)

func (*TaskManager) Run

func (tm *TaskManager) Run()

func (*TaskManager) SetIoC

func (tm *TaskManager) SetIoC(ioc lib.IoC)