processor

Documentation

Index

• type Processor
  • func New(stores []Store) Processor
• type Reader
  • func NewReader(r io.Reader, endDate time.Time) Reader
• type Store
  • func NewStores() []Store

Types

type Processor

type Processor interface {
	Run(csvFile Reader, outputDir string) error
}

func New

func New(stores []Store) Processor

type Reader

type Reader interface {
	Read() (record []string, err error)
	GetEndDate() time.Time
	GetStartDate() time.Time
}

func NewReader

func NewReader(r io.Reader, endDate time.Time) Reader

type Store

type Store interface {
	Save([]string)
	Flush() io.Reader
}

func NewStores

func NewStores() []Store