examples

Documentation

Index

• type CSVFormat
  • func (m CSVFormat[T]) Reader(ctx context.Context, r io.Reader) (CSVReader[T], error)
  • func (m CSVFormat[T]) Writer(ctx context.Context, w io.Writer) (CSVWriter[T], error)
• type CSVReader
  • func (r CSVReader[T]) Close(ctx context.Context, err error) error
  • func (r CSVReader[T]) Read(ctx context.Context) (T, error)
• type CSVWriter
  • func (r CSVWriter[T]) Close(ctx context.Context, err error) error
  • func (r CSVWriter[T]) Write(ctx context.Context, row T) error
• type JSONLinesFormat
  • func (m JSONLinesFormat[T]) Reader(ctx context.Context, r io.Reader) (JSONLinesReader[T], error)
  • func (m JSONLinesFormat[T]) Writer(ctx context.Context, w io.Writer) (JSONLinesWriter[T], error)
• type JSONLinesReader
  • func (r JSONLinesReader[T]) Close(ctx context.Context, err error) error
  • func (r JSONLinesReader[T]) Read(ctx context.Context) (T, error)
• type JSONLinesWriter
  • func (r JSONLinesWriter[T]) Close(ctx context.Context, err error) error
  • func (w JSONLinesWriter[T]) Write(ctx context.Context, row T) error

Types

type CSVFormat

type CSVFormat[T any] struct {
	// contains filtered or unexported fields
}

func (CSVFormat[T]) Reader

func (m CSVFormat[T]) Reader(ctx context.Context, r io.Reader) (CSVReader[T], error)

func (CSVFormat[T]) Writer

func (m CSVFormat[T]) Writer(ctx context.Context, w io.Writer) (CSVWriter[T], error)

type CSVReader

type CSVReader[T any] struct {
	// contains filtered or unexported fields
}

func (CSVReader[T]) Close

func (r CSVReader[T]) Close(ctx context.Context, err error) error

func (CSVReader[T]) Read

func (r CSVReader[T]) Read(ctx context.Context) (T, error)

type CSVWriter

type CSVWriter[T any] struct {
	// contains filtered or unexported fields
}

func (CSVWriter[T]) Close

func (r CSVWriter[T]) Close(ctx context.Context, err error) error

func (CSVWriter[T]) Write

func (r CSVWriter[T]) Write(ctx context.Context, row T) error

type JSONLinesFormat

type JSONLinesFormat[T any] struct{}

jsonLinesFormat simply writes JSON lines, leveraging the json package.

func (JSONLinesFormat[T]) Reader

func (m JSONLinesFormat[T]) Reader(ctx context.Context, r io.Reader) (JSONLinesReader[T], error)

func (JSONLinesFormat[T]) Writer

func (m JSONLinesFormat[T]) Writer(ctx context.Context, w io.Writer) (JSONLinesWriter[T], error)

type JSONLinesReader

type JSONLinesReader[T any] struct {
	// contains filtered or unexported fields
}

func (JSONLinesReader[T]) Close

func (r JSONLinesReader[T]) Close(ctx context.Context, err error) error

func (JSONLinesReader[T]) Read

func (r JSONLinesReader[T]) Read(ctx context.Context) (T, error)

type JSONLinesWriter

type JSONLinesWriter[T any] struct {
	// contains filtered or unexported fields
}

func (JSONLinesWriter[T]) Close

func (r JSONLinesWriter[T]) Close(ctx context.Context, err error) error

func (JSONLinesWriter[T]) Write

func (w JSONLinesWriter[T]) Write(ctx context.Context, row T) error