task

Documentation

Index

• Constants
• Variables
• type TaskInfo
  • func (ti *TaskInfo) CloseBound()
  • func (ti *TaskInfo) CloseSockJSSession(reason string, status uint32)
  • func (ti *TaskInfo) GetBound() chan error
  • func (ti *TaskInfo) GetId() int
  • func (ti *TaskInfo) IntoBound(msg error)
  • func (ti *TaskInfo) SendMsg(msg interface{})
  • func (ti *TaskInfo) SetBound(c chan error)
  • func (ti *TaskInfo) SetId(id int)
  • func (ti *TaskInfo) SetSockJSSession(s sockjs.Session)
• type TaskMap
  • func (ti *TaskMap) Close(id int, reason string, status uint32)
  • func (ti *TaskMap) Get(id int) wsTaskInfo.WsTaskInfo
  • func (ti *TaskMap) GetCount() int
  • func (ti *TaskMap) Set(id int, task wsTaskInfo.WsTaskInfo)

Constants

const (
	StatusNew     = 0 //新建
	StatusRunning = 1 //运行中
	StatusEnd     = 2 //已完成
	StatusError   = 3 //错误
)

任务状态

Variables

var TaskInfos = &TaskMap{TaskInfos: make(map[int]wsTaskInfo.WsTaskInfo)}

Types

type TaskInfo

type TaskInfo struct {
	Name     string
	Path     string
	Progress *model.StatusUpdate
	wsTaskInfo.WsTaskInfo
	// contains filtered or unexported fields
}

func (*TaskInfo) CloseBound

func (ti *TaskInfo) CloseBound()

func (*TaskInfo) CloseSockJSSession

func (ti *TaskInfo) CloseSockJSSession(reason string, status uint32)

func (*TaskInfo) GetBound

func (ti *TaskInfo) GetBound() chan error

func (*TaskInfo) GetId

func (ti *TaskInfo) GetId() int

func (*TaskInfo) IntoBound

func (ti *TaskInfo) IntoBound(msg error)

func (*TaskInfo) SendMsg

func (ti *TaskInfo) SendMsg(msg interface{})

func (*TaskInfo) SetBound

func (ti *TaskInfo) SetBound(c chan error)

func (*TaskInfo) SetId

func (ti *TaskInfo) SetId(id int)

func (*TaskInfo) SetSockJSSession

func (ti *TaskInfo) SetSockJSSession(s sockjs.Session)

type TaskMap

type TaskMap struct {
	TaskInfos map[int]wsTaskInfo.WsTaskInfo
	Lock      sync.Mutex
	wsTaskInfo.WsTask
}

func (*TaskMap) Close

func (ti *TaskMap) Close(id int, reason string, status uint32)

func (*TaskMap) Get

func (ti *TaskMap) Get(id int) wsTaskInfo.WsTaskInfo

func (*TaskMap) GetCount

func (ti *TaskMap) GetCount() int

GetCount 获取进行中任务数量

func (*TaskMap) Set

func (ti *TaskMap) Set(id int, task wsTaskInfo.WsTaskInfo)