Versions in this module Expand all Collapse all v1 v1.0.1 Aug 15, 2024 Changes in this version + type Client struct + func (client *Client) BatchDeletePipelineDefinition(ids []string, ops ...mysqlxorm.SessionOption) error + func (client *Client) BatchDeletePipelineDefinitionExtra(ids []string, ops ...mysqlxorm.SessionOption) error + func (client *Client) CountPipelineDefinition(session *xorm.Session) (int64, error) + func (client *Client) CreatePipelineDefinition(pipelineDefinition *PipelineDefinition, ops ...mysqlxorm.SessionOption) (err error) + func (client *Client) CreatePipelineDefinitionExtra(pipelineDefinitionExtra *PipelineDefinitionExtra, ...) (err error) + func (client *Client) DeletePipelineDefinition(id string, ops ...mysqlxorm.SessionOption) error + func (client *Client) DeletePipelineDefinitionByRemote(remote string, ops ...mysqlxorm.SessionOption) error + func (client *Client) DeletePipelineDefinitionExtraByRemote(remote string, ops ...mysqlxorm.SessionOption) error + func (client *Client) DeletePipelineDefinitionExtraExtra(id string, ops ...mysqlxorm.SessionOption) error + func (client *Client) GetPipelineDefinition(id string, ops ...mysqlxorm.SessionOption) (*PipelineDefinition, error) + func (client *Client) GetPipelineDefinitionBySourceID(sourceID string, ops ...mysqlxorm.SessionOption) (*PipelineDefinition, bool, error) + func (client *Client) GetPipelineDefinitionExtra(id string, ops ...mysqlxorm.SessionOption) (*PipelineDefinitionExtra, error) + func (client *Client) GetPipelineDefinitionExtraByDefinitionID(definitionID string, ops ...mysqlxorm.SessionOption) (*PipelineDefinitionExtra, error) + func (client *Client) GetPipelineDefinitionListInSourceIDs(ids []string, ops ...mysqlxorm.SessionOption) ([]PipelineDefinition, error) + func (client *Client) ListPipelineDefinition(req *pb.PipelineDefinitionListRequest, ops ...mysqlxorm.SessionOption) ([]PipelineDefinitionSource, int64, error) + func (client *Client) ListPipelineDefinitionByRemote(remote string, ops ...mysqlxorm.SessionOption) ([]PipelineDefinitionSource, error) + func (client *Client) ListPipelineDefinitionExtra(idList []string, ops ...mysqlxorm.SessionOption) ([]PipelineDefinitionExtra, error) + func (client *Client) ListPipelineDefinitionExtraByDefinitionIDList(definitionIDList []string, ops ...mysqlxorm.SessionOption) ([]PipelineDefinitionExtra, error) + func (client *Client) ListUsedRef(req *pb.PipelineDefinitionUsedRefListRequest, ops ...mysqlxorm.SessionOption) (refs []string, err error) + func (client *Client) StatisticsGroupByFilePath(req *pb.PipelineDefinitionStatisticsRequest, ops ...mysqlxorm.SessionOption) ([]PipelineDefinitionStatistics, error) + func (client *Client) StatisticsGroupByRemote(req *pb.PipelineDefinitionStatisticsRequest, ops ...mysqlxorm.SessionOption) ([]PipelineDefinitionStatistics, error) + func (client *Client) UpdatePipelineDefinition(id string, pipelineDefinition *PipelineDefinition, ...) error + func (client *Client) UpdatePipelineDefinitionExtra(id string, pipelineDefinitionExtra *PipelineDefinitionExtra, ...) error + type PipelineDefinition struct + Category string + CostTime int64 + Creator string + EndedAt time.Time + ExecutedActionNum int64 + Executor string + ID string + Location string + Name string + PipelineID uint64 + PipelineSourceId string + Ref string + SoftDeletedAt uint64 + StartedAt time.Time + Status string + TimeCreated time.Time + TimeUpdated time.Time + TotalActionNum int64 + func (PipelineDefinition) TableName() string + type PipelineDefinitionExtra struct + Extra apistructs.PipelineDefinitionExtraValue + ID string + PipelineDefinitionID string + PipelineSourceID string + SoftDeletedAt uint64 + TimeCreated *time.Time + TimeUpdated *time.Time + func (PipelineDefinitionExtra) TableName() string + type PipelineDefinitionSource struct + FileName string + Path string + Ref string + Remote string + SourceType string + func (p *PipelineDefinitionSource) Convert() *pb.PipelineDefinition + type PipelineDefinitionStatistics struct + FailedNum uint64 + Group string + RunningNum uint64 + TotalNum uint64
Go to main page