pipeline

Documentation

Index

• Variables
• func Approve(ctx context.Context, store store.Store, currentPipeline *model.Pipeline, ...) (*model.Pipeline, error)
• func Cancel(ctx context.Context, _forge forge.Forge, store store.Store, repo *model.Repo, ...) error
• func Create(ctx context.Context, _store store.Store, repo *model.Repo, ...) (*model.Pipeline, error)
• func Decline(ctx context.Context, store store.Store, pipeline *model.Pipeline, ...) (*model.Pipeline, error)
• func Restart(ctx context.Context, store store.Store, lastPipeline *model.Pipeline, ...) (*model.Pipeline, error)
• func UpdateStatusToDone(store store.Store, pipeline model.Pipeline, status model.StatusValue, ...) (*model.Pipeline, error)
• func UpdateStepStatus(store store.Store, step *model.Step, state rpc.StepState) error
• func UpdateStepStatusToDone(store store.Store, step model.Step, state rpc.StepState) (*model.Step, error)
• func UpdateStepToStatusKilled(store store.Store, step model.Step) (*model.Step, error)
• func UpdateStepToStatusSkipped(store store.Store, step model.Step, finished int64) (*model.Step, error)
• func UpdateStepToStatusStarted(store store.Store, step model.Step, state rpc.StepState) (*model.Step, error)
• func UpdateToStatusDeclined(store store.Store, pipeline model.Pipeline, reviewer string) (*model.Pipeline, error)
• func UpdateToStatusError(store store.Store, pipeline model.Pipeline, err error) (*model.Pipeline, error)
• func UpdateToStatusKilled(store store.Store, pipeline model.Pipeline) (*model.Pipeline, error)
• func UpdateToStatusPending(store store.Store, pipeline model.Pipeline, reviewer string) (*model.Pipeline, error)
• func UpdateToStatusRunning(store store.Store, pipeline model.Pipeline, started int64) (*model.Pipeline, error)
• func UpdateWorkflowStatusToDone(store store.Store, workflow model.Workflow, state rpc.WorkflowState) (*model.Workflow, error)
• func UpdateWorkflowStatusToRunning(store store.Store, workflow model.Workflow, state rpc.WorkflowState) (*model.Workflow, error)
• func UpdateWorkflowToStatusSkipped(store store.Store, workflow model.Workflow) (*model.Workflow, error)
• type ErrBadRequest
  • func (e ErrBadRequest) Error() string
  • func (e ErrBadRequest) Is(target error) bool
• type ErrNotFound
  • func (e ErrNotFound) Error() string
  • func (e ErrNotFound) Is(target error) bool

Variables

var ErrFiltered = errors.New("ignoring hook: 'when' filters filtered out all steps")

Functions

func Approve

func Approve(ctx context.Context, store store.Store, currentPipeline *model.Pipeline, user *model.User, repo *model.Repo) (*model.Pipeline, error)

Approve update the status to pending for a blocked pipeline because of a gated repo and start them afterward.

func Cancel

func Cancel(ctx context.Context, _forge forge.Forge, store store.Store, repo *model.Repo, user *model.User, pipeline *model.Pipeline) error

Cancel the pipeline and returns the status.

func Create

func Create(ctx context.Context, _store store.Store, repo *model.Repo, pipeline *model.Pipeline) (*model.Pipeline, error)

Create a new pipeline and start it.

func Decline

func Decline(ctx context.Context, store store.Store, pipeline *model.Pipeline, user *model.User, repo *model.Repo) (*model.Pipeline, error)

Decline updates the status to declined for blocked pipelines because of a gated repo.

func Restart

func Restart(ctx context.Context, store store.Store, lastPipeline *model.Pipeline, user *model.User, repo *model.Repo, envs map[string]string) (*model.Pipeline, error)

Restart a pipeline by creating a new one out of the old and start it.

func UpdateStatusToDone

func UpdateStatusToDone(store store.Store, pipeline model.Pipeline, status model.StatusValue, stopped int64) (*model.Pipeline, error)

func UpdateStepStatus

func UpdateStepStatus(store store.Store, step *model.Step, state rpc.StepState) error

func UpdateStepStatusToDone

func UpdateStepStatusToDone(store store.Store, step model.Step, state rpc.StepState) (*model.Step, error)

func UpdateStepToStatusKilled

func UpdateStepToStatusKilled(store store.Store, step model.Step) (*model.Step, error)

func UpdateStepToStatusSkipped

func UpdateStepToStatusSkipped(store store.Store, step model.Step, finished int64) (*model.Step, error)

func UpdateStepToStatusStarted

func UpdateStepToStatusStarted(store store.Store, step model.Step, state rpc.StepState) (*model.Step, error)

func UpdateToStatusDeclined

func UpdateToStatusDeclined(store store.Store, pipeline model.Pipeline, reviewer string) (*model.Pipeline, error)

func UpdateToStatusError

func UpdateToStatusError(store store.Store, pipeline model.Pipeline, err error) (*model.Pipeline, error)

func UpdateToStatusKilled

func UpdateToStatusKilled(store store.Store, pipeline model.Pipeline) (*model.Pipeline, error)

func UpdateToStatusPending

func UpdateToStatusPending(store store.Store, pipeline model.Pipeline, reviewer string) (*model.Pipeline, error)

func UpdateToStatusRunning

func UpdateToStatusRunning(store store.Store, pipeline model.Pipeline, started int64) (*model.Pipeline, error)

func UpdateWorkflowStatusToDone

func UpdateWorkflowStatusToDone(store store.Store, workflow model.Workflow, state rpc.WorkflowState) (*model.Workflow, error)

func UpdateWorkflowStatusToRunning

func UpdateWorkflowStatusToRunning(store store.Store, workflow model.Workflow, state rpc.WorkflowState) (*model.Workflow, error)

func UpdateWorkflowToStatusSkipped

func UpdateWorkflowToStatusSkipped(store store.Store, workflow model.Workflow) (*model.Workflow, error)

Types

type ErrBadRequest

type ErrBadRequest struct {
	Msg string
}

func (ErrBadRequest) Error

func (e ErrBadRequest) Error() string

func (ErrBadRequest) Is

func (e ErrBadRequest) Is(target error) bool

type ErrNotFound

type ErrNotFound struct {
	Msg string
}

func (ErrNotFound) Error

func (e ErrNotFound) Error() string

func (ErrNotFound) Is

func (e ErrNotFound) Is(target error) bool