cbcsv

Documentation

Index

• Variables
• type ConcurrentWaitGroup
• type Csv
  • func NewCsv[T any](opts ...CsvOption) (c *Csv[T], e error)
  • func (c *Csv[T]) Close() (errs []error)
  • func (c *Csv[T]) Range(fn func(offset int, item T) error, wg ConcurrentWaitGroup) error
  • func (c *Csv[T]) Read() (T, error)
  • func (c *Csv[T]) Write(item T) error
• type CsvOption
  • func WithAppendFile() CsvOption
  • func WithFilePath(filePath string) CsvOption
  • func WithMissingHeader() CsvOption
  • func WithRead() CsvOption
  • func WithReader(reader io.ReadCloser) CsvOption
  • func WithSkipErrors() CsvOption
  • func WithSkipRows(rows int) CsvOption
  • func WithTruncatedFile() CsvOption
  • func WithWrite() CsvOption
  • func WithWriter(writer io.WriteCloser) CsvOption

Variables

var (
	ErrNotInReadMode  = errors.New("csv is not in read mode")
	ErrNotInWriteMode = errors.New("csv is not in write mode")
)

Types

type ConcurrentWaitGroup

type ConcurrentWaitGroup interface {
	Add()
	Done()
	Wait()
}

type Csv

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

func NewCsv

func NewCsv[T any](opts ...CsvOption) (c *Csv[T], e error)

func (*Csv[T]) Close

func (c *Csv[T]) Close() (errs []error)

func (*Csv[T]) Range

func (c *Csv[T]) Range(fn func(offset int, item T) error, wg ConcurrentWaitGroup) error

func (*Csv[T]) Read

func (c *Csv[T]) Read() (T, error)

func (*Csv[T]) Write

func (c *Csv[T]) Write(item T) error

type CsvOption

type CsvOption func(o *csvOptions)

func WithAppendFile

func WithAppendFile() CsvOption

func WithFilePath

func WithFilePath(filePath string) CsvOption

func WithMissingHeader

func WithMissingHeader() CsvOption

func WithRead

func WithRead() CsvOption

func WithReader

func WithReader(reader io.ReadCloser) CsvOption

func WithSkipErrors

func WithSkipErrors() CsvOption

func WithSkipRows

func WithSkipRows(rows int) CsvOption

func WithTruncatedFile

func WithTruncatedFile() CsvOption

func WithWrite

func WithWrite() CsvOption

func WithWriter

func WithWriter(writer io.WriteCloser) CsvOption