trigger

Documentation

Index

• type Plan
  • func (p *Plan) GetExchanges() []int
  • func (p *Plan) GetRoots() []int
  • func (p *Plan) GetSteps() []PlanStep
• type PlanStep
• type Planner
  • func (p *Planner) AddPipe(name, digest string, pipe nuggit.Pipe) error
  • func (p *Planner) AddReferencedPipe(name, digest string, pipe nuggit.Pipe)
  • func (p *Planner) Build() *Plan

Types

type Plan

type Plan struct {
	// Roots is a 0-indexed list of root actions.
	Roots []int `json:"roots,omitempty"`
	// Exchanges is a 0-indexed list of exchange actions.
	Exchanges []int `json:"exchanges,omitempty"`
	// Types specifies the type number of each exchange Point.
	// The client may use this to further optimize the plan
	// or raise exceptions.
	Types []int `json:"types,omitempty"`
	// Steps contains the optimal sequence of actions needed to execute the given pipelines.
	Steps []PlanStep `json:"steps,omitempty"`
}

func (*Plan) GetExchanges

func (p *Plan) GetExchanges() []int

func (*Plan) GetRoots

func (p *Plan) GetRoots() []int

func (*Plan) GetSteps

func (p *Plan) GetSteps() []PlanStep

type PlanStep

type PlanStep struct {
	// Input is the node number representing the input to this step.
	//
	// The node number is 1-indexed, therefore equal to one greater
	// than the slice index. A value of 0 indicates the step has no
	// inputs, and that it is a root.
	Input         int `json:"input,omitempty"`
	nuggit.Action `json:"action,omitempty"`
}

type Planner

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

func (*Planner) AddPipe

func (p *Planner) AddPipe(name, digest string, pipe nuggit.Pipe) error

func (*Planner) AddReferencedPipe

func (p *Planner) AddReferencedPipe(name, digest string, pipe nuggit.Pipe)

func (*Planner) Build

func (p *Planner) Build() *Plan