csv

Documentation

Index

• type CSVErrWriter
  • func (w *CSVErrWriter) InitFile(file config.File, concurrency int)
• type CSVReader
  • func (r *CSVReader) Read()

Types

type CSVErrWriter

type CSVErrWriter struct {
	ErrCh  <-chan base.ErrData
	FailCh chan<- stats.Stats
	// contains filtered or unexported fields
}

func (*CSVErrWriter) InitFile

func (w *CSVErrWriter) InitFile(file config.File, concurrency int)

type CSVReader

type CSVReader struct {
	File    config.File
	DataChs []chan base.Data
}

func (*CSVReader) Read

func (r *CSVReader) Read()