flow

package

v0.0.0-...-90deddd Latest Latest Go to latest Published: Oct 18, 2023 License: Apache-2.0 Imports: 6 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

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

This section is empty.

This section is empty.

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

Collect constructs a new flow.Collect node.

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

Data constructs a new reflow.Data node.

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

Exec constructs a new flow.OpExec node.

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

Extern constructs a new flow.Extern node.

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

Groupby constructs a new flow.Groupby node.

func Intern(rawurl string) *flow.Flow

Intern constructs a new flow.OpIntern node.

func K(id string, k func(vs []values.T) *flow.Flow, deps ...*flow.Flow) *flow.Flow

K constructs a new flow.K node.

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

Map constructs a new flow.Map node.

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

Merge constructs a new flow.Merge node.

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

Pullup constructs a new flow.Pullup node.

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

Val constructs a new flow.Val node.

This section is empty.