workflow

Documentation

Index

• type AllWorkflowResponseContainer
• type AllWorkflowsResponseItem
• type ExecutionWithoutLogs
• type FoundWorkFlow
• type Handler
  • func NewHandler() *Handler
  • func (w *Handler) GetAllWorkflowsHandler(c *gin.Context)
  • func (w *Handler) SetUpRoutes(router *gin.RouterGroup)
• type Service
  • func GetWorkflowService() *Service
  • func (w *Service) FindByUser(user string, result interface{}) error
  • func (w *Service) FindOne(id string) (models.Workflow, error)
• type TaskWithoutLogs

Types

type AllWorkflowResponseContainer

type AllWorkflowResponseContainer struct {
	Workflows []AllWorkflowsResponseItem `json:"workflows"`
}

type AllWorkflowsResponseItem

type AllWorkflowsResponseItem struct {
	Id         primitive.ObjectID     `json:"id"`
	Name       string                 `json:"name"`
	User       string                 `json:"user"`
	Executions []ExecutionWithoutLogs `json:"executions"`
}

type ExecutionWithoutLogs

type ExecutionWithoutLogs struct {
	ID           primitive.ObjectID `json:"id"`
	Namespace    string             `json:"namespace"`
	ArgoName     string             `json:"argoName"`
	WorkflowName string             `json:"workflowName"`
	Status       string             `json:"status"`
	WorkflowID   primitive.ObjectID `json:"workflowId"`
	StartedAt    string             `json:"startedAt"`
	FinishedAt   string             `json:"finishedAt"`
	Tasks        []TaskWithoutLogs  `json:"tasks"`
}

type FoundWorkFlow

type FoundWorkFlow struct {
	Id      string   `json:"id"`
	Name    string   `json:"name"`
	Cluster []string `json:"cluster"`
}

type Handler

type Handler struct {
	Service          *Service
	ExecutionService executions.Service
}

func NewHandler

func NewHandler() *Handler

func (*Handler) GetAllWorkflowsHandler

func (w *Handler) GetAllWorkflowsHandler(c *gin.Context)

func (*Handler) SetUpRoutes

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

type Service

type Service struct {
	// contains filtered or unexported fields
}

func GetWorkflowService

func GetWorkflowService() *Service

func (*Service) FindByUser

func (w *Service) FindByUser(user string, result interface{}) error

func (*Service) FindOne

func (w *Service) FindOne(id string) (models.Workflow, error)

type TaskWithoutLogs

type TaskWithoutLogs struct {
	Name       string  `json:"name"`
	BlockID    int     `json:"blockId"`
	Status     string  `json:"status"`
	StartedAt  string  `json:"startedAt"`
	FinishedAt string  `json:"finishedAt"`
	CostLimit  float32 `json:"costLimit"`
	PodName    string  `json:"podName"`
}