Function CreateTaskInSlave

service/node/task.go:25–52

(s *cluster.CreateSlaveTask, c *gin.Context)

)

func CreateTaskInSlave(s *cluster.CreateSlaveTask, c *gin.Context) (int, error) {
	dep := dependency.FromContext(c)
	registry := dep.TaskRegistry()

	props, err := slaveTaskPropsFromContext(c)
	if err != nil {
		return 0, serializer.NewError(serializer.CodeParamErr, "failed to get master props from header", err)
	}

	var t queue.Task
	switch s.Type {
	case queue.SlaveUploadTaskType:
		t = workflows.NewSlaveUploadTask(c, props, registry.NextID(), s.State)
	case queue.SlaveCreateArchiveTaskType:
		t = workflows.NewSlaveCreateArchiveTask(c, props, registry.NextID(), s.State)
	case queue.SlaveExtractArchiveType:
		t = workflows.NewSlaveExtractArchiveTask(c, props, registry.NextID(), s.State)
	default:
		return 0, serializer.NewError(serializer.CodeParamErr, "type not supported", nil)
	}

	if err := dep.SlaveQueue(c).QueueTask(c, t); err != nil {
		return 0, serializer.NewError(serializer.CodeInternalSetting, "failed to queue task", err)
	}

	registry.Set(t.ID(), t)
	return t.ID(), nil
}

type (
	GetSlaveTaskParamCtx struct{}