slavetask

Documentation

Index

• type TransferTask
  • func (job *TransferTask) Creator() uint
  • func (job *TransferTask) Do()
  • func (job *TransferTask) GetError() *task.JobError
  • func (job *TransferTask) Model() *model.Task
  • func (job *TransferTask) Props() string
  • func (job *TransferTask) Recycle()
  • func (job *TransferTask) SetError(err *task.JobError)
  • func (job *TransferTask) SetErrorMsg(msg string, err error)
  • func (job *TransferTask) SetStatus(status int)
  • func (job *TransferTask) Type() int

Types

type TransferTask

type TransferTask struct {
	Err      *task.JobError
	Req      *serializer.SlaveTransferReq
	MasterID string
}

TransferTask 文件中转任务

func (*TransferTask) Creator

func (job *TransferTask) Creator() uint

Creator 获取创建者ID

func (*TransferTask) Do

func (job *TransferTask) Do()

Do 开始执行任务

func (*TransferTask) GetError

func (job *TransferTask) GetError() *task.JobError

GetError 返回任务失败信息

func (*TransferTask) Model

func (job *TransferTask) Model() *model.Task

Model 获取任务的数据库模型

func (*TransferTask) Props

func (job *TransferTask) Props() string

Props 获取任务属性

func (*TransferTask) Recycle

func (job *TransferTask) Recycle()

Recycle 回收临时文件

func (*TransferTask) SetError

func (job *TransferTask) SetError(err *task.JobError)

SetError 设定任务失败信息

func (*TransferTask) SetErrorMsg

func (job *TransferTask) SetErrorMsg(msg string, err error)

SetErrorMsg 设定任务失败信息

func (*TransferTask) SetStatus

func (job *TransferTask) SetStatus(status int)

SetStatus 设定状态

func (*TransferTask) Type

func (job *TransferTask) Type() int

Type 获取任务类型