executions

Documentation

Index

• type ExecutionDbRecord
• type Handler
  • func NewHandler() *Handler
  • func (h *Handler) SetUpRoutes(router *gin.RouterGroup)
• type Repository
  • func NewRepository() Repository
• type Service
  • func NewService() Service

Types

type ExecutionDbRecord

type ExecutionDbRecord struct {
	ID           primitive.ObjectID  `bson:"_id,omitempty"`
	Namespace    string              `bson:"namespace"`
	ArgoName     string              `bson:"argoName"`
	WorkflowName string              `bson:"workflowName"`
	Status       string              `bson:"status"`
	WorkflowID   primitive.ObjectID  `bson:"workflowId"`
	StartedAt    *primitive.DateTime `bson:"startedAt"`
	FinishedAt   *primitive.DateTime `bson:"finishedAt"`
	Tasks        []models.Task       `bson:"tasks"`
}

type Handler

type Handler struct {
	Service Service
}

func NewHandler

func NewHandler() *Handler

func (*Handler) SetUpRoutes

func (h *Handler) SetUpRoutes(router *gin.RouterGroup)

type Repository

type Repository interface {
	Insert(execution models.Execution) (*models.Execution, error)
	FindAll(filters models.ExecutionFilters) ([]models.Execution, error)
	FindOne(id string) (models.Execution, error)
	UpdateOne(id string, execution models.Execution) error
	CountStatus(filters models.ExecutionFilters) (*models.ExecutionStatusCount, error)
}

func NewRepository

func NewRepository() Repository

type Service

type Service interface {
	ExecuteWorkflow(workflow models.Workflow) (*models.Execution, error)
	FindAll(filters models.ExecutionFilters) ([]models.Execution, error)
	FindOne(id string) (models.Execution, error)
	CountStatus(filters models.ExecutionFilters) (*models.ExecutionStatusCount, error)
}

func NewService

func NewService() Service