core

Documentation

Index

• func Backward(stages map[string]*schema.Stage, input util.Values, force bool)
• func Connect(wf *schema.Workflow, k8s *kube.K8s, tiller *helm.Tiller, v util.Values) error
• func Create(stg *schema.Stage, logger *log.Entry, key string, global util.Values, ...) error
• func Destroy(stg *schema.Stage, logger *log.Entry, key string, global util.Values, ...) error
• func Forward(stages map[string]*schema.Stage, input util.Values, force bool) error
• func Lint(wf *schema.Workflow, in util.Values) (err error)
• func RenderWith(k8s *kube.K8s) template.FuncMap
• func Shell(command string, values []string) ([]byte, error)
• func Until(stages map[string]*schema.Stage, input util.Values, force bool, target string)
• type Depends
  • func NewDepends(stages map[string]*schema.Stage, reverse bool) *Depends
  • func (d Depends) Complete(stages ...string)
  • func (d Depends) IsCyclic() bool
  • func (d Depends) Wait(stages ...string)
• type Node

Functions

func Backward

func Backward(stages map[string]*schema.Stage, input util.Values, force bool)

Backward deletes each stage in reverse order

func Connect

func Connect(wf *schema.Workflow, k8s *kube.K8s, tiller *helm.Tiller, v util.Values) error

Connect links all of our stages to their required resources and pre-renders their input

func Create

func Create(stg *schema.Stage, logger *log.Entry, key string, global util.Values, force bool) error

Create installs / upgrades resource

func Destroy

func Destroy(stg *schema.Stage, logger *log.Entry, key string, global util.Values, force bool) error

Destroy removes resource

func Forward

func Forward(stages map[string]*schema.Stage, input util.Values, force bool) error

Forward processes each stage in the pipeline

func Lint

func Lint(wf *schema.Workflow, in util.Values) (err error)

Lint all the stages in our pipeline

func RenderWith

func RenderWith(k8s *kube.K8s) template.FuncMap

RenderWith returns the supported templating functions

func Shell

func Shell(command string, values []string) ([]byte, error)

Shell runs any given command

func Until

func Until(stages map[string]*schema.Stage, input util.Values, force bool, target string)

Until creates single resource and dependencies

Types

type Depends

type Depends map[string]*Node

Depends implements a mapped waitgroup for dependencies

func NewDepends

func NewDepends(stages map[string]*schema.Stage, reverse bool) *Depends

NewDepends generates a dependency map

func (Depends) Complete

func (d Depends) Complete(stages ...string)

Complete given waitgroups

func (Depends) IsCyclic

func (d Depends) IsCyclic() bool

IsCyclic returns true if there is a cycle in the graph

func (Depends) Wait

func (d Depends) Wait(stages ...string)

Wait on given waitgroups

type Node

type Node struct {
	Lock  *sync.WaitGroup
	Edges []string
}