pipeline

Documentation

Index

• type Controller
  • func NewController() *Controller
  • func (c *Controller) RegisterRoute(group *gin.RouterGroup)
• type Edges
  • func (e *Edges) BeforeCreate(tx *gorm.DB) error
  • func (e *Edges) TableName() string
• type Nodes
  • func (n *Nodes) BeforeCreate(tx *gorm.DB) error
  • func (n *Nodes) TableName() string
• type Params
  • func (p *Params) Scan(value interface{}) error
  • func (p Params) Value() (driver.Value, error)
• type Service
  • func GetService() *Service
  • func (s *Service) AddWorkflow(wf *WorkflowRequest) error
  • func (s *Service) DeleteWorkflow(wf *Workflow) error
  • func (s *Service) GetWorkflow(wf *Workflow) (*WorkflowRequest, error)
  • func (s *Service) Initialize() error
  • func (s *Service) ListWorkflow(wf *Workflow) ([]*WorkflowRequest, error)
  • func (s *Service) UpdateWorkflow(wf *WorkflowRequest) error
• type Workflow
  • func (w *Workflow) BeforeCreate(tx *gorm.DB) error
  • func (w *Workflow) TableName() string
• type WorkflowRequest

Types

type Controller

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

func NewController

func NewController() *Controller

func (*Controller) RegisterRoute

func (c *Controller) RegisterRoute(group *gin.RouterGroup)

type Edges

type Edges struct {
	ID         string `json:"id" gorm:"primary_key;" example:"00000000-0000-0000-0000-000000000000"`
	WorkflowId string `json:"workflowId" example:"00000000-0000-0000-0000-000000000000"`
	Source     string `json:"source" example:"00000000-0000-0000-0000-000000000000"`
	Target     string `json:"target" example:"00000000-0000-0000-0000-000000000000"`

	database.BaseModel
}

func (*Edges) BeforeCreate

func (e *Edges) BeforeCreate(tx *gorm.DB) error

func (*Edges) TableName

func (e *Edges) TableName() string

type Nodes

type Nodes struct {
	ID         string `json:"id" gorm:"primary_key;" example:"00000000-0000-0000-0000-000000000000"`
	WorkflowId string `json:"workflowId" example:"00000000-0000-0000-0000-000000000000"`
	Uses       string `json:"uses" example:"test"`
	Label      string `json:"label" example:"test"`
	Params     Params `json:"params" example:"test"`

	CreatedAt time.Time `json:"createdAt" swaggerignore:"true"`
	UpdatedAt time.Time `json:"updatedAt" swaggerignore:"true"`
}

func (*Nodes) BeforeCreate

func (n *Nodes) BeforeCreate(tx *gorm.DB) error

func (*Nodes) TableName

func (n *Nodes) TableName() string

type Params

type Params []*workflow.TaskParam

func (*Params) Scan

func (p *Params) Scan(value interface{}) error

func (Params) Value

func (p Params) Value() (driver.Value, error)

type Service

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

func GetService

func GetService() *Service

func (*Service) AddWorkflow

func (s *Service) AddWorkflow(wf *WorkflowRequest) error

func (*Service) DeleteWorkflow

func (s *Service) DeleteWorkflow(wf *Workflow) error

func (*Service) GetWorkflow

func (s *Service) GetWorkflow(wf *Workflow) (*WorkflowRequest, error)

func (*Service) Initialize

func (s *Service) Initialize() error

func (*Service) ListWorkflow

func (s *Service) ListWorkflow(wf *Workflow) ([]*WorkflowRequest, error)

func (*Service) UpdateWorkflow

func (s *Service) UpdateWorkflow(wf *WorkflowRequest) error

type Workflow

type Workflow struct {
	ID    string `json:"id" gorm:"primary_key;" example:"00000000-0000-0000-0000-000000000000"`
	Title string `json:"title" example:"test" validate:"required"`
	Owner string `json:"owner" example:"test" validate:"required"`

	database.BaseModel
}

func (*Workflow) BeforeCreate

func (w *Workflow) BeforeCreate(tx *gorm.DB) error

func (*Workflow) TableName

func (w *Workflow) TableName() string

type WorkflowRequest

type WorkflowRequest struct {
	*Workflow
	*workflow.WorkflowDAG
}