util

Mar 3, 2016

Changes in this version

+ func CSVString(v interface{}) string

+ func DeleteS3Objects(client *s3.S3, bucket string, objKeys []string) (*s3.DeleteObjectsOutput, error)

+ func ExecuteSQLQuery(db *sql.DB, query string) error

+ func GetDataFromSQLQuery(db *sql.DB, query string, batchSize int, structDest interface{}) (chan data.JSON, error)

+ func GetS3Object(client *s3.S3, bucket, objKey string) (*s3.GetObjectOutput, error)

+ func KillPipelineIfErr(err error, killChan chan error)

+ func ListS3Objects(client *s3.S3, bucket, keyPrefix string) ([]string, error)

+ func SQLInsertData(db *sql.DB, d data.JSON, tableName string, onDupKeyUpdate bool, batchSize int) error

+ type CSVWriter struct

+ AlwaysEncapsulate bool

+ Comma rune

+ QuoteEscape string

+ UseCRLF bool

+ func NewCSVWriter(w io.Writer) *CSVWriter

+ func (w *CSVWriter) Error() error

+ func (w *CSVWriter) Flush()

+ func (w *CSVWriter) Write(record []string) (err error)

+ func (w *CSVWriter) WriteAll(records [][]string) (err error)

+ type Timer struct

+ func StartTimer() (t *Timer)

+ func (t *Timer) Duration() time.Duration

+ func (t *Timer) Stop() *Timer

+ func (t *Timer) Stopped() bool

+ func (t *Timer) String() string