builder

Documentation

Index

• func Json(builder *WorkflowBuilder) ([]byte, error)
• func Validate(builder *WorkflowBuilder) error
• func Yaml(builder *WorkflowBuilder) ([]byte, error)
• type CallBuilder
  • func NewCallBuilder(root *graph.Node) *CallBuilder
  • func (b *CallBuilder) GetCall() string
  • func (b *CallBuilder) SetCall(call CallKind) *CallBuilder
  • func (b *CallBuilder) With() *MapBuilder
• type CallKind
• type DoBuilder
  • func NewDoBuilder(root *graph.Node) *DoBuilder
  • func (b *DoBuilder) AddCall(name string) (*CallBuilder, int)
  • func (b *DoBuilder) AddWait(name string) (*WaitBuilder, int)
  • func (b *DoBuilder) RemoveTask(index int) *DoBuilder
• type DocumentBuilder
  • func NewDocumentBuilder(root *graph.Node) *DocumentBuilder
  • func (b *DocumentBuilder) GetDSL() string
  • func (b *DocumentBuilder) GetName() string
  • func (b *DocumentBuilder) GetNamespace() string
  • func (b *DocumentBuilder) GetVersion() string
  • func (b *DocumentBuilder) SetDSL(dsl string) *DocumentBuilder
  • func (b *DocumentBuilder) SetName(dsl string) *DocumentBuilder
  • func (b *DocumentBuilder) SetNamespace(dsl string) *DocumentBuilder
  • func (b *DocumentBuilder) SetVersion(dsl string) *DocumentBuilder
• type DurationBuilder
  • func NewDurationBuilder(root *graph.Node) *DurationBuilder
  • func (b *DurationBuilder) GetSeconds() int
  • func (b *DurationBuilder) SetSeconds(seconds int) *DurationBuilder
• type MapBuilder
  • func NewMapBuilder(root *graph.Node) *MapBuilder
  • func (b *MapBuilder) Get(name string) string
  • func (b *MapBuilder) Set(name string, value string)
• type UseBuilder
  • func NewUseBuilder(root *graph.Node) *UseBuilder
• type WaitBuilder
  • func NewWaitBuilder(root *graph.Node) *WaitBuilder
  • func (b *WaitBuilder) Duration() *DurationBuilder
  • func (b *WaitBuilder) GetWait() string
  • func (b *WaitBuilder) SetWait(wait string)
• type WorkflowBuilder
  • func NewWorkflowBuilder() *WorkflowBuilder
  • func NewWorkflowBuilderFromFile(path string) (*WorkflowBuilder, error)
  • func NewWorkflowBuilderFromJSONSource(source []byte) (*WorkflowBuilder, error)
  • func NewWorkflowBuilderFromYAMLSource(source []byte) (*WorkflowBuilder, error)
  • func (b *WorkflowBuilder) Do() *DoBuilder
  • func (b *WorkflowBuilder) Document() *DocumentBuilder
  • func (b *WorkflowBuilder) Node() *graph.Node
  • func (b *WorkflowBuilder) Use() *UseBuilder

Functions

func Json

func Json(builder *WorkflowBuilder) ([]byte, error)

func Validate

func Validate(builder *WorkflowBuilder) error

func Yaml

func Yaml(builder *WorkflowBuilder) ([]byte, error)

Types

type CallBuilder

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

func NewCallBuilder

func NewCallBuilder(root *graph.Node) *CallBuilder

func (*CallBuilder) GetCall

func (b *CallBuilder) GetCall() string

func (*CallBuilder) SetCall

func (b *CallBuilder) SetCall(call CallKind) *CallBuilder

func (*CallBuilder) With

func (b *CallBuilder) With() *MapBuilder

type CallKind

type CallKind string

const (
	CallKindHttp CallKind = "http"
	CallKindGrpc CallKind = "grpc"
)

type DoBuilder

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

func NewDoBuilder

func NewDoBuilder(root *graph.Node) *DoBuilder

func (*DoBuilder) AddCall

func (b *DoBuilder) AddCall(name string) (*CallBuilder, int)

func (*DoBuilder) AddWait

func (b *DoBuilder) AddWait(name string) (*WaitBuilder, int)

func (*DoBuilder) RemoveTask

func (b *DoBuilder) RemoveTask(index int) *DoBuilder

type DocumentBuilder

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

func NewDocumentBuilder

func NewDocumentBuilder(root *graph.Node) *DocumentBuilder

func (*DocumentBuilder) GetDSL

func (b *DocumentBuilder) GetDSL() string

func (*DocumentBuilder) GetName

func (b *DocumentBuilder) GetName() string

func (*DocumentBuilder) GetNamespace

func (b *DocumentBuilder) GetNamespace() string

func (*DocumentBuilder) GetVersion

func (b *DocumentBuilder) GetVersion() string

func (*DocumentBuilder) SetDSL

func (b *DocumentBuilder) SetDSL(dsl string) *DocumentBuilder

func (*DocumentBuilder) SetName

func (b *DocumentBuilder) SetName(dsl string) *DocumentBuilder

func (*DocumentBuilder) SetNamespace

func (b *DocumentBuilder) SetNamespace(dsl string) *DocumentBuilder

func (*DocumentBuilder) SetVersion

func (b *DocumentBuilder) SetVersion(dsl string) *DocumentBuilder

type DurationBuilder

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

func NewDurationBuilder

func NewDurationBuilder(root *graph.Node) *DurationBuilder

func (*DurationBuilder) GetSeconds

func (b *DurationBuilder) GetSeconds() int

func (*DurationBuilder) SetSeconds

func (b *DurationBuilder) SetSeconds(seconds int) *DurationBuilder

type MapBuilder

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

func NewMapBuilder

func NewMapBuilder(root *graph.Node) *MapBuilder

func (*MapBuilder) Get

func (b *MapBuilder) Get(name string) string

func (*MapBuilder) Set

func (b *MapBuilder) Set(name string, value string)

type UseBuilder

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

func NewUseBuilder

func NewUseBuilder(root *graph.Node) *UseBuilder

type WaitBuilder

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

func NewWaitBuilder

func NewWaitBuilder(root *graph.Node) *WaitBuilder

func (*WaitBuilder) Duration

func (b *WaitBuilder) Duration() *DurationBuilder

func (*WaitBuilder) GetWait

func (b *WaitBuilder) GetWait() string

func (*WaitBuilder) SetWait

func (b *WaitBuilder) SetWait(wait string)

type WorkflowBuilder

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

func NewWorkflowBuilder

func NewWorkflowBuilder() *WorkflowBuilder

func NewWorkflowBuilderFromFile

func NewWorkflowBuilderFromFile(path string) (*WorkflowBuilder, error)

func NewWorkflowBuilderFromJSONSource

func NewWorkflowBuilderFromJSONSource(source []byte) (*WorkflowBuilder, error)

func NewWorkflowBuilderFromYAMLSource

func NewWorkflowBuilderFromYAMLSource(source []byte) (*WorkflowBuilder, error)

func (*WorkflowBuilder) Do

func (b *WorkflowBuilder) Do() *DoBuilder

func (*WorkflowBuilder) Document

func (b *WorkflowBuilder) Document() *DocumentBuilder

func (*WorkflowBuilder) Node

func (b *WorkflowBuilder) Node() *graph.Node

func (*WorkflowBuilder) Use

func (b *WorkflowBuilder) Use() *UseBuilder