executions

package
v0.0.0-...-de2e23a Latest Latest
Warning

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

Go to latest
Published: Mar 31, 2022 License: MIT Imports: 26 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

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

Jump to

Keyboard shortcuts

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