Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
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 推送任务日志消息.
Source Files
Click to show internal directories.
Click to hide internal directories.