Documentation
¶
Index ¶
- func CreateTaskDefinition(taskDef *models.TaskDefinition) error
- func DeleteTaskDefinitionById(definitionId uuid.UUID)
- func GetAllTaskDefinitions() []models.TaskDefinition
- func GetExecutionById(executionId uuid.UUID) (*models.TaskExecution, error)
- func GetExecutionStatusHistory(executionId uuid.UUID) []models.ExecutionStatusHistory
- func GetExecutionsToWatch() []models.TaskExecution
- func GetLatestExecutionByDefinitionId(definitionId uuid.UUID) (models.TaskExecution, error)
- func GetPendingTasks() []models.TaskDefinition
- func GetTaskDefinitionById(definitionId uuid.UUID) (models.TaskDefinition, error)
- func GetTasksToTimeout() []models.TaskExecution
- func InsertExecutionStatusUpdate(executionId uuid.UUID, status models.Status)
- func InsertTaskExecution(taskEx *models.TaskExecution) error
- func UpdateDefinition(taskDefinition *models.TaskDefinition)
- func UpdateExecutionStatus(executionId uuid.UUID, status models.Status)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func CreateTaskDefinition ¶
func CreateTaskDefinition(taskDef *models.TaskDefinition) error
func GetAllTaskDefinitions ¶
func GetAllTaskDefinitions() []models.TaskDefinition
func GetExecutionById ¶
func GetExecutionById(executionId uuid.UUID) (*models.TaskExecution, error)
func GetExecutionStatusHistory ¶ added in v0.1.0
func GetExecutionStatusHistory(executionId uuid.UUID) []models.ExecutionStatusHistory
func GetExecutionsToWatch ¶
func GetExecutionsToWatch() []models.TaskExecution
func GetLatestExecutionByDefinitionId ¶
func GetLatestExecutionByDefinitionId(definitionId uuid.UUID) (models.TaskExecution, error)
func GetPendingTasks ¶
func GetPendingTasks() []models.TaskDefinition
func GetTaskDefinitionById ¶
func GetTaskDefinitionById(definitionId uuid.UUID) (models.TaskDefinition, error)
func GetTasksToTimeout ¶
func GetTasksToTimeout() []models.TaskExecution
func InsertExecutionStatusUpdate ¶ added in v0.1.0
func InsertTaskExecution ¶
func InsertTaskExecution(taskEx *models.TaskExecution) error
func UpdateDefinition ¶
func UpdateDefinition(taskDefinition *models.TaskDefinition)
Types ¶
This section is empty.
Click to show internal directories.
Click to hide internal directories.