pipeline

package

v0.17.0 Latest Latest Go to latest Published: Nov 3, 2026 License: Apache-2.0 Imports: 4 Imported by: 0

Details

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

Repository

github.com/NethermindEth/juno

Links

Open Source Insights

Documentation ¶

Index ¶

type Pipeline
- func New[I, O any, S State[I, O]](inputs Pipeline[I], concurrency int, state S) Pipeline[O]
- func Source[I any](it iter.Seq[I]) Pipeline[I]
- func (p Pipeline[I]) Run(ctx context.Context) (<-chan I, func() Result)
type Result
type State

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type Pipeline ¶ added in v0.15.18

type Pipeline[I any] func(*resources) <-chan I

func New ¶

func New[I, O any, S State[I, O]](
	inputs Pipeline[I],
	concurrency int,
	state S,
) Pipeline[O]

New fans input out to concurrency workers. Worth it only when the per-item work outweighs the channel handoff and the goroutine wake-ups it costs: a sequential source feeding cheap writes is faster without it

func Source ¶ added in v0.15.18

func Source[I any](it iter.Seq[I]) Pipeline[I]

func (Pipeline[I]) Run ¶ added in v0.15.18

func (p Pipeline[I]) Run(ctx context.Context) (<-chan I, func() Result)

type Result ¶ added in v0.15.18

type Result struct {
	IsDone bool
	Err    error
}

type State ¶

type State[I, O any] interface {
	Run(index int, input I, outputs chan<- O) error
	Done(index int, outputs chan<- O) error
}

Source Files ¶

View all Source files

pipeline.go

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