csv

Documentation

Overview

Package csv provides CSV format adapters for the Pulse I/O pipeline.

Package csv provides CSV import and export for the pulse I/O pipeline.

Index

• type Reader
  • func NewReader(fs afero.Fs, path string) *Reader
  • func NewReaderFromBytes(data []byte) *Reader
  • func (r *Reader) Close() error
  • func (r *Reader) ReadHeader() ([]string, error)
  • func (r *Reader) ReadRows(ctx context.Context, fn func(row []string) error) error
  • func (r *Reader) Reset() error
• type Writer
  • func NewWriter(fs afero.Fs, path string) *Writer
  • func NewWriterToBuffer() *Writer
  • func (w *Writer) Bytes() []byte
  • func (w *Writer) Close() error
  • func (w *Writer) WriteHeader(columns []string) error
  • func (w *Writer) WriteRow(values []any) error

Types

type Reader

type Reader struct {
	// contains filtered or unexported fields
}

Reader reads CSV data from a byte source.

func NewReader

func NewReader(fs afero.Fs, path string) *Reader

NewReader creates a CSV reader from a filesystem path.

func NewReaderFromBytes

func NewReaderFromBytes(data []byte) *Reader

NewReaderFromBytes creates a CSV reader from raw bytes.

func (*Reader) Close

func (r *Reader) Close() error

Close releases resources.

func (*Reader) ReadHeader

func (r *Reader) ReadHeader() ([]string, error)

ReadHeader returns the column names from the first row.

func (*Reader) ReadRows

func (r *Reader) ReadRows(ctx context.Context, fn func(row []string) error) error

ReadRows streams rows to fn. ReadHeader must be called first.

func (*Reader) Reset

func (r *Reader) Reset() error

Reset rewinds the reader to the beginning.

type Writer

type Writer struct {
	// contains filtered or unexported fields
}

Writer writes CSV data to a buffer.

func NewWriter

func NewWriter(fs afero.Fs, path string) *Writer

NewWriter creates a CSV writer targeting a filesystem path.

func NewWriterToBuffer

func NewWriterToBuffer() *Writer

NewWriterToBuffer creates a CSV writer that writes to an internal buffer.

func (*Writer) Bytes

func (w *Writer) Bytes() []byte

Bytes returns the buffered CSV output.

func (*Writer) Close

func (w *Writer) Close() error

Close flushes and writes to the target path if configured.

func (*Writer) WriteHeader

func (w *Writer) WriteHeader(columns []string) error

WriteHeader writes the column names as the first CSV row.

func (*Writer) WriteRow

func (w *Writer) WriteRow(values []any) error

WriteRow writes a single data row.