Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ExecutionDto ¶
type ExecutionService ¶
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 }
func NewExecutionService ¶
func NewExecutionService(store pipelineStore.PipelineStore, queue queueService.QueueService, intgService integrationService.IntegrationService, utoService utopiopsService.UtopiopsService) ExecutionService
Source Files ¶
- check_access.go
- check_execution_initial_data.go
- check_return_values.go
- delete_execution.go
- execute_tasks.go
- getExecution.go
- get_execution_id_for_pipeline.go
- get_initial_data.go
- get_interaction_res.go
- get_number_of_total_tasks.go
- get_taskId_by_execution.go
- get_task_by_execution.go
- get_tasks_with_status_for_execution.go
- interface.go
- map_fields_utils.go
- set_executiontime.go
- set_task_status_to_timedout.go
- start_pipeline.go
- start_pipeline_by_endpoint.go
- start_pipeline_by_name.go
- task_execution_result.go
Click to show internal directories.
Click to hide internal directories.