executionService

type ExecutionDto struct {
	AccountId   string `json:"account_id" binding:"required"`
	ExecutionId string `json:"execution_id" binding:"required"`
	Seconds     int    `json:"seconds" binding:"required"`
}

type ExecutionService interface {
	// execution
	GetInitialData(executionId int) (models.InputData, int)
	StartPipeline(input map[string]interface{}, accountId, endpoint string) (interface{}, error)
	StartPipelineByEndpoint(input map[string]interface{}, endpoint string) (interface{}, error)
	StartPipelineByName(input map[string]interface{}, accountId, name, tpAccountId, userGroup, projectName string) (interface{}, error)
	GetExecution(string) (interface{}, error)
	GetExecutionDetails(executionId int) (models.Execution, error)
	GetExecutionIdForPipeline(accountId, pipeLineName, projectName string) (int, error)

	// tasks
	SetTaskExecutionStatus(executionId int, taskId int, taskStatus string) error
	SetTaskExecutionResultDetails(executionId int, taskId int, status string, returnValue models.ReturnValueMap, log string) error
	GetTaskExecutionResult(executionId int, taskId int) (interface{}, error)
	GetTaskId(executionId int, taskName string) (int, error)
	SetTaskStatusToTimedout(executionId, taskId int) error
	GetNumberOfTasksByExecution(executionId int) (int, error)
	GetTaskByExecution(executionId, taskId int) (models.TaskDetails, error)
	GetTasksWithStatusForExecution(id int) ([]models.TaskStatusSummery, error)
	SetExecutionTime(executionId int, seconds int) error
	CheckAccess(accId string, excutionId int) (bool, error)
	IsChanged(inputSummeries, lastSummeries []models.TaskStatusSummery) bool
	IsExecutionDone(totalTasks int, currentTasks []models.TaskStatusSummery) bool
}