workers

Documentation

Index

• type BuildsWorker
  • func NewBuildsWorker(db *gorm.DB, PipelineWorker *PipelineWorker, notify chan *models.Pipeline) *BuildsWorker
  • func (w *BuildsWorker) Perform(pipeline *models.Pipeline)
• type PipelineWorker
  • func NewPipelineWorker(db *gorm.DB, pipeline *controllers.Pipelines, build *controllers.Builds) *PipelineWorker
  • func (w *PipelineWorker) Perform(pipelineID int64) error
• type Stats
• type StuckWorker
  • func NewStuckWorker(db *gorm.DB) *StuckWorker
  • func (w *StuckWorker) Perform() error

Types

type BuildsWorker

type BuildsWorker struct {
	PipelineWorker *PipelineWorker
	// contains filtered or unexported fields
}

BuildsWorker --

func NewBuildsWorker

func NewBuildsWorker(db *gorm.DB, PipelineWorker *PipelineWorker, notify chan *models.Pipeline) *BuildsWorker

NewBuildsWorker --

func (*BuildsWorker) Perform

func (w *BuildsWorker) Perform(pipeline *models.Pipeline)

Perform -- -- Called after all builds are created -- Called after every build status update

type PipelineWorker

type PipelineWorker struct {
	// contains filtered or unexported fields
}

PipelineWorker --

func NewPipelineWorker

func NewPipelineWorker(db *gorm.DB, pipeline *controllers.Pipelines, build *controllers.Builds) *PipelineWorker

NewPipelineWorker creates a pipeline worker

func (*PipelineWorker) Perform

func (w *PipelineWorker) Perform(pipelineID int64) error

Perform is called after all jobs are created, after all job updates

type Stats

type Stats struct {
	Created                 int64
	Active                  int64
	Successful              int64
	Skipped                 int64
	Failed                  int64
	Canceled                int64
	Total                   int64
	AllowedFailures         int64
	NonBlockingManualBuilds int64
	BlockingManualBuilds    int64
}

Stats --

type StuckWorker

type StuckWorker struct {
	// contains filtered or unexported fields
}

StuckWorker --

func NewStuckWorker

func NewStuckWorker(db *gorm.DB) *StuckWorker

NewStuckWorker --

func (*StuckWorker) Perform

func (w *StuckWorker) Perform() error

Perform --