spec

package

Go to main page

Versions in this module

v1

v1.5.0

Jan 6, 2022

Changes in this version

+ const CtxExecutorChDataVersionPrefix

+ type ExecutorDoneChanData struct

+ Data interface{}

+ Version string

type PipelineCron

+ func (pc *PipelineCron) GenCompensateCreatePipelineReqFilterLabels() map[string]string

+ func (pc *PipelineCron) GenCompensateCreatePipelineReqNormalLabels(triggerTime time.Time) map[string]string

type PipelineTask

+ Inspect apistructs.PipelineTaskInspect

+ func (pt *PipelineTask) CheckExecutorDoneChanDataVersion(actualVersion string) error

+ func (pt *PipelineTask) GenerateExecutorDoneChanDataVersion() string

+ func (pt *PipelineTask) GetMetadata() apistructs.Metadata

type PipelineTaskExtra

+ CurrentPolicy apistructs.Policy

v1.4.0

Nov 16, 2021

Changes in this version

type RuntimeResource

+ MaxCPU float64

+ MaxMemory float64

v1.3.2

Oct 19, 2021

v1.3.1

Oct 14, 2021

v1.3.0

Oct 11, 2021

Changes in this version

+ const CtxExecutorChKeyPrefix

+ func MakeTaskExecutorCtxKey(task *PipelineTask) string

type Pipeline

+ func (p *Pipeline) GetUserID() string

type PipelineCron

+ func (pc *PipelineCron) GetOrgID() uint64

+ func (pc *PipelineCron) GetUserID() string

type PipelineExtraInfo

+ NotPipelineControlledNs bool

+ TaskOperates []apistructs.PipelineTaskOperateRequest

type PipelineTaskExecutorKind

+ var PipelineTaskExecutorKindWait PipelineTaskExecutorKind = "WAIT"

type PipelineTaskExecutorName

+ var PipelineTaskExecutorNameWaitDefault PipelineTaskExecutorName = "wait"

type PipelineTaskExtra

+ NotPipelineControlledNs bool

+ TaskContainers []apistructs.TaskContainer

v1.3.0-rc

Sep 10, 2021

v1.2.2

Sep 7, 2021

Changes in this version

type PipelineTaskExtra

+ EncryptSecretKeys []string

type Snapshot

+ EncryptSecretKeys []string

v1.2.1

Aug 20, 2021

v1.2.0

Aug 13, 2021

Changes in this version

type QueueInfo

+ PriorityChangeHistory []int64

v1.2.0-rc

Aug 2, 2021

v1.1.1

Aug 3, 2021

v1.1.0

Jul 31, 2021

Changes in this version

+ const Extra

type PipelineTaskExecutorKind

+ var PipelineTaskExecutorKindList = []PipelineTaskExecutorKind{ ... }

+ func (that PipelineTaskExecutorKind) Check() bool

+ type PipelineTaskExecutorName string

+ var PipelineTaskExecutorNameList = []PipelineTaskExecutorName{ ... }

+ func (that PipelineTaskExecutorName) Check() bool

+ func (that PipelineTaskExecutorName) String() string

+ type TaskExecutorConfig struct

+ ClusterName string

+ Kind string

+ Name string

+ Options map[string]string

v1.1.0-rc

Jul 8, 2021

v1.0.1

Jul 5, 2021

v1.0.0

Jun 8, 2021

v1.0.0-rc

May 24, 2021

v1.0.0-RC

May 21, 2021

v0

v0.0.1

May 21, 2021

Changes in this version

+ const PipelineCronCronExpr

+ const PipelineCronEnable

+ const StoreTypeNFSProto

+ var PipelineTaskExecutorNameAPITestDefault = "api-test"

+ var PipelineTaskExecutorNameEmpty = ""

+ var PipelineTaskExecutorNameSchedulerDefault = "scheduler"

+ type ActionExecutorConfig struct

+ Kind string

+ Name string

+ Options map[string]string

+ type CIV3BuildArtifact struct

+ ClusterName string

+ Content string

+ CreatedAt time.Time

+ ID int64

+ IdentityText string

+ PipelineID uint64

+ Sha256 string

+ Type apistructs.BuildArtifactType

+ UpdatedAt time.Time

+ func (*CIV3BuildArtifact) TableName() string

+ func (artifact *CIV3BuildArtifact) Convert2DTO() *apistructs.BuildArtifact

+ type CIV3BuildCache struct

+ ClusterName string

+ CreatedAt time.Time

+ DeletedAt time.Time

+ ID int64

+ LastPullAt time.Time

+ Name string

+ UpdatedAt time.Time

+ func (*CIV3BuildCache) TableName() string

+ type FlinkSparkConf struct

+ Depend string

+ JarResource string

+ MainArgs []string

