Versions in this module Expand all Collapse all v0 v0.0.6 Nov 15, 2025 Changes in this version + func AccumulateAndOutput(fn AccumulateAndOutputFunc) gloo.Command + func AccumulateAndProcess(fn AccumulateAndProcessFunc) gloo.Command + func ChannelAccumulateAndOutput[T any](fn ChannelAccumulateAndOutputFunc[T]) gloo.ChannelCommand[T] + func ChannelAccumulateAndProcess[T any](fn ChannelAccumulateAndProcessFunc[T]) gloo.ChannelCommand[T] + func ChannelBuffer[T any](size int) gloo.ChannelExecutor[T] + func ChannelFanOut[T any](outputs ...chan<- gloo.Row[T]) gloo.ChannelExecutor[T] + func ChannelLineTransform[T any](fn ChannelLineTransformFunc[T]) gloo.ChannelCommand[T] + func ChannelMerge[T any](inputs ...<-chan gloo.Row[T]) gloo.ChannelExecutor[T] + func ChannelStatefulLineTransform[T any](fn ChannelStatefulLineTransformFunc[T]) gloo.ChannelCommand[T] + func ChannelTransform[TIn, TOut any](fn func(TIn) (TOut, bool, error)) func(context.Context, <-chan gloo.Row[TIn], chan<- gloo.Row[TOut]) error + func LineTransform(fn LineTransformFunc) gloo.Command + func RawCommand(fn gloo.CommandExecutor) gloo.Command + func StatefulLineTransform(fn StatefulLineTransformFunc) gloo.Command + type AccumulateAndOutputFunc func(lines []string, stdout io.Writer) error + type AccumulateAndProcessFunc func(lines []string) []string + type ChannelAccumulateAndOutputFunc func(rows []T, out chan<- gloo.Row[T]) error + type ChannelAccumulateAndProcessFunc func(rows []T) []T + type ChannelLineTransformFunc func(data T) (output T, emit bool) + type ChannelStatefulLineTransformFunc func(rowNum int64, data T) (output T, emit bool) + type LineTransformFunc func(line string) (output string, emit bool) + type StatefulLineTransformFunc func(lineNum int64, line string) (output string, emit bool)
Go to main page