runner

Documentation

Index

• func GetLogger(ctx context.Context) logrus.FieldLogger
• func NewLogger() logrus.FieldLogger
• func WithLogger(ctx context.Context, logger logrus.FieldLogger) context.Context
• func WithLoggerComposeStepResult(ctx context.Context, sr *StepResult) context.Context
• func WithResult(ctx context.Context, result *Result) context.Context
• type FieldUpdater
  • func NewFieldUpdater(secrets map[string]string) *FieldUpdater
  • func (f *FieldUpdater) Update(field *string)
  • func (f *FieldUpdater) UpdateImage(image *models.Image) *models.Image
  • func (f *FieldUpdater) UpdateMap(data map[string]string) map[string]string
• type ProjectInfo
  • func NewProjInfo(hostPath string) *ProjectInfo
• type Result
  • func GetResult(ctx context.Context) *Result
  • func NewResult(name string, r *Runner) *Result
  • func (r *Result) AddStep(idx float32, name string, step *models.Step) *StepResult
  • func (r *Result) GetCachePath() string
  • func (r *Result) GetDuration() time.Duration
  • func (r *Result) GetResultPath() string
• type Runner
  • func New(projPath string, conf *config.Config, secrets map[string]string) *Runner
  • func (r *Runner) LoadPlan() error
  • func (r *Runner) Run(name string, targetBranch string)
• type StepResult
  • func (sr *StepResult) GetIdxString() string
• type Task
  • func ChainTask(tasks ...Task) Task
  • func NewCachesRestoreTask(c *docker.Container, sr *StepResult) Task
  • func NewCachesSaveTask(c *docker.Container, sr *StepResult) Task
  • func NewCloneTask(c *docker.Container) Task
  • func NewCmdTask(c *docker.Container, sr *StepResult, cmd []string) Task
  • func NewContainerCreateTask(c *docker.Container, sr *StepResult) Task
  • func NewContainerDestroyTask(c *docker.Container) Task
  • func NewContainerStartTask(c *docker.Container) Task
  • func NewCreateServicesTask(c *docker.Container, sr *StepResult) Task
  • func NewDownloadArtifactsTask(c *docker.Container, sr *StepResult) Task
  • func NewImagePullTask(c *docker.Container) Task
  • func NewSaveArtifactsTask(c *docker.Container, sr *StepResult) Task
  • func NewScriptTask(c *docker.Container, sr *StepResult, scripts models.StepScript) Task
  • func ParallelTask(size int, tasks ...Task) Task
  • func WithTimeout(task Task, timeout time.Duration) Task
  • func (t Task) Finally(ft Task) Task
  • func (t Task) Then(next Task) Task
  • func (t Task) WithCondition(cond func() bool) Task

Functions

func GetLogger

func GetLogger(ctx context.Context) logrus.FieldLogger

func NewLogger

func NewLogger() logrus.FieldLogger

func WithLogger

func WithLogger(ctx context.Context, logger logrus.FieldLogger) context.Context

func WithLoggerComposeStepResult

func WithLoggerComposeStepResult(ctx context.Context, sr *StepResult) context.Context

func WithResult

func WithResult(ctx context.Context, result *Result) context.Context

Types

type FieldUpdater

type FieldUpdater struct {
	Secrets map[string]string
}

func NewFieldUpdater

func NewFieldUpdater(secrets map[string]string) *FieldUpdater

func (*FieldUpdater) Update

func (f *FieldUpdater) Update(field *string)

func (*FieldUpdater) UpdateImage

func (f *FieldUpdater) UpdateImage(image *models.Image) *models.Image

func (*FieldUpdater) UpdateMap

func (f *FieldUpdater) UpdateMap(data map[string]string) map[string]string

type ProjectInfo

type ProjectInfo struct {
	Path       string
	ID         string
	Name       string
	Owner      string
	OwnerID    string
	RepoID     string
	BranchName string
	CommitID   string
}

func NewProjInfo

func NewProjInfo(hostPath string) *ProjectInfo

type Result

type Result struct {
	ID          string
	EventName   string
	StepResults map[float32]*StepResult
	Status      string
	Runner      *Runner
	Artifacts   map[string]string
}

func GetResult

func GetResult(ctx context.Context) *Result

func NewResult

func NewResult(name string, r *Runner) *Result

func (*Result) AddStep

func (r *Result) AddStep(idx float32, name string, step *models.Step) *StepResult

func (*Result) GetCachePath

func (r *Result) GetCachePath() string

func (*Result) GetDuration

func (r *Result) GetDuration() time.Duration

func (*Result) GetResultPath

func (r *Result) GetResultPath() string

type Runner

type Runner struct {
	Plan       *models.Plan
	Config     *config.Config
	Info       *ProjectInfo
	Secrets    map[string]string
	CacheStore *cache.Store
}

func New

func New(projPath string, conf *config.Config, secrets map[string]string) *Runner

func (*Runner) LoadPlan

func (r *Runner) LoadPlan() error

func (*Runner) Run

func (r *Runner) Run(name string, targetBranch string)

type StepResult

type StepResult struct {
	ID        uuid.UUID
	Index     float32
	Name      string
	Step      *models.Step
	Outputs   map[string]string
	StartTime time.Time
	EndTime   time.Time
	Status    string
	Result    *Result
}

func (*StepResult) GetIdxString

func (sr *StepResult) GetIdxString() string

type Task

type Task func(ctx context.Context) error

func ChainTask

func ChainTask(tasks ...Task) Task

func NewCachesRestoreTask

func NewCachesRestoreTask(c *docker.Container, sr *StepResult) Task

func NewCachesSaveTask

func NewCachesSaveTask(c *docker.Container, sr *StepResult) Task

func NewCloneTask

func NewCloneTask(c *docker.Container) Task

func NewCmdTask

func NewCmdTask(c *docker.Container, sr *StepResult, cmd []string) Task

func NewContainerCreateTask

func NewContainerCreateTask(c *docker.Container, sr *StepResult) Task

func NewContainerDestroyTask

func NewContainerDestroyTask(c *docker.Container) Task

func NewContainerStartTask

func NewContainerStartTask(c *docker.Container) Task

func NewCreateServicesTask

func NewCreateServicesTask(c *docker.Container, sr *StepResult) Task

func NewDownloadArtifactsTask

func NewDownloadArtifactsTask(c *docker.Container, sr *StepResult) Task

func NewImagePullTask

func NewImagePullTask(c *docker.Container) Task

func NewSaveArtifactsTask

func NewSaveArtifactsTask(c *docker.Container, sr *StepResult) Task

func NewScriptTask

func NewScriptTask(c *docker.Container, sr *StepResult, scripts models.StepScript) Task

func ParallelTask

func ParallelTask(size int, tasks ...Task) Task

func WithTimeout

func WithTimeout(task Task, timeout time.Duration) Task

func (Task) Finally

func (t Task) Finally(ft Task) Task

func (Task) Then

func (t Task) Then(next Task) Task

func (Task) WithCondition

func (t Task) WithCondition(cond func() bool) Task