importer

Dec 3, 2024

Changes in this version

+ func CreateConfigFile(taskDir string, cfgBytes []byte) (string, error)

+ func CreateNewTaskDir(rootDir string, id string) (string, error)

+ func DeleteImportTask(tasksDir, taskID, address, username string) error

+ func GetImportTask(taskID, address, username string) (*types.GetImportTaskData, error)

+ func GetManyImportTask(address, username, space string, pageIndex, pageSize int, status string) (*types.GetManyImportTaskData, error)

+ func InitTask()

+ func NewTaskMgr(serverName string, tackConfig *types.TaskConfig)

+ func StartImport(taskID string) (err error)

+ func StopImportTask(taskID, address, username string) error

+ type Client struct

+ Cfg *types.ImportTaskV2Config

+ HasStarted bool

+ Logger logger.Logger

+ Manager manager.Manager

+ type ImportResult struct

+ ErrorResult struct{ ... }

+ FailedRows int64

+ TaskId string

+ TimeCost string

+ type Task struct

+ Client *Client

+ TaskInfo *db.TaskInfo

+ func UnmarshalTask(byts []byte) (t *Task, err error)

+ func (t *Task) Marshal() (byts []byte, err error)

+ func (t *Task) ToImportTaskData() (result *types.GetImportTaskData, err error)

+ func (t *Task) UpdateQueryStats() error

+ type TaskMgr struct

+ func GetTaskMgr() *TaskMgr

+ func (mgr *TaskMgr) AbortTask(taskID, msg string) (err error)

+ func (mgr *TaskMgr) DelTask(tasksDir, taskID string) error

+ func (mgr *TaskMgr) FinishTask(taskID, status string) (err error)

+ func (mgr *TaskMgr) GetDcron() *dcron.Dcron

+ func (mgr *TaskMgr) GetTask(taskID string) (*Task, bool)

+ func (mgr *TaskMgr) GetTaskInfoByName(taskName string) (task *db.TaskInfo, err error)

+ func (mgr *TaskMgr) NewTask(id, cron, host, user, taskName string, rawConfig string, ...) (*Task, error)

+ func (mgr *TaskMgr) NewTaskDraft(id, host, user, taskName, space, rawCfg string) error

+ func (mgr *TaskMgr) NewTaskEffect(taskEffect *db.TaskEffect) error

+ func (mgr *TaskMgr) PutTask(taskID string, task *Task)

+ func (mgr *TaskMgr) StartTask(info *db.TaskInfo) error

+ func (mgr *TaskMgr) Stop()

+ func (mgr *TaskMgr) StopTask(taskID string) error

+ func (mgr *TaskMgr) StorePartTaskLog(taskID string) error

+ func (mgr *TaskMgr) TurnDraftToTask(id, cron, taskName string, rawCfg string, cfg *types.ImportTaskV2Config) (*Task, error)

+ func (mgr *TaskMgr) UpdateTask(task *Task) error

+ func (mgr *TaskMgr) UpdateTaskDraft(id, taskName, space, rawCfg string) error

+ func (mgr *TaskMgr) UpdateTaskInfo(taskID string) error

+ func (mgr *TaskMgr) UpdateTaskInfoById(task *Task) error