db

Documentation

Index

• type Client
  • func (client *Client) CreatePipelineDefinition(pipelineDefinition *PipelineDefinition, ops ...mysqlxorm.SessionOption) (err error)
  • func (client *Client) DeletePipelineDefinition(id uint64, ops ...mysqlxorm.SessionOption) error
  • func (client *Client) GetPipelineDefinitionByNameAndSource(PipelineSource apistructs.PipelineSource, PipelineYmlName string, ...) (*PipelineDefinition, error)
  • func (client *Client) GetPipelineDefinitionBySnippetConfigOrder(snippetConfig apistructs.SnippetConfigOrder, ops ...mysqlxorm.SessionOption) (*PipelineDefinition, error)
  • func (client *Client) UpdatePipelineDefinition(id uint64, pipelineDefinition *PipelineDefinition, ...) error
• type PipelineDefinition
  • func (PipelineDefinition) TableName() string
• type PipelineDefinitionExtra

Types

type Client

type Client struct {
	mysqlxorm.Interface
}

func (*Client) CreatePipelineDefinition

func (client *Client) CreatePipelineDefinition(pipelineDefinition *PipelineDefinition, ops ...mysqlxorm.SessionOption) (err error)

func (*Client) DeletePipelineDefinition

func (client *Client) DeletePipelineDefinition(id uint64, ops ...mysqlxorm.SessionOption) error

func (*Client) GetPipelineDefinitionByNameAndSource

func (client *Client) GetPipelineDefinitionByNameAndSource(PipelineSource apistructs.PipelineSource, PipelineYmlName string, ops ...mysqlxorm.SessionOption) (*PipelineDefinition, error)

func (*Client) GetPipelineDefinitionBySnippetConfigOrder

func (client *Client) GetPipelineDefinitionBySnippetConfigOrder(snippetConfig apistructs.SnippetConfigOrder, ops ...mysqlxorm.SessionOption) (*PipelineDefinition, error)

func (*Client) UpdatePipelineDefinition

func (client *Client) UpdatePipelineDefinition(id uint64, pipelineDefinition *PipelineDefinition, ops ...mysqlxorm.SessionOption) error

type PipelineDefinition

type PipelineDefinition struct {
	ID              uint64                    `json:"id" xorm:"pk autoincr"`
	PipelineSource  apistructs.PipelineSource `json:"pipelineSource"`
	PipelineYmlName string                    `json:"pipelineYmlName"`
	PipelineYml     string                    `json:"pipelineYml"`
	Extra           PipelineDefinitionExtra   `json:"extra" xorm:"json"`
	VersionLock     uint64                    `json:"versionLock" xorm:"version_lock version"`

	TimeCreated *time.Time `json:"timeCreated,omitempty" xorm:"created_at created"`
	TimeUpdated *time.Time `json:"timeUpdated,omitempty" xorm:"updated_at updated"`
}

func (PipelineDefinition) TableName

func (PipelineDefinition) TableName() string

type PipelineDefinitionExtra

type PipelineDefinitionExtra struct {
	SnippetConfig *apistructs.SnippetConfigOrder      `json:"snippetConfig" xorm:"json:"`
	CreateRequest *apistructs.PipelineCreateRequestV2 `json:"createRequest" xorm:"json:"`
}