task

Documentation

Index

• Constants
• Variables
• func NewNamespaceProcessor(cfg *config.CloudConfig) (*namespaceProcessor, error)
• func RegisterNamespaceProcessor(cfg *config.CloudConfig) error
• type ProcessorFunc
• type ProcessorList
• type TaskManager
  • func NewTaskManager(cfg *config.CloudConfig) (*TaskManager, error)
  • func (m *TaskManager) Close()
  • func (m *TaskManager) FetchTask()
  • func (m *TaskManager) RunTasks()
  • func (m *TaskManager) Start()

Constants

const (
	DeleteNamespace        = "delete_namespace"
	DeleteQuotaByNamespace = "delete_quota_by_namespace"
	DeleteIndexByNamespace = "delete_index_by_namespace"
)

Variables

var (
	ErrTaskNotExist    = errors.New("failed to get task, task not exist.")
	ErrProcessConflict = errors.New("failed to add processor, the processor already exist.")
	ErrProcessNotExist = errors.New("failed to unregister processor, the processor not exist.")
)

var TaskRegister = taskRegister{
	// contains filtered or unexported fields
}

Functions

func NewNamespaceProcessor

func NewNamespaceProcessor(cfg *config.CloudConfig) (*namespaceProcessor, error)

func RegisterNamespaceProcessor

func RegisterNamespaceProcessor(cfg *config.CloudConfig) error

Types

type ProcessorFunc

type ProcessorFunc func(task *models.Task) error

type ProcessorList

type ProcessorList []processor

type TaskManager

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

func NewTaskManager

func NewTaskManager(cfg *config.CloudConfig) (*TaskManager, error)

func (*TaskManager) Close

func (m *TaskManager) Close()

func (*TaskManager) FetchTask

func (m *TaskManager) FetchTask()

func (*TaskManager) RunTasks

func (m *TaskManager) RunTasks()

func (*TaskManager) Start

func (m *TaskManager) Start()