pipeline

Apr 27, 2020

Changes in this version

type DBSynchronizer

+ RowCount func() int64

Apr 25, 2020

Changes in this version

+ type CSVReader struct

+ FileName string

+ Separator rune

+ func (r *CSVReader) Close() error

+ func (r *CSVReader) HeaderRow() []string

+ func (r *CSVReader) Open() error

+ func (r *CSVReader) ReadRow() ([]string, error)

+ func (r *CSVReader) RowCount() int64

+ func (r *CSVReader) Source() string

+ type Computer interface

+ Compute func(map[string]interface{}) (map[string]interface{}, error)

+ type Converter interface

+ Convert func(map[string]interface{}) (map[string]interface{}, error)

+ type DBConfig struct

+ Db string

+ Host string

+ Password string

+ Port int32

+ SSLMode string

+ User string

+ func NewDBConfig(configFile string) (DBConfig, error)

+ func (c DBConfig) ConnectionString() string

+ type DBSynchronizer interface

+ Create func(*sql.DB) error

+ Delete func(*sql.DB) error

+ DependsOn func() []string

+ Drop func(*sql.DB) error

+ Fill func(*sql.DB) error

+ Name func() string

+ type FieldProvider interface

+ ProvideField func([]string) (map[string]interface{}, error)

+ Setup func(header []string) error

+ type RecordReader struct

+ Computer Computer

+ Converter Converter

+ FieldProvider FieldProvider

+ Name string

+ RowReader RowReader

+ Validator Validator

+ func (r *RecordReader) Close() error

+ func (r *RecordReader) Open() error

+ func (r *RecordReader) ReadRecord() (map[string]interface{}, error)

+ type RowReader interface

+ Close func() error

+ HeaderRow func() []string

+ Open func() error

+ ReadRow func() ([]string, error)

+ RowCount func() int64

+ Source func() string

+ type Validator interface

+ Validate func(map[string]interface{}) error