task

Documentation

Index

• func NewProcess(msg *models.Msg) error
• func NewTaskLog(tlog models.TaskLog) error
• func UpdateTaskStatus(taskID bson.ObjectId, newStatus models.TaskStatus) error
• type MessageHandle
  • func (m *MessageHandle) HandelNewProcess(message *nsq.Message) error
  • func (m *MessageHandle) HandelNewTaskLog(message *nsq.Message) error
  • func (m *MessageHandle) HandleNewStatus(message *nsq.Message) error
  • func (m *MessageHandle) PushTaskLog(tlog *models.TaskLog)

Functions

func NewProcess

func NewProcess(msg *models.Msg) error

NewProcess 更新任务处理进度

func NewTaskLog

func NewTaskLog(tlog models.TaskLog) error

NewTaskLog 记录任务日志

func UpdateTaskStatus

func UpdateTaskStatus(taskID bson.ObjectId, newStatus models.TaskStatus) error

UpdateTaskStatus 更新任务状态

Types

type MessageHandle

type MessageHandle struct {
}

MessageHandle NSQ消息处理

func (*MessageHandle) HandelNewProcess

func (m *MessageHandle) HandelNewProcess(message *nsq.Message) error

HandelNewProcess 更新任务处理进度.

func (*MessageHandle) HandelNewTaskLog

func (m *MessageHandle) HandelNewTaskLog(message *nsq.Message) error

HandelNewTaskLog 处理任务日志

func (*MessageHandle) HandleNewStatus

func (m *MessageHandle) HandleNewStatus(message *nsq.Message) error

HandleNewStatus 更新任务状态

func (*MessageHandle) PushTaskLog

func (m *MessageHandle) PushTaskLog(tlog *models.TaskLog)

PushTaskLog 推送任务日志消息.