Versions in this module Expand all Collapse all v0 v0.2.0 Aug 6, 2018 v0.1.0 Apr 18, 2018 Changes in this version + type BatchLoader struct + func NewBatchLoader(dbType string, sqlDB *sql.DB) *BatchLoader + func (l *BatchLoader) AddRow(row []interface{}) + func (l *BatchLoader) Commit(ctx context.Context, tableName string, cols ...string) (Stats, error) + func (l *BatchLoader) Delete(query string, vals ...interface{}) + type Duration struct + func (d *Duration) UnmarshalText(b []byte) error + func (d Duration) MarshalText() ([]byte, error) + type NopBatchLoader struct + Mode string + Stats Stats + func NewNopBatchLoader(mode string) *NopBatchLoader + func (l *NopBatchLoader) AddRow(row []interface{}) + func (l *NopBatchLoader) Commit(ctx context.Context, tableName string, cols ...string) (Stats, error) + func (l *NopBatchLoader) Delete(query string, vals ...interface{}) + type Stats struct + BatchDate string + Cols int + Dur Duration + Inserted int64 + Removed int64 + Rows int64 + Started string + Table string + func NewStats() Stats + func NewStatsFromBytes(b []byte) Stats + func (s *Stats) AddRow() + func (s *Stats) ParseBatchDate() time.Time + func (s *Stats) ParseStarted() time.Time + func (s *Stats) SetBatchDate(t time.Time) + func (s *Stats) SetStarted(t time.Time) + func (s Stats) Clone() Stats + func (s Stats) JSONBytes() []byte + func (s Stats) JSONString() string
Go to main page