pcsv

Documentation

Index

• func Marshal(v interface{}) ([]string, error)
• func Unmarshal(data []string, v interface{}) error
• type PCsvReader
  • func NewPCsvReader(filePaths []string, withHeader bool) *PCsvReader
  • func (pr *PCsvReader) Read(dataCh chan []string)
• type PCsvWriter
  • func NewPCsvWriter(filePrefix, outputDir string) *PCsvWriter
  • func (pw *PCsvWriter) Write(dataCh chan []string)

Functions

func Marshal

func Marshal(v interface{}) ([]string, error)

Marshal struct to csv row([]string)

func Unmarshal

func Unmarshal(data []string, v interface{}) error

Unmarshal csv row([]string) to struct

Types

type PCsvReader

type PCsvReader struct {
	WithHeader      bool
	FieldsPerRecord int
	FilePaths       []string
	ReadingState    map[string]int // map[filepath]line
}

func NewPCsvReader

func NewPCsvReader(filePaths []string, withHeader bool) *PCsvReader

func (*PCsvReader) Read

func (pr *PCsvReader) Read(dataCh chan []string)

type PCsvWriter

type PCsvWriter struct {
	Lines      int
	FileNo     int
	CsvFile    *os.File
	MaxLines   int
	FilePrefix string
	OutputDir  string
	Title      []string
}

func NewPCsvWriter

func NewPCsvWriter(filePrefix, outputDir string) *PCsvWriter

func (*PCsvWriter) Write

func (pw *PCsvWriter) Write(dataCh chan []string)