flow

Documentation

Overview

Package flow contains a number of constructors for Flow nodes that are convenient for testing.

Index

• func Collect(re, repl string, dep *reflow.Flow) *reflow.Flow
• func Data(b []byte) *reflow.Flow
• func Exec(image, cmd string, resources reflow.Resources, deps ...*reflow.Flow) *reflow.Flow
• func Extern(rawurl string, dep *reflow.Flow) *reflow.Flow
• func Groupby(re string, dep *reflow.Flow) *reflow.Flow
• func Intern(rawurl string) *reflow.Flow
• func Map(fn func(*reflow.Flow) *reflow.Flow, dep *reflow.Flow) *reflow.Flow
• func Merge(deps ...*reflow.Flow) *reflow.Flow
• func Pullup(deps ...*reflow.Flow) *reflow.Flow
• func Val(v reflow.Fileset) *reflow.Flow

Functions

func Collect

func Collect(re, repl string, dep *reflow.Flow) *reflow.Flow

Collect constructs a new reflow.OpCollect node.

func Data

func Data(b []byte) *reflow.Flow

Data constructs a new reflow.Data node.

func Exec

func Exec(image, cmd string, resources reflow.Resources, deps ...*reflow.Flow) *reflow.Flow

Exec constructs a new reflow.OpExec node.

func Extern

func Extern(rawurl string, dep *reflow.Flow) *reflow.Flow

Extern constructs a new reflow.OpExtern node.

func Groupby

func Groupby(re string, dep *reflow.Flow) *reflow.Flow

Groupby constructs a new reflow.OpGroupby node.

func Intern

func Intern(rawurl string) *reflow.Flow

Intern constructs a new reflow.OpIntern node.

func Map

func Map(fn func(*reflow.Flow) *reflow.Flow, dep *reflow.Flow) *reflow.Flow

Map constructs a new reflow.OpMap node.

func Merge

func Merge(deps ...*reflow.Flow) *reflow.Flow

Merge constructs a new reflow.OpMerge node.

func Pullup

func Pullup(deps ...*reflow.Flow) *reflow.Flow

Pullup constructs a new reflow.OpPullup node.

func Val

func Val(v reflow.Fileset) *reflow.Flow

Val constructs a new reflow.OpVal node.