+ MainClass string

+ type Pipeline struct

+ Labels map[string]string

+ func (p *Pipeline) DecodeV1UniquePipelineYmlName(name string) string

+ func (p *Pipeline) EnsureGC()

+ func (p *Pipeline) GenIdentityInfo() apistructs.IdentityInfo

+ func (p *Pipeline) GenerateNormalLabelsForCreateV2() map[string]string

+ func (p *Pipeline) GenerateV1UniquePipelineYmlName(originPipelineYmlPath string) string

+ func (p *Pipeline) GetCancelUserID() string

+ func (p *Pipeline) GetConfigManageNamespaces() []string

+ func (p *Pipeline) GetLabel(labelKey string) string

+ func (p *Pipeline) GetPipelineAppliedResources() apistructs.PipelineAppliedResources

+ func (p *Pipeline) GetPipelineQueueID() (uint64, bool)

+ func (p *Pipeline) GetResourceGCTTL() uint64

+ func (p *Pipeline) GetRunUserID() string

+ func (p *Pipeline) GetSubmitUserID() string

+ func (p *Pipeline) MergeLabels() map[string]string

+ type PipelineArchive struct

+ Content PipelineArchiveContent

+ DiceVersion string

+ ID uint64

+ PipelineID uint64

+ PipelineSource apistructs.PipelineSource

+ PipelineYmlName string

+ Status apistructs.PipelineStatus

+ TimeCreated time.Time

+ TimeUpdated time.Time

+ func (*PipelineArchive) TableName() string

+ type PipelineArchiveContent struct

+ Pipeline Pipeline

+ PipelineLabels []PipelineLabel

+ PipelineReports []PipelineReport

+ PipelineStages []PipelineStage

+ PipelineTasks []PipelineTask

+ type PipelineBase struct

+ ClusterName string

+ CostTimeSec int64

+ CronID *uint64

+ ID uint64

+ IsSnippet bool

+ ParentPipelineID *uint64

+ ParentTaskID *uint64

+ PipelineSource apistructs.PipelineSource

+ PipelineYmlName string

+ Status apistructs.PipelineStatus

+ TimeBegin *time.Time

+ TimeCreated *time.Time

+ TimeEnd *time.Time

+ TimeUpdated *time.Time

+ TriggerMode apistructs.PipelineTriggerMode

+ Type apistructs.PipelineType

+ func (*PipelineBase) TableName() string

+ type PipelineCmsConfig struct

+ Encrypt *bool

+ Extra PipelineCmsConfigExtra

+ ID uint64

+ Key string

+ NsID uint64

+ TimeCreated *time.Time

+ TimeUpdated *time.Time

+ Type apistructs.PipelineCmsConfigType

+ Value string

+ func (PipelineCmsConfig) TableName() string

+ func (c PipelineCmsConfig) BeforeSet(fieldName string, cell xorm.Cell)

+ func (c PipelineCmsConfig) Equal(another PipelineCmsConfig) bool

+ type PipelineCmsConfigExtra struct

+ Comment string

+ From string

+ Operations *apistructs.PipelineCmsConfigOperations

+ func (extra *PipelineCmsConfigExtra) FromDB(b []byte) error

+ func (extra *PipelineCmsConfigExtra) ToDB() ([]byte, error)

+ type PipelineCmsNs struct

+ ID uint64

+ Ns string

+ PipelineSource apistructs.PipelineSource

+ TimeCreated *time.Time

+ TimeUpdated *time.Time

+ func (PipelineCmsNs) TableName() string

+ type PipelineCombosReq struct

+ Branches []string

+ Sources []string

+ YmlNames []string

+ type PipelineConfig struct

+ ID uint64

+ Type PipelineConfigType

+ Value interface{}

+ func (PipelineConfig) TableName() string

+ type PipelineConfigType string

+ var PipelineConfigTypeActionExecutor PipelineConfigType = "action_executor"

+ type PipelineCron struct

+ ApplicationID uint64

+ BasePipelineID uint64

+ Branch string

+ CronExpr string

+ Enable *bool

+ Extra PipelineCronExtra

+ ID uint64

+ PipelineSource apistructs.PipelineSource

+ PipelineYmlName string

+ TimeCreated time.Time

+ TimeUpdated time.Time

+ func (PipelineCron) TableName() string

+ func (pc *PipelineCron) Convert2DTO() *apistructs.PipelineCronDTO

+ func (pc *PipelineCron) GetAppID() uint64

+ func (pc *PipelineCron) GetBranch() string

+ type PipelineCronExtra struct

+ ClusterName string

+ Compensator *apistructs.CronCompensator

+ ConfigManageNamespaces []string

+ CronStartFrom *time.Time

+ Envs map[string]string

+ FilterLabels map[string]string

+ LastCompensateAt *time.Time

+ NormalLabels map[string]string

+ PipelineYml string

+ Version string

+ type PipelineExtra struct

+ Commit string

+ CommitDetail apistructs.CommitDetail

+ Extra PipelineExtraInfo

+ ExtraTimeCreated *time.Time

+ ExtraTimeUpdated *time.Time

+ NormalLabels map[string]string

+ OrgName string

+ PipelineID uint64

+ PipelineYml string

+ Progress int

+ Snapshot Snapshot

+ Snippets []pipelineyml.SnippetPipelineYmlCache

+ func (*PipelineExtra) TableName() string

+ func (extra *PipelineExtra) GetCommitID() string

+ func (extra *PipelineExtra) GetOrgName() string

+ type PipelineExtraInfo struct

+ CallbackURLs []string

+ CancelUser *apistructs.PipelineUser

+ CompleteReconcilerGC bool

+ CompleteReconcilerTeardown bool

+ ConfigManageNamespaceOfSecrets string

+ ConfigManageNamespaceOfSecretsDefault string

+ ConfigManageNamespaces []string

+ CopyFromPipelineID *uint64

+ CronExpr string

+ CronTriggerTime *time.Time

+ DefinedOutputs []apistructs.PipelineOutput

+ DiceWorkspace apistructs.DiceWorkspace

+ GC apistructs.PipelineGC

+ InternalClient string

+ IsAutoRun bool

+ Messages []string

+ Namespace string

+ PipelineYmlNameV1 string

+ PipelineYmlSource apistructs.PipelineYmlSource

+ QueueInfo *QueueInfo

+ RerunFailedDetail *RerunFailedDetail

+ RunPipelineParams []apistructs.PipelineRunParam

+ RunUser *apistructs.PipelineUser

+ ShareVolumeID string

+ ShowMessage *apistructs.ShowMessage

+ SnippetChain []uint64

+ StorageConfig apistructs.StorageConfig

+ SubmitUser *apistructs.PipelineUser

+ TaskWorkspaces []string

+ Version string

+ type PipelineLabel struct

+ ID uint64

+ Key string

+ PipelineSource apistructs.PipelineSource

+ PipelineYmlName string

+ TargetID uint64

+ TimeCreated time.Time

+ TimeUpdated time.Time

+ Type apistructs.PipelineLabelType

+ Value string

+ func (p PipelineLabel) TableName() string

+ type PipelineOld struct

+ ApplicationID uint64

+ ApplicationName string

+ BasePipelineID uint64

+ Branch string

+ ClusterName string

+ Commit string

+ CommitDetail apistructs.CommitDetail

+ CostTimeSec int64

+ CronID *uint64

+ Extra PipelineExtraInfo

+ ID uint64

+ OrgID uint64

+ OrgName string

+ PipelineYml string

+ PipelineYmlName string

+ PipelineYmlSource apistructs.PipelineYmlSource

+ Progress float64

+ ProjectID uint64

+ ProjectName string

+ Snapshot Snapshot

+ Source apistructs.PipelineSource

+ Status apistructs.PipelineStatus

+ TimeBegin *time.Time

+ TimeCreated *time.Time

+ TimeEnd *time.Time

+ TimeUpdated *time.Time

+ TriggerMode apistructs.PipelineTriggerMode

+ Type apistructs.PipelineType

+ func (*PipelineOld) TableName() string

+ type PipelineReport struct

+ CreatedAt time.Time

+ CreatorID string

+ ID uint64

+ Meta apistructs.PipelineReportMeta

+ PipelineID uint64

+ Type apistructs.PipelineReportType

+ UpdatedAt time.Time

+ UpdaterID string

+ func (*PipelineReport) TableName() string

+ type PipelineStage struct

+ CostTimeSec int64

+ Extra PipelineStageExtra

+ ID uint64

+ Name string

+ PipelineID uint64

+ Status apistructs.PipelineStatus

+ TimeBegin time.Time

+ TimeCreated time.Time

+ TimeEnd time.Time

+ TimeUpdated time.Time

+ func (ps *PipelineStage) Convert2DTO() *apistructs.PipelineStageDTO

+ func (ps *PipelineStage) TableName() string

+ type PipelineStageExtra struct

+ PreStage *PreStageSimple

+ StageOrder int

+ type PipelineStageWithTask struct

+ PipelineTasks []*PipelineTask

+ type PipelineTask struct

+ Context PipelineTaskContext

+ CostTimeSec int64

+ ExecutorKind PipelineTaskExecutorKind

+ Extra PipelineTaskExtra

+ ID uint64

+ IsSnippet bool

+ Name string

+ OpType PipelineTaskOpType

+ PipelineID uint64

+ QueueTimeSec int64

