graph

Documentation

Index

• Constants
• type Asset
• type AssetManager
  • func NewAssetManager(baseURL string, opts ...storage.Option) *AssetManager
  • func (m *AssetManager) LoadAsset(ctx context.Context, loc string) (*Asset, bool, error)
  • func (m *AssetManager) LoadWorkflow(ctx context.Context, URL string) *Asset
• type Instance
• type Instances
  • func NewInstances(holderURL string, match string, objects []storage.Object) *Instances
  • func (i *Instances) Lookup(index int) *Instance
  • func (i *Instances) Range() string
• type Node
  • func NewWorkflowNode(name string, node *yaml.Node) *Node
  • func (n *Node) ActionMap() (map[string]interface{}, error)
  • func (n *Node) Data() string
  • func (n *Node) Extracts(callback func(name string, node *Node) error) error
  • func (n *Node) HasInit()
  • func (n *Node) IsTaskNode() bool
  • func (n *Node) Request() (interface{}, error)
  • func (n *Node) Scalar(name string) (interface{}, bool)
  • func (n *Node) String(name string) (interface{}, bool)
  • func (n *Node) Task(name string) (*Node, error)
  • func (n *Node) TaskMap() (map[string]interface{}, error)
  • func (n *Node) Tasks(callback func(name string, node *Node) error) error
  • func (n *Node) Template() *Node
  • func (n *Node) Variables(ns string) (string, error)
  • func (n *Node) WorkflowMap() (map[string]interface{}, error)
• type Service
  • func New() *Service
  • func (s *Service) LoadWorkflow(ctx context.Context, URL string, opts ...storage.Option) (*Node, error)
• type Type

Constants

const (
	TypeWorkflow = Type(iota)
	TypeVariable
	TypeTask
	TypeAction
	TypeTemplate
)

Types

type Asset

type Asset struct {
	Name string
	URI  string
	storage.Object
}

Asset represents an asset

type AssetManager

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

func NewAssetManager

func NewAssetManager(baseURL string, opts ...storage.Option) *AssetManager

func (*AssetManager) LoadAsset

func (m *AssetManager) LoadAsset(ctx context.Context, loc string) (*Asset, bool, error)

func (*AssetManager) LoadWorkflow

func (m *AssetManager) LoadWorkflow(ctx context.Context, URL string) *Asset

type Instance

type Instance struct {
	Object storage.Object
	Tag    string
	Match  string
	Index  int
}

type Instances

type Instances struct {
	BaseURL   string
	Instances []*Instance
	ByIdx     map[int]int
	Min       int
	Max       int
	Match     string
	// contains filtered or unexported fields
}

func NewInstances

func NewInstances(holderURL string, match string, objects []storage.Object) *Instances

func (*Instances) Lookup

func (i *Instances) Lookup(index int) *Instance

func (*Instances) Range

func (i *Instances) Range() string

type Node

type Node struct {
	*yml.Node
	Type       Type
	Name       string
	IsTemplate bool
}

Node represents a workflow node

func NewWorkflowNode

func NewWorkflowNode(name string, node *yaml.Node) *Node

func (*Node) ActionMap

func (n *Node) ActionMap() (map[string]interface{}, error)

ActionMap returns action map

func (*Node) Data

func (n *Node) Data() string

func (*Node) Extracts

func (n *Node) Extracts(callback func(name string, node *Node) error) error

func (*Node) HasInit

func (n *Node) HasInit()

func (*Node) IsTaskNode

func (n *Node) IsTaskNode() bool

func (*Node) Request

func (n *Node) Request() (interface{}, error)

func (*Node) Scalar

func (n *Node) Scalar(name string) (interface{}, bool)

func (*Node) String

func (n *Node) String(name string) (interface{}, bool)

func (*Node) Task

func (n *Node) Task(name string) (*Node, error)

func (*Node) TaskMap

func (n *Node) TaskMap() (map[string]interface{}, error)

TaskMap returns task map

func (*Node) Tasks

func (n *Node) Tasks(callback func(name string, node *Node) error) error

func (*Node) Template

func (n *Node) Template() *Node

func (*Node) Variables

func (n *Node) Variables(ns string) (string, error)

func (*Node) WorkflowMap

func (n *Node) WorkflowMap() (map[string]interface{}, error)

type Service

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

func New

func New() *Service

func (*Service) LoadWorkflow

func (s *Service) LoadWorkflow(ctx context.Context, URL string, opts ...storage.Option) (*Node, error)

type Type

type Type int

Type represents a node type