dao

package
v0.1.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Feb 6, 2024 License: MIT Imports: 6 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func CreateTaskDefinition

func CreateTaskDefinition(taskDef *models.TaskDefinition) error

func DeleteTaskDefinitionById

func DeleteTaskDefinitionById(definitionId uuid.UUID)

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 InsertExecutionStatusUpdate(executionId uuid.UUID, status models.Status)

func InsertTaskExecution

func InsertTaskExecution(taskEx *models.TaskExecution) error

func UpdateDefinition

func UpdateDefinition(taskDefinition *models.TaskDefinition)

func UpdateExecutionStatus

func UpdateExecutionStatus(executionId uuid.UUID, status models.Status)

Types

This section is empty.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL