graph

package

v0.96.0 Latest Latest Go to latest Published: Oct 21, 2026 License: Apache-2.0 Imports: 15 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/viant/endly

Links

Open Source Insights

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
type Service
- func New() *Service
- func (s *Service) LoadWorkflow(ctx context.Context, URL string, opts ...storage.Option) (*Node, error)
type Type

Constants ¶

View Source

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

Variables ¶

This section is empty.

Functions ¶

This section is empty.

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

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
yml

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL