Versions in this module Expand all Collapse all v1 v1.0.1 Aug 15, 2024 Changes in this version + const Extra + const PipelineCronCronExpr + const PipelineCronEnable + const PipelineCronIsEdge + const PipelineDefinitionID + type Client struct + func (client *Client) BatchDeletePipelineCron(ids []uint64, ops ...mysqlxorm.SessionOption) error + func (client *Client) BatchGetPipelineCronByDefinitionID(definitionIDs []string, ops ...mysqlxorm.SessionOption) (cronList []PipelineCron, err error) + func (client *Client) CreatePipelineCron(cron *PipelineCron, ops ...mysqlxorm.SessionOption) error + func (client *Client) DeletePipelineCron(id uint64, ops ...mysqlxorm.SessionOption) error + func (client *Client) GetDBClient() (db *xorm.Engine) + func (client *Client) GetPipelineCron(id uint64, ops ...mysqlxorm.SessionOption) (cron PipelineCron, bool bool, err error) + func (client *Client) InsertOrUpdatePipelineCron(new_ *PipelineCron, ops ...mysqlxorm.SessionOption) error + func (client *Client) IsCronExist(cron *PipelineCron, ops ...mysqlxorm.SessionOption) (bool bool, err error) + func (client *Client) ListAllPipelineCrons(ops ...mysqlxorm.SessionOption) (crons []PipelineCron, err error) + func (client *Client) ListPipelineCrons(enable *bool, ops ...mysqlxorm.SessionOption) ([]PipelineCron, error) + func (client *Client) PagingPipelineCron(req *pb.CronPagingRequest, ops ...mysqlxorm.SessionOption) ([]PipelineCron, int64, error) + func (client *Client) UpdatePipelineCron(id uint64, cron *PipelineCron, ops ...mysqlxorm.SessionOption) error + func (client *Client) UpdatePipelineCronWillUseDefault(id uint64, cron *PipelineCron, columns []string, ...) error + type PipelineCron struct + ApplicationID uint64 + BasePipelineID uint64 + Branch string + ClusterName string + CronExpr string + Enable *bool + Extra PipelineCronExtra + ID uint64 + IsEdge *bool + PipelineDefinitionID string + PipelineSource apistructs.PipelineSource + PipelineYmlName string + SoftDeletedAt int64 + TimeCreated time.Time + TimeUpdated time.Time + func (PipelineCron) TableName() string + func (pc *PipelineCron) Convert2DTO() *pb.Cron + func (pc *PipelineCron) GenCompensateCreatePipelineReqFilterLabels() map[string]string + func (pc *PipelineCron) GenCompensateCreatePipelineReqNormalLabels(triggerTime time.Time) map[string]string + func (pc *PipelineCron) GetOrgID() uint64 + func (pc *PipelineCron) GetUserID() string + func (pc PipelineCron) GetIsEdge() bool + type PipelineCronExtra struct + ClusterName string + Compensator *pb.CronCompensator + ConfigManageNamespaces []string + CronStartFrom *time.Time + Envs map[string]string + FilterLabels map[string]string + IncomingSecrets map[string]string + LastCompensateAt *time.Time + NormalLabels map[string]string + PipelineYml string + Version string
Go to main page