common

Documentation

Index

• func CreateAliasMap(aliases []v1alpha1.Alias) map[string]string
• type SimpleOutputsResolver
  • func NewSimpleOutputsResolver(store storage.ProtobufStore) SimpleOutputsResolver
  • func (r SimpleOutputsResolver) ExtractOutput(ctx context.Context, w v1alpha1.ExecutableWorkflow, n v1alpha1.ExecutableNode, ...) (values *core.Literal, err error)

Functions

func CreateAliasMap

func CreateAliasMap(aliases []v1alpha1.Alias) map[string]string

Types

type SimpleOutputsResolver

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

A simple output resolver that expects an outputs.pb at the data directory of the node.

func NewSimpleOutputsResolver

func NewSimpleOutputsResolver(store storage.ProtobufStore) SimpleOutputsResolver

Creates a simple output resolver that expects an outputs.pb at the data directory of the node.

func (SimpleOutputsResolver) ExtractOutput

func (r SimpleOutputsResolver) ExtractOutput(ctx context.Context, w v1alpha1.ExecutableWorkflow, n v1alpha1.ExecutableNode,
	bindToVar handler.VarName) (values *core.Literal, err error)