+ Result apistructs.PipelineTaskResult

+ SnippetPipelineDetail *apistructs.PipelineTaskSnippetDetail

+ SnippetPipelineID *uint64

+ StageID uint64

+ Status apistructs.PipelineStatus

+ TimeBegin time.Time

+ TimeCreated time.Time

+ TimeEnd time.Time

+ TimeUpdated time.Time

+ Type string

+ func (*PipelineTask) TableName() string

+ func (pt *PipelineTask) Convert2DTO() *apistructs.PipelineTaskDTO

+ func (pt *PipelineTask) NodeName() string

+ func (pt *PipelineTask) PrevNodeNames() []string

+ func (pt *PipelineTask) ReleaseID() string

+ func (pt *PipelineTask) RuntimeID() string

+ type PipelineTaskContext struct

+ CmsDiceFiles apistructs.Metadata

+ InStorages apistructs.Metadata

+ OutStorages apistructs.Metadata

+ func (c *PipelineTaskContext) Dedup()

+ type PipelineTaskExecutorKind string

+ var PipelineTaskExecutorKindAPITest PipelineTaskExecutorKind = "APITEST"

+ var PipelineTaskExecutorKindMemory PipelineTaskExecutorKind = "MEMORY"

+ var PipelineTaskExecutorKindScheduler PipelineTaskExecutorKind = "SCHEDULER"

+ type PipelineTaskExtra struct

+ Action pipelineyml.Action

+ AllowFailure bool

+ AppliedResources apistructs.PipelineAppliedResources

+ Binds []apistructs.Bind

+ ClusterName string

+ Cmd string

+ CmdArgs []string

+ ExecutorName string

+ FlinkSparkConf FlinkSparkConf

+ Image string

+ Labels map[string]string

+ LoopOptions *apistructs.PipelineTaskLoopOptions

+ Namespace string

+ OpenapiOAuth2TokenPayload apistructs.OpenapiOAuth2TokenPayload

+ Pause bool

+ PreFetcher *apistructs.PreFetcher

+ PrivateEnvs map[string]string

+ PublicEnvs map[string]string

+ RunAfter []string

+ RuntimeResource RuntimeResource

+ StageOrder int

+ TimeBeginQueue time.Time

+ TimeEndQueue time.Time

+ Timeout time.Duration

+ UUID string

+ Volumes []apistructs.MetadataField

+ type PipelineTaskOpType string

+ var PipelineTaskOpTypeGet PipelineTaskOpType = "get"

+ var PipelineTaskOpTypePut PipelineTaskOpType = "put"

+ var PipelineTaskOpTypeTask PipelineTaskOpType = "task"

+ type PipelineWithStage struct

+ PipelineStages []*PipelineStageWithTask

+ type PipelineWithTasks struct

+ Pipeline *Pipeline

+ Tasks []*PipelineTask

+ func (p *PipelineWithTasks) DoneTasks() []string

+ type PreStageSimple struct

+ ID uint64

+ Status apistructs.PipelineStatus

+ type QueueInfo struct

+ CustomPriority int64

+ QueueID uint64

+ type RerunFailedDetail struct

+ FailedTasks map[string]uint64

+ NotExecuteTasks map[string]uint64

+ RerunPipelineID uint64

+ StageIndex int

+ SuccessTasks map[string]uint64

+ type RuntimeResource struct

+ CPU float64

+ Disk float64

+ Memory float64

+ func GenDefaultTaskResource() RuntimeResource

+ type Snapshot struct

+ AnalyzedCrossCluster *bool

+ AppliedResources apistructs.PipelineAppliedResources

+ BindQueue *apistructs.PipelineQueue

+ CmsDiceFiles map[string]string

+ Envs map[string]string

+ Events []*apistructs.PipelineEvent

+ IdentityInfo apistructs.IdentityInfo

+ OutputValues []apistructs.PipelineOutputWithValue

+ PipelineYml string

+ PlatformSecrets map[string]string

+ RunPipelineParams apistructs.PipelineRunParamsWithValue

+ Secrets map[string]string

+ func (s *Snapshot) FromDB(b []byte) error

+ func (s *Snapshot) ToDB() ([]byte, error)

+ type StoreType string

+ var StoreTypeDiceCacheNFS StoreType = "dice-cache-nfs-volume"

+ var StoreTypeDiceVolumeFake StoreType = "dice-fake-volume"

+ var StoreTypeDiceVolumeLocal StoreType = "dice-local-volume"

+ var StoreTypeDiceVolumeNFS StoreType = "dice-nfs-volume"

+ var StoreTypeNFS StoreType = "NFS"

+ var StoreTypeOSS StoreType = "OSS"

+ type Volume struct

+ ContainerPath string

+ HostPath string

+ ReadOnly bool

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL