hostRepo

Documentation

Index

• type TaskRepo
  • func NewTaskRepo() *TaskRepo
  • func (r *TaskRepo) AddRetry(po agentModel.Task) (err error)
  • func (r *TaskRepo) Delete(id uint) (err error)
  • func (r *TaskRepo) Get(id uint) (po agentModel.Task, err error)
  • func (r *TaskRepo) GetActiveTaskByMd5(md5 string) (po agentModel.Task, err error)
  • func (r *TaskRepo) GetActiveTaskByVm(vm string) (po agentModel.Task, err error)
  • func (r *TaskRepo) GetByUrl(url string) (po agentModel.Task, err error)
  • func (r *TaskRepo) GetCompletedTaskByMd5(md5 string) (po agentModel.Task, err error)
  • func (r *TaskRepo) GetDetail(id uint) (po agentModel.Task, err error)
  • func (r *TaskRepo) Query() (pos []agentModel.Task, err error)
  • func (r *TaskRepo) Save(po *agentModel.Task) (err error)
  • func (r *TaskRepo) SetCanceled(po agentModel.Task) (err error)
  • func (r *TaskRepo) SetFailed(po agentModel.Task) (err error)
  • func (r *TaskRepo) Update(po *agentModel.Task) (err error)
  • func (r *TaskRepo) UpdateSpeed(id uint, speed float64) (err error)
  • func (r *TaskRepo) UpdateStatus(id uint, filePath string, completionRate float64, xmlDesc string, ...) (err error)

Types

type TaskRepo

type TaskRepo struct {
	DB *gorm.DB `inject:""`
}

func NewTaskRepo

func NewTaskRepo() *TaskRepo

func (*TaskRepo) AddRetry

func (r *TaskRepo) AddRetry(po agentModel.Task) (err error)

func (*TaskRepo) Delete

func (r *TaskRepo) Delete(id uint) (err error)

func (*TaskRepo) Get

func (r *TaskRepo) Get(id uint) (po agentModel.Task, err error)

func (*TaskRepo) GetActiveTaskByMd5

func (r *TaskRepo) GetActiveTaskByMd5(md5 string) (po agentModel.Task, err error)

func (*TaskRepo) GetActiveTaskByVm

func (r *TaskRepo) GetActiveTaskByVm(vm string) (po agentModel.Task, err error)

func (*TaskRepo) GetByUrl

func (r *TaskRepo) GetByUrl(url string) (po agentModel.Task, err error)

func (*TaskRepo) GetCompletedTaskByMd5

func (r *TaskRepo) GetCompletedTaskByMd5(md5 string) (po agentModel.Task, err error)

func (*TaskRepo) GetDetail

func (r *TaskRepo) GetDetail(id uint) (po agentModel.Task, err error)

func (*TaskRepo) Query

func (r *TaskRepo) Query() (pos []agentModel.Task, err error)

func (*TaskRepo) Save

func (r *TaskRepo) Save(po *agentModel.Task) (err error)

func (*TaskRepo) SetCanceled

func (r *TaskRepo) SetCanceled(po agentModel.Task) (err error)

func (*TaskRepo) SetFailed

func (r *TaskRepo) SetFailed(po agentModel.Task) (err error)

func (*TaskRepo) Update

func (r *TaskRepo) Update(po *agentModel.Task) (err error)

func (*TaskRepo) UpdateSpeed

func (r *TaskRepo) UpdateSpeed(id uint, speed float64) (err error)

func (*TaskRepo) UpdateStatus

func (r *TaskRepo) UpdateStatus(id uint, filePath string, completionRate float64, xmlDesc string,
	status consts.TaskStatus, execInfo string, isStart, isEnd bool) (err error)