Versions in this module Expand all Collapse all v0 v0.4.0 Jan 27, 2017 v0.3.0 Jan 12, 2017 Changes in this version + var DBCmd = &cobra.Command + func ApplyMigrations(dir migrate.MigrationDirection, dryrun bool, limit int) error + func DB() *sql.DB + func DBMap(db *sql.DB) *gorp.DbMap + func Init() (*sql.DB, error) + func InitSchemas(sqlDB *sql.DB, sqlfile string) error + func Set(d *sql.DB) + func Status() string + type Executer interface + Exec func(query string, args ...interface{}) (sql.Result, error) + type MigrationLock struct + Id string + Locked *time.Time + Unlocked *time.Time + type PipelineScheduler sdk.PipelineScheduler + func (p *PipelineScheduler) PostGet(s gorp.SqlExecutor) error + func (p *PipelineScheduler) PostInsert(s gorp.SqlExecutor) error + func (p *PipelineScheduler) PostUpdate(s gorp.SqlExecutor) error + func (p *PipelineScheduler) PreDelete(s gorp.SqlExecutor) error + type PipelineSchedulerExecution sdk.PipelineSchedulerExecution + type Querier interface + Query func(query string, args ...interface{}) (*sql.Rows, error) + QueryRow func(query string, args ...interface{}) *sql.Row + type QueryExecuter interface + Exec func(query string, args ...interface{}) (sql.Result, error) + Query func(query string, args ...interface{}) (*sql.Rows, error) + QueryRow func(query string, args ...interface{}) *sql.Row + type Scanner interface + Scan func(dest ...interface{}) error + type TemplateExtension sdk.TemplateExtension + func (t *TemplateExtension) PostInsert(s gorp.SqlExecutor) error + func (t *TemplateExtension) PostUpdate(s gorp.SqlExecutor) error + func (t *TemplateExtension) PreDelete(s gorp.SqlExecutor) error + type WorkerModel sdk.Model + func (m *WorkerModel) PostInsert(s gorp.SqlExecutor) error + func (m *WorkerModel) PostSelect(s gorp.SqlExecutor) error + func (m *WorkerModel) PostUpdate(s gorp.SqlExecutor) error + func (m *WorkerModel) PreDelete(s gorp.SqlExecutor) error