Versions in this module Expand all Collapse all v0 v0.0.10 Apr 10, 2026 v0.0.9 Mar 17, 2026 Changes in this version + const APP_NAME + type CONDITION_OPERATOR string + const CONDITION_OPERATOR_IN + type Contiditon struct + InputParam string + Operator CONDITION_OPERATOR + Values []string + type DescribeTaskRequest struct + TaskId string + func NewDescribeTaskRequest(taskId string) *DescribeTaskRequest + type QueryTaskRequest struct + Label map[string]string + PipelineTaskId []string + ScheduledAgentId string + Status STATUS + WithDetail bool + func NewQueryTaskRequest() *QueryTaskRequest + func (r *QueryTaskRequest) AddPipelineTaskId(ids ...string) *QueryTaskRequest + func (r *QueryTaskRequest) SetLabel(key, value string) *QueryTaskRequest + func (r *QueryTaskRequest) SetScheduledAgentId(agentId string) *QueryTaskRequest + func (r *QueryTaskRequest) SetStatus(status STATUS) *QueryTaskRequest + type ReRunTaskRequest struct + Clone bool + TaskId string + func NewReRunTaskRequest(taskId string) *ReRunTaskRequest + type STATUS string + const STATUS_CANCELED + const STATUS_FAILED + const STATUS_PENDDING + const STATUS_RUNNING + const STATUS_SKIP + const STATUS_SUCCESS + const STATUS_WAIT_UPDATE + func (s STATUS) IsComplete() bool + func (s STATUS) String() string + type Service interface + CheckScheduleTimeout func(ctx context.Context, timeoutSeconds int) error + DescribeTask func(ctx context.Context, in *DescribeTaskRequest) (*Task, error) + QueryTask func(ctx context.Context, in *QueryTaskRequest) (*types.Set[*Task], error) + ReRunTask func(ctx context.Context, in *ReRunTaskRequest) (*Task, error) + RunTask func(ctx context.Context, in *Task) error + SaveTask func(ctx context.Context, in *Task) error + UpdateScheduleConfirmed func(ctx context.Context, taskId string, confirmed bool) error + UpdateTaskStatus func(ctx context.Context, in *Task) error + func GetService() Service + type TYPE string + const TYPE_AGENT_UPGRADE + const TYPE_DOCKER_RUNNER + const TYPE_IMAGE_BUILD + const TYPE_JENKINS_RUNNER + const TYPE_K8S_RUNNER + const TYPE_TASK_DEBUG + func (t TYPE) String() string + type Task struct + func NewTask(t TYPE, name string) *Task + func (e *Task) DependsNodes() []string + func (e *Task) GetName() string + func (e *Task) GetStatus() dag.NodeStatus + func (e *Task) InitEmbeddedFields() *Task + func (e *Task) IsCompleted() bool + func (e *Task) IsContinue() bool + func (e *Task) IsFailed() bool + func (e *Task) IsPendding() bool + func (e *Task) IsSuccess() bool + func (e *Task) LoadFromEvent(event *bus.Event) error + func (e *Task) NodeName() string + func (e *Task) SetDependsOn(depends ...string) *Task + func (e *Task) SetStatus(status dag.NodeStatus) + func (e *Task) TableName() string + func (e *Task) ToBusEvent(topic string) *bus.Event + func (e *Task) Validate() error + func (e *Task) When() string + func (r *Task) AddDependsTask(taskNames ...string) *Task + func (r *Task) AddWhen(conditions ...*Contiditon) *Task + func (r *Task) FixStartAt(pipelineStartAt time.Time) + func (r *Task) SetLabel(key, value string) *Task + func (t *Task) Clone() *Task + func (t *Task) GetIgnoreError() bool + func (t *Task) GetLogCallback() func(content string) + func (t *Task) IsScheduleConfirmTimeout() bool + func (t *Task) IsScheduleTimeout(seconds int) bool + func (t *Task) IsTimeout() bool + func (t *Task) LogDebug(msg string) + func (t *Task) LogError(msg string) + func (t *Task) LogInfo(msg string) + func (t *Task) LogSuccess(msg string) + func (t *Task) LogWarn(msg string) + func (t *Task) OutputDir() string + func (t *Task) ResetForRerun() + func (t *Task) SetAgentEnv(v string) *Task + func (t *Task) SetDescription(v string) *Task + func (t *Task) SetId(id string) *Task + func (t *Task) SetIgnoreError(v bool) *Task + func (t *Task) SetLogCallback(callback func(content string)) *Task + func (t *Task) SetParam(key, value string) *Task + func (t *Task) SetRefPipelineTask(refPipelineTaskId string) *Task + func (t *Task) SetTimeoutSecond(v int64) *Task + func (t *Task) SharedDataDir() string + func (t *Task) String() string + func (t *Task) TimeoutDuration() time.Duration + func (t *Task) TimeoutDurationString() string + func (t *Task) UseTaskLog(ctx context.Context) *Task + func (t *Task) WorkDir() string + type TaskSpec struct + AgentEnv string + CreateAt time.Time + Define map[string]string + DependsTasks []string + Description string + Extras map[string]string + Id string + IgnoreError *bool + InputParams map[string]string + Label map[string]string + Name string + PipelineTaskId string + TimeoutSecond int64 + Type TYPE + When []Contiditon + WhenCondition string + func NewTaskSpec(t TYPE, name string) *TaskSpec + func (r *TaskSpec) ShortDisplay() string + func (r *TaskSpec) String() string + func (s *TaskSpec) GetParam(key string) string + func (s *TaskSpec) SetDefine(key, value string) *TaskSpec + func (s *TaskSpec) SetInputParam(key, value string) *TaskSpec + type TaskStatus struct + Detail string + EndAt time.Time + Extras map[string]string + Message string + Output map[string]string + RefURL string + RunBy string + ScheduledAgentId *string + ScheduledAt *time.Time + ScheduledConfirmTTL int64 + ScheduledConfirmed *bool + StartAt *time.Time + Status STATUS + UpdateAt time.Time + func NewTaskStatus() *TaskStatus + func (r *TaskStatus) ConfirmScheduled() *TaskStatus + func (r *TaskStatus) GetScheduledAgentId() string + func (r *TaskStatus) IsRunning() bool + func (r *TaskStatus) IsScheduleConfirm() bool + func (r *TaskStatus) IsScheduleConfirmed() bool + func (r *TaskStatus) IsScheduled() bool + func (r *TaskStatus) IsWaitUpdate() bool + func (r *TaskStatus) MarkScheduled(agentId string) *TaskStatus + func (r *TaskStatus) MarkedRunning() + func (r *TaskStatus) SetScheduledAgentId(agentId string) *TaskStatus + func (r *TaskStatus) SetScheduledConfirmed(confirmed bool) *TaskStatus + func (r *TaskStatus) String() string + func (r *TaskStatus) TableName() string + func (t *TaskStatus) Canceledf(format string, a ...any) *TaskStatus + func (t *TaskStatus) Failedf(format string, a ...any) *TaskStatus + func (t *TaskStatus) Skipf(format string, a ...any) *TaskStatus + func (t *TaskStatus) Success(format string, a ...any) *TaskStatus + func (t *TaskStatus) WaitUpdate(updateId string) *TaskStatus + func (t *TaskStatus) WithDetail(format string, a ...any) *TaskStatus + func (t *TaskStatus) WithExtra(key, value string) *TaskStatus + func (t *TaskStatus) WithRefURL(refURL string) *TaskStatus + type TaskUpdate struct + Params map[string]string + func (r *TaskUpdate) TableName() string
Go to main page