importer

Documentation

Index

• Variables
• func FromGzippedCSVFiles(a FromGzippedCSVFilesArgs)
• type AddFunc
• type Batcher
• type FromGzippedCSVFilesArgs

Variables

var (
	DebugPrint = true
)

Functions

func FromGzippedCSVFiles

func FromGzippedCSVFiles(a FromGzippedCSVFilesArgs)

Types

type AddFunc

type AddFunc = func(rec, headers []string) error

type Batcher

type Batcher interface {
	Add(rec, headers []string) error
	Flush() error
}

type FromGzippedCSVFilesArgs

type FromGzippedCSVFilesArgs struct {
	Dir              string  // Dir to look for files in
	PrefixFilter     string  // limit to filenames matching the filter
	MaxRecordsToRead int     // Max CSV records to read before exiting
	Batcher          Batcher // Use this batcher (optional)
	AddFunc          AddFunc // Call this add function for each record (optional)
}