phase

Documentation

Index

• func ListExec(ctx context.Context, status pipeline.Status, id uint32)
• func Phases() map[pipeline.Status]*BasePhase
• func RemainsExec(ctx context.Context, status pipeline.Status, id uint32)
• type BasePhase
  • func NewBasePhase(IPhaser IPhaser) *BasePhase
  • func PhaseList() []*BasePhase
  • func Remains(status pipeline.Status) []*BasePhase
  • func (b *BasePhase) Exec(ctx context.Context, id uint32) error
• type BuildQueuingPhase
  • func NewBuildQueuingPhase() *BuildQueuingPhase
  • func (q *BuildQueuingPhase) Exec(ctx context.Context, p *pipeline.Pipeline) error
  • func (q *BuildQueuingPhase) Status() pipeline.Status
• type IPhaser
• type WaitForBorrowingPhase
  • func NewWaitForBorrowingPhase() *WaitForBorrowingPhase
  • func (b *WaitForBorrowingPhase) Exec(ctx context.Context, p *pipeline.Pipeline) error
  • func (b *WaitForBorrowingPhase) Status() pipeline.Status
• type WaitForDispatchingPhase
  • func NewWaitForDispatchingPhase() *WaitForDispatchingPhase
  • func (w WaitForDispatchingPhase) Exec(ctx context.Context, p *pipeline.Pipeline) error
  • func (w WaitForDispatchingPhase) Status() pipeline.Status

Functions

func ListExec

func ListExec(ctx context.Context, status pipeline.Status, id uint32)

func Phases

func Phases() map[pipeline.Status]*BasePhase

func RemainsExec

func RemainsExec(ctx context.Context, status pipeline.Status, id uint32)

Types

type BasePhase

type BasePhase struct {
	IPhaser IPhaser
}

func NewBasePhase

func NewBasePhase(IPhaser IPhaser) *BasePhase

func PhaseList

func PhaseList() []*BasePhase

func Remains

func Remains(status pipeline.Status) []*BasePhase

func (*BasePhase) Exec

func (b *BasePhase) Exec(ctx context.Context, id uint32) error

type BuildQueuingPhase

type BuildQueuingPhase struct {
}

func NewBuildQueuingPhase

func NewBuildQueuingPhase() *BuildQueuingPhase

func (*BuildQueuingPhase) Exec

func (q *BuildQueuingPhase) Exec(ctx context.Context, p *pipeline.Pipeline) error

Exec BuildQueuing 状态的任务会被该方法执行 将任务状态由 BuildQueuing -> WaitForBorrowing

func (*BuildQueuingPhase) Status

func (q *BuildQueuingPhase) Status() pipeline.Status

type IPhaser

type IPhaser interface {
	Exec(ctx context.Context, p *pipeline.Pipeline) error
	Status() pipeline.Status
}

type WaitForBorrowingPhase

type WaitForBorrowingPhase struct {
}

func NewWaitForBorrowingPhase

func NewWaitForBorrowingPhase() *WaitForBorrowingPhase

func (*WaitForBorrowingPhase) Exec

func (b *WaitForBorrowingPhase) Exec(ctx context.Context, p *pipeline.Pipeline) error

func (*WaitForBorrowingPhase) Status

func (b *WaitForBorrowingPhase) Status() pipeline.Status

type WaitForDispatchingPhase

type WaitForDispatchingPhase struct {
}

func NewWaitForDispatchingPhase

func NewWaitForDispatchingPhase() *WaitForDispatchingPhase

func (WaitForDispatchingPhase) Exec

func (w WaitForDispatchingPhase) Exec(ctx context.Context, p *pipeline.Pipeline) error

func (WaitForDispatchingPhase) Status

func (w WaitForDispatchingPhase) Status() pipeline.Status