engine

Documentation

Index

• Variables
• type Engine
  • func NewEngine(logger log.Logger, binder common.IBinder) *Engine
  • func (e *Engine) AddToQueue(ctx model.QueueContext)
  • func (e *Engine) ChangeInWorkers()
  • func (e *Engine) Finished(buildID string)
  • func (e *Engine) Run()
  • func (e *Engine) Schedule(buildID string)
  • func (e *Engine) Shutdown() chan any
• type EngineEvent
  • func (e EngineEvent) String() string
• type EngineEventStatus
  • func (s EngineEventStatus) String() string

Variables

var (
	ErrInvalidBuild     = errors.New("invalid build")
	ErrInvalidPipeline  = errors.New("invalid project")
	ErrInvalidProject   = errors.New("invalid pipeline")
	ErrInvalidSecrets   = errors.New("invalid secrets")
	ErrInvalidVariables = errors.New("invalid variables")

	ErrBuildSave       = errors.New("unable to save build to database")
	ErrBuildInitFailed = errors.New("build init ended with error")
)

var ErrBuildCancelled = errors.New("build cancelled")

Types

type Engine

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

func NewEngine

func NewEngine(logger log.Logger, binder common.IBinder) *Engine

func (*Engine) AddToQueue

func (e *Engine) AddToQueue(ctx model.QueueContext)

func (*Engine) ChangeInWorkers

func (e *Engine) ChangeInWorkers()

func (*Engine) Finished

func (e *Engine) Finished(buildID string)

func (*Engine) Run

func (e *Engine) Run()

func (*Engine) Schedule

func (e *Engine) Schedule(buildID string)

func (*Engine) Shutdown

func (e *Engine) Shutdown() chan any

type EngineEvent

type EngineEvent int

const (
	EventSchedule EngineEvent = iota
	EventFinished
	EventAddToQueue
	EventChangeInWorkers
	EventShutdown
)

func (EngineEvent) String

func (e EngineEvent) String() string

type EngineEventStatus

type EngineEventStatus int

const (
	EventReceived EngineEventStatus = iota
	EventProcessed
	EventComplete
	EventFailed
)

func (EngineEventStatus) String

func (s EngineEventStatus) String() string