Documentation ¶
Overview ¶
Package flow contains a number of constructors for Flow nodes that are convenient for testing.
Index ¶
- func Collect(re, repl string, dep *flow.Flow) *flow.Flow
- func Data(b []byte) *flow.Flow
- func Exec(image, cmd string, resources reflow.Resources, deps ...*flow.Flow) *flow.Flow
- func Extern(rawurl string, dep *flow.Flow) *flow.Flow
- func Groupby(re string, dep *flow.Flow) *flow.Flow
- func Intern(rawurl string) *flow.Flow
- func K(id string, k func(vs []values.T) *flow.Flow, deps ...*flow.Flow) *flow.Flow
- func Map(fn func(*flow.Flow) *flow.Flow, dep *flow.Flow) *flow.Flow
- func Merge(deps ...*flow.Flow) *flow.Flow
- func Pullup(deps ...*flow.Flow) *flow.Flow
- func Val(v reflow.Fileset) *flow.Flow
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
This section is empty.
Click to show internal directories.
Click to hide internal directories.