Examples

Real-world pipeline recipes showing patterns in action.

Each command ships an /alias package that re-exports its constructor and options under short names. Import the ones you need:

import (
    "os"

    gloo "github.com/gloo-foo/framework"
    grep "github.com/gloo-foo/cmd-grep/alias"
    sort "github.com/gloo-foo/cmd-sort/alias"
    uniq "github.com/gloo-foo/cmd-uniq/alias"
)

Log Processing

Find 5xx errors, sort them, count unique occurrences.

filter accumulate stateful-filter


gloo.Run(source, gloo.ByteWriteTo(os.Stdout),
    grep.Grep("5[0-9]{2}", grep.Extended),
    sort.Sort(),
    uniq.Uniq(uniq.Count),
)

Filter selects lines matching 5xx. Accumulate sorts. StatefulFilter deduplicates and counts.

Data Transformation

CSV to JSON, then pluck specific fields.

accumulate map


gloo.Run(source, gloo.ByteWriteTo(os.Stdout),
    fromcsv.FromCsv(),
    pluck.Pluck("name", "email"),
)

FromCsv accumulates rows into JSON objects; Pluck maps each object to just the named fields.

Field Extraction

Extract fields 1 and 3 from comma-delimited input.

map


gloo.Run(source, gloo.ByteWriteTo(os.Stdout),
    cut.Cut(cut.Fields(1, 3), cut.Delimiter(",")),
)

One Map command. Clean, readable, type-safe.

Multi-Stage ETL

Filter active records, extract a field, number results, take first 10.

filter map stateful-map stateful-filter


gloo.Chain(source).
    To(grep.Grep("active", grep.IgnoreCase)).
    To(cut.Cut(cut.Fields(3), cut.Delimiter(","))).
    To(nl.Nl()).
    To(head.Head(head.Lines(10))).
    Sink(gloo.ByteWriteTo(os.Stdout))

Filter → Map → StatefulMap → StatefulFilter. Four patterns, four lines.