stream_ops

package

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

Details

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

Repository

github.com/nexssp/flow

Links

Open Source Insights

Documentation ¶

Overview ¶

Package stream_ops exposes kernel stream operations to Flow DSL.

Typical use:

fs.walk -> stream.batch @{ size: 100 } -> process

Index ¶

Constants
func Bundle(_ map[string]string) compiler.Bundle
func Fold(cfg FoldConfig) action.StreamOp[any, any]
func Library() action.Library
func Operators() []action.NamedOperator
type FoldConfig

Constants ¶

View Source

const ID = "stream_ops"

Variables ¶

This section is empty.

Functions ¶

func Bundle ¶

func Bundle(_ map[string]string) compiler.Bundle

func Fold ¶ added in v0.30.2

func Fold(cfg FoldConfig) action.StreamOp[any, any]

Fold consumes the complete stream and emits one accumulated value. Its expression is compiled once when the operator is built; evaluation remains streaming and retains only the accumulator.

func Library ¶

func Library() action.Library

func Operators ¶

func Operators() []action.NamedOperator

Operators exposes the stateless stream manipulators into the DSL.

Types ¶

type FoldConfig ¶ added in v0.30.2

type FoldConfig struct {
	Initial    any    `json:"initial"`
	Expression string `json:"expression"`
}

FoldConfig configures stream.fold. Expression is evaluated once per input item with the current accumulator available as acc and the input as item.

Source Files ¶

View all Source files

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