Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

gloo

package module

Go to main page

Versions in this module

v0

v0.0.6

Nov 15, 2025

v0.0.5

Nov 15, 2025

v0.0.4

Nov 15, 2025

Changes in this version

+ func MustRunChannel[T any](cmd ChannelCommand[T])

+ func ReaderToChannelParsed[T any](ctx context.Context, r io.Reader, out chan<- Row[T]) error

+ func ReaderToChannelWithParser[T any](ctx context.Context, r io.Reader, out chan<- Row[T], ...) error

+ func RunChannelWithContext[T any](ctx context.Context, cmd ChannelCommand[T]) error

+ func RunChannel[T any](cmd ChannelCommand[T]) error

+ type ChannelCommand interface

+ ChannelExecutor func() ChannelExecutor[T]

+ type ChannelExecutor func(ctx context.Context, in <-chan Row[T], out chan<- Row[T]) error

+ func Batch[T any](size int, fn func([]T) ([]T, error)) ChannelExecutor[T]

+ func ParallelMap[T any](workers int, fn func(T) (T, bool, error)) ChannelExecutor[T]

+ func Pipe[T any](first ChannelExecutor[T], rest ...ChannelExecutor[T]) ChannelExecutor[T]

type Command

+ func Pipeline[T any](executor ChannelExecutor[T]) Command

type Inputs

+ func (inputs Inputs[T, O]) ToChannelBytes(ctx context.Context, stdin io.Reader, out chan<- Row[[]byte]) error

+ func (inputs Inputs[T, O]) ToChannelString(ctx context.Context, stdin io.Reader, out chan<- Row[string]) error

+ func (inputs Inputs[T, O]) WrapChannelBytes(executor ChannelExecutor[[]byte]) CommandExecutor

+ func (inputs Inputs[T, O]) WrapChannelString(executor ChannelExecutor[string]) CommandExecutor

+ type Row struct

+ Data T

+ Err error

+ type RowParser interface

+ ParseRow func(line string) error

v0.0.3

Nov 7, 2025

v0.0.1

Nov 7, 2025

Changes in this version

+ func Must(err error)

+ func MustRun(cmd Command)

+ func Run(cmd Command) error

+ func RunWithContext(ctx context.Context, cmd Command) error

+ type AccumulateAndOutputFunc func(lines []string, stdout io.Writer) error

+ type AccumulateAndProcessFunc func(lines []string) []string

+ type Command interface

+ Executor func() CommandExecutor

+ func AccumulateAndOutput(fn AccumulateAndOutputFunc) Command

+ func AccumulateAndProcess(fn AccumulateAndProcessFunc) Command

+ func LineTransform(fn LineTransformFunc) Command

+ func RawCommand(fn CommandExecutor) Command

+ func StatefulLineTransform(fn StatefulLineTransformFunc) Command

+ type CommandExecutor func(ctx context.Context, stdin io.Reader, stdout, stderr io.Writer) error

+ type File string

+ type Inputs struct

+ Ambiguous []any

+ Flags O

+ Positional []T

+ func Initialize[T any, O any](parameters ...any) Inputs[T, O]

+ func (inputs Inputs[T, O]) Close() error

+ func (inputs Inputs[T, O]) Reader(stdin io.Reader) io.Reader

+ func (inputs Inputs[T, O]) Readers() []io.Reader

+ func (inputs Inputs[T, O]) Wrap(executor CommandExecutor) CommandExecutor

+ type LineTransformFunc func(line string) (output string, emit bool)

+ type StatefulLineTransformFunc func(lineNum int64, line string) (output string, emit bool)

+ type Switch interface

+ Configure func(*T)