Documentation ¶
Index ¶
Constants ¶
View Source
const MAX_COLUMNS_TO_ADD = 20
Variables ¶
View Source
var MISSING_COLUMN_REGEXP = regexp.MustCompile(
`pq: column "([^"]*)" of relation "([^"]*)" does not exist`)
Functions ¶
func QuoteString ¶
func ValidateOptions ¶
func ValidateOptions(options *Options)
Types ¶
type Connection ¶
type Connection struct {
// contains filtered or unexported fields
}
func NewConnection ¶
func NewConnection(opts *Options, configPath string) *Connection
func (*Connection) CreateTable ¶
func (conn *Connection) CreateTable()
func (*Connection) InsertMaps ¶
func (conn *Connection) InsertMaps(maps []map[string]interface{})
func (*Connection) QueryForLastTimestamp ¶
func (conn *Connection) QueryForLastTimestamp(whereClause string) time.Time
Click to show internal directories.
Click to hide internal directories.