Versions in this module Expand all Collapse all v0 v0.19.4 May 24, 2023 Changes in this version + const ArtifactStatusUploadConfirmed + const ArtifactStatusUploadError + const ArtifactStatusUploadPending + func CountRunJobs(ctx context.Context, opts FindRunJobOptions) (int64, error) + func CountRunners(ctx context.Context, opts FindRunnerOptions) (int64, error) + func CountRuns(ctx context.Context, opts FindRunOptions) (int64, error) + func CountTasks(ctx context.Context, opts FindTaskOptions) (int64, error) + func CreateRunner(ctx context.Context, t *ActionRunner) error + func DeleteRunner(ctx context.Context, id int64) error + func FindTaskOutputKeyByTaskID(ctx context.Context, taskID int64) ([]string, error) + func InsertRun(ctx context.Context, run *ActionRun, jobs []*jobparser.SingleWorkflow) error + func InsertTaskOutputIfNotExist(ctx context.Context, taskID int64, key, value string) error + func StopTask(ctx context.Context, taskID int64, status Status) error + func UpdateArtifactByID(ctx context.Context, id int64, art *ActionArtifact) error + func UpdateRun(ctx context.Context, run *ActionRun, cols ...string) error + func UpdateRunJob(ctx context.Context, job *ActionRunJob, cond builder.Cond, cols ...string) (int64, error) + func UpdateRunner(ctx context.Context, r *ActionRunner, cols ...string) error + func UpdateRunnerToken(ctx context.Context, r *ActionRunnerToken, cols ...string) (err error) + func UpdateTask(ctx context.Context, task *ActionTask, cols ...string) error + type ActionArtifact struct + ArtifactName string + ArtifactPath string + CommitSHA string + ContentEncoding string + CreatedUnix timeutil.TimeStamp + FileCompressedSize int64 + FileSize int64 + ID int64 + OwnerID int64 + RepoID int64 + RunID int64 + RunnerID int64 + Status int64 + StoragePath string + UpdatedUnix timeutil.TimeStamp + func CreateArtifact(ctx context.Context, t *ActionTask, artifactName string) (*ActionArtifact, error) + func GetArtifactByID(ctx context.Context, id int64) (*ActionArtifact, error) + func ListArtifactsByRepoID(ctx context.Context, repoID int64) ([]*ActionArtifact, error) + func ListArtifactsByRunID(ctx context.Context, runID int64) ([]*ActionArtifact, error) + func ListUploadedArtifactsByRunID(ctx context.Context, runID int64) ([]*ActionArtifact, error) + type ActionJobList []*ActionRunJob + func FindRunJobs(ctx context.Context, opts FindRunJobOptions) (ActionJobList, int64, error) + func (jobs ActionJobList) GetRunIDs() []int64 + func (jobs ActionJobList) LoadAttributes(ctx context.Context, withRepo bool) error + func (jobs ActionJobList) LoadRuns(ctx context.Context, withRepo bool) error + type ActionRun struct + ApprovedBy int64 + CommitSHA string + Created timeutil.TimeStamp + Event webhook_module.HookEventType + EventPayload string + ID int64 + Index int64 + IsForkPullRequest bool + NeedApproval bool + OwnerID int64 + Ref string + Repo *repo_model.Repository + RepoID int64 + Started timeutil.TimeStamp + Status Status + Stopped timeutil.TimeStamp + Title string + TriggerUser *user_model.User + TriggerUserID int64 + Updated timeutil.TimeStamp + WorkflowID string + func GetRunByID(ctx context.Context, id int64) (*ActionRun, error) + func GetRunByIndex(ctx context.Context, repoID, index int64) (*ActionRun, error) + func (run *ActionRun) Duration() time.Duration + func (run *ActionRun) GetPullRequestEventPayload() (*api.PullRequestPayload, error) + func (run *ActionRun) GetPushEventPayload() (*api.PushPayload, error) + func (run *ActionRun) HTMLURL() string + func (run *ActionRun) Link() string + func (run *ActionRun) LoadAttributes(ctx context.Context) error + func (run *ActionRun) PrettyRef() string + func (run *ActionRun) RefLink() string + type ActionRunIndex db.ResourceIndex + type ActionRunJob struct + Attempt int64 + CommitSHA string + Created timeutil.TimeStamp + ID int64 + IsForkPullRequest bool + JobID string + Name string + Needs []string + OwnerID int64 + RepoID int64 + Run *ActionRun + RunID int64 + RunsOn []string + Started timeutil.TimeStamp + Status Status + Stopped timeutil.TimeStamp + TaskID int64 + Updated timeutil.TimeStamp + WorkflowPayload []byte + func GetRunJobByID(ctx context.Context, id int64) (*ActionRunJob, error) + func GetRunJobsByRunID(ctx context.Context, runID int64) ([]*ActionRunJob, error) + func (job *ActionRunJob) Duration() time.Duration + func (job *ActionRunJob) LoadAttributes(ctx context.Context) error + func (job *ActionRunJob) LoadRun(ctx context.Context) error + type ActionRunner struct + AgentLabels []string + Base int + Created timeutil.TimeStamp + CustomLabels []string + Deleted timeutil.TimeStamp + Description string + ID int64 + LastActive timeutil.TimeStamp + LastOnline timeutil.TimeStamp + Name string + Owner *user_model.User + OwnerID int64 + Repo *repo_model.Repository + RepoID int64 + RepoRange string + Token string + TokenHash string + TokenSalt string + UUID string + Updated timeutil.TimeStamp + Version string + func GetRunnerByID(ctx context.Context, id int64) (*ActionRunner, error) + func GetRunnerByUUID(ctx context.Context, uuid string) (*ActionRunner, error) + func (r *ActionRunner) AllLabels() []string + func (r *ActionRunner) BelongsToOwnerName() string + func (r *ActionRunner) BelongsToOwnerType() types.OwnerType + func (r *ActionRunner) Editable(ownerID, repoID int64) bool + func (r *ActionRunner) GenerateToken() (err error) + func (r *ActionRunner) IsOnline() bool + func (r *ActionRunner) LoadAttributes(ctx context.Context) error + func (r *ActionRunner) Status() runnerv1.RunnerStatus + func (r *ActionRunner) StatusLocaleName(lang translation.Locale) string + func (r *ActionRunner) StatusName() string + type ActionRunnerToken struct + Created timeutil.TimeStamp + Deleted timeutil.TimeStamp + ID int64 + IsActive bool + Owner *user_model.User + OwnerID int64 + Repo *repo_model.Repository + RepoID int64 + Token string + Updated timeutil.TimeStamp + func GetRunnerToken(ctx context.Context, token string) (*ActionRunnerToken, error) + func GetUnactivatedRunnerToken(ctx context.Context, ownerID, repoID int64) (*ActionRunnerToken, error) + func NewRunnerToken(ctx context.Context, ownerID, repoID int64) (*ActionRunnerToken, error) + type ActionTask struct + Attempt int64 + CommitSHA string + Created timeutil.TimeStamp + ID int64 + IsForkPullRequest bool + Job *ActionRunJob + JobID int64 + LogExpired bool + LogFilename string + LogInStorage bool + LogIndexes LogIndexes + LogLength int64 + LogSize int64 + OwnerID int64 + RepoID int64 + RunnerID int64 + Started timeutil.TimeStamp + Status Status + Steps []*ActionTaskStep + Stopped timeutil.TimeStamp + Token string + TokenHash string + TokenLastEight string + TokenSalt string + Updated timeutil.TimeStamp + func CreateTaskForRunner(ctx context.Context, runner *ActionRunner) (*ActionTask, bool, error) + func GetRunningTaskByToken(ctx context.Context, token string) (*ActionTask, error) + func GetTaskByID(ctx context.Context, id int64) (*ActionTask, error) + func UpdateTaskByState(ctx context.Context, state *runnerv1.TaskState) (*ActionTask, error) + func (task *ActionTask) Duration() time.Duration + func (task *ActionTask) GenerateToken() (err error) + func (task *ActionTask) GetCommitLink() string + func (task *ActionTask) GetRepoLink() string + func (task *ActionTask) GetRepoName() string + func (task *ActionTask) GetRunLink() string + func (task *ActionTask) IsStopped() bool + func (task *ActionTask) LoadAttributes(ctx context.Context) error + func (task *ActionTask) LoadJob(ctx context.Context) error + type ActionTaskOutput struct + ID int64 + OutputKey string + OutputValue string + TaskID int64 + func FindTaskOutputByTaskID(ctx context.Context, taskID int64) ([]*ActionTaskOutput, error) + type ActionTaskStep struct + Created timeutil.TimeStamp + ID int64 + Index int64 + LogIndex int64 + LogLength int64 + Name string + RepoID int64 + Started timeutil.TimeStamp + Status Status + Stopped timeutil.TimeStamp + TaskID int64 + Updated timeutil.TimeStamp + func GetTaskStepsByTaskID(ctx context.Context, taskID int64) ([]*ActionTaskStep, error) + func (step *ActionTaskStep) Duration() time.Duration + type FindRunJobOptions struct + CommitSHA string + OwnerID int64 + RepoID int64 + RunID int64 + Statuses []Status + UpdatedBefore timeutil.TimeStamp + type FindRunOptions struct + Approved bool + OwnerID int64 + RepoID int64 + TriggerUserID int64 + WorkflowFileName string + type FindRunnerOptions struct + Filter string + OwnerID int64 + RepoID int64 + Sort string + WithAvailable bool + type FindTaskOptions struct + CommitSHA string + IDOrderDesc bool + OwnerID int64 + RepoID int64 + RunnerID int64 + StartedBefore timeutil.TimeStamp + Status Status + UpdatedBefore timeutil.TimeStamp + type LogIndexes []int64 + func (indexes *LogIndexes) FromDB(b []byte) error + func (indexes *LogIndexes) ToDB() ([]byte, error) + type RunList []*ActionRun + func FindRuns(ctx context.Context, opts FindRunOptions) (RunList, int64, error) + func (runs RunList) GetRepoIDs() []int64 + func (runs RunList) GetUserIDs() []int64 + func (runs RunList) LoadRepos() error + func (runs RunList) LoadTriggerUser(ctx context.Context) error + type RunnerList []*ActionRunner + func FindRunners(ctx context.Context, opts FindRunnerOptions) (runners RunnerList, err error) + func (runners RunnerList) GetUserIDs() []int64 + func (runners RunnerList) LoadAttributes(ctx context.Context) error + func (runners RunnerList) LoadOwners(ctx context.Context) error + func (runners RunnerList) LoadRepos(ctx context.Context) error + type Status int + const StatusBlocked + const StatusCancelled + const StatusFailure + const StatusRunning + const StatusSkipped + const StatusSuccess + const StatusUnknown + const StatusWaiting + func (s Status) AsResult() runnerv1.Result + func (s Status) HasRun() bool + func (s Status) In(statuses ...Status) bool + func (s Status) IsBlocked() bool + func (s Status) IsCancelled() bool + func (s Status) IsDone() bool + func (s Status) IsFailure() bool + func (s Status) IsRunning() bool + func (s Status) IsSkipped() bool + func (s Status) IsSuccess() bool + func (s Status) IsUnknown() bool + func (s Status) IsWaiting() bool + func (s Status) LocaleString(lang translation.Locale) string + func (s Status) String() string + type TaskList []*ActionTask + func FindTasks(ctx context.Context, opts FindTaskOptions) (TaskList, error) + func (tasks TaskList) GetJobIDs() []int64 + func (tasks TaskList) LoadAttributes(ctx context.Context) error + func (tasks TaskList) LoadJobs(ctx context.Context) error