Method createTaskWithCompletion

pkg/mockpve/state.go:406–431

(node, taskType, id, user string, onComplete func())

}

func (s *MockState) createTaskWithCompletion(node, taskType, id, user string, onComplete func()) string {
	s.mu.Lock()
	defer s.mu.Unlock()

	hexTime := fmt.Sprintf("%X", time.Now().Unix())
	upid := fmt.Sprintf("UPID:%s:%s:%s:%s:%s:%s:%s:", node, hexTime, "00000000", "00000000", taskType, id, user)

	task := &MockTask{
		UPID:       upid,
		Node:       node,
		Type:       taskType,
		ID:         id,
		User:       user,
		StartTime:  time.Now().Unix(),
		Status:     taskStatusRunning,
		onComplete: onComplete,
	}
	s.Tasks[upid] = task

	go func(upid string) {
		time.Sleep(s.taskDelay)
		s.CompleteTask(upid, "OK")
	}(upid)

	return upid
}

func (s *MockState) CompleteTask(upid, exitStatus string) {
	s.mu.Lock()