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

script

package module

Go to main page

Versions in this module

v0

v0.3.0

Oct 17, 2025

Changes in this version

type Processor

+ func ChainProcessor(processors ...Processor) Processor

type Writer

+ func ChainWriter(writers ...Writer) Writer

v0.2.0

Oct 14, 2025

Changes in this version

type Processor

+ func Chain(processors ...Processor) Processor

+ type RunResult struct

+ Processed int

+ Read int

+ Written int

v0.1.0

Aug 31, 2025

Changes in this version

+ var EOF error = io.EOF

+ var ErrNoProcessors = errors.New("no processors provided")

+ func Run(ctx context.Context, r RunConfig) error

+ type CSVReader struct

+ func NewCSVReader(filename string) (*CSVReader, error)

+ func (c *CSVReader) Close() error

+ func (c *CSVReader) Read() ([]string, error)

+ type CSVWriter struct

+ func NewCSVWriter(filename string) (*CSVWriter, error)

+ func (c *CSVWriter) Close() error

+ func (c *CSVWriter) Error() error

+ func (c *CSVWriter) Write(record []string) error

+ type MemReader struct

+ func NewMemReader(records [][]string) *MemReader

+ func (m *MemReader) Read() ([]string, error)

+ type MemWriter struct

+ func NewMemWriter() *MemWriter

+ func (m *MemWriter) Output() [][]string

+ func (m *MemWriter) Write(record []string) error

+ type NopWriter struct

+ func NewNopWriter() *NopWriter

+ func (d *NopWriter) Write([]string) error

+ type Processor func(context.Context, []string) ([]string, error)

+ type Reader interface

+ Read func() ([]string, error)

+ type RunConfig struct

+ Concurrency int

+ Input Reader

+ Limit int

+ Offset int

+ Output Writer

+ Processor Processor

+ type StdinReader struct

+ func NewStdinReader() *StdinReader

+ func (s *StdinReader) Read() ([]string, error)

+ type StdoutWriter struct

+ func NewStdoutWriter() *StdoutWriter

+ func (s *StdoutWriter) Write(in []string) error

+ type Writer interface

+ Write func([]string) error