migration

package module

Go to main page

Versions in this module

v1

v1.3.1

Jul 16, 2019

v1.3.0

Jul 16, 2019

Changes in this version

+ type PostgreSQLTarget struct

+ func NewPostgreSQLTarget(db *sql.DB) *PostgreSQLTarget

+ func (target *PostgreSQLTarget) AddMigration(summary *Summary) error

+ func (target *PostgreSQLTarget) MigrationsExecuted() ([]time.Time, error)

+ func (target *PostgreSQLTarget) RemoveMigration(summary *Summary) error

+ func (target *PostgreSQLTarget) Version() (time.Time, error)

v1.2.3

Apr 21, 2019

v1.2.2

Apr 16, 2019

Changes in this version

type DefaultMigration

+ func NewCodeMigrationCustom(skip int, handlers ...Handler) *DefaultMigration

type Summary

+ func (summary *Summary) Duration() time.Duration

v1.2.1

Apr 15, 2019

v1.2.0

Apr 15, 2019

Changes in this version

type MongoDBTarget

+ func (t *MongoDBTarget) Database() *mgo.Database

v1.1.0

Nov 21, 2018

Changes in this version

+ const DefaultMigrationTable

+ var CodeMigrationDateFormat = "20060102150405"

+ var ErrMigrationPanicked = errors.New("migration panicked")

+ var ErrMigrationStarved = errors.New("migration starvation")

+ var NoVersion = time.Date(0, 0, 0, 0, 0, 0, 0, time.UTC)

+ func NewMigrationID(str string) time.Time

+ func Register(migration Migration)

+ type ArgsRunner struct

+ func (runner *ArgsRunner) Run()

+ type BaseMigration struct

+ func (m *BaseMigration) GetDescription() string

+ func (m *BaseMigration) GetID() time.Time

+ type CodeSource struct

+ func DefaultCodeSource() *CodeSource

+ func NewCodeSource() *CodeSource

+ func (s *CodeSource) List() ([]Migration, error)

+ func (s *CodeSource) Register(migration Migration)

+ type DefaultMigration struct

+ func NewCodeMigration(handlers ...Handler) *DefaultMigration

+ func NewMigration(id time.Time, description string, handlers ...Handler) *DefaultMigration

+ func (m *DefaultMigration) Do() error

+ func (m *DefaultMigration) GetManager() Manager

+ func (m *DefaultMigration) SetManager(manager Manager) Migration

+ func (m *DefaultMigration) Undo() error

+ type DefaultReporter struct

+ func NewDefaultReporter() *DefaultReporter

+ func NewDefaultReporterWithParams(w io.Writer, exitFnc func(code int)) *DefaultReporter

+ func (reporter *DefaultReporter) AfterMigrate(migrations []*Summary, err error)

+ func (reporter *DefaultReporter) AfterMigration(summary Summary, err error)

+ func (reporter *DefaultReporter) AfterReset(rewindSummary []*Summary, migrateSummary []*Summary, err error)

+ func (reporter *DefaultReporter) AfterRewind(migrations []*Summary, err error)

+ func (reporter *DefaultReporter) BeforeMigrate(migrations []Migration)

+ func (reporter *DefaultReporter) BeforeMigration(summary Summary, err error)

+ func (reporter *DefaultReporter) BeforeReset()

+ func (reporter *DefaultReporter) BeforeRewind(migrations []Migration)

+ func (reporter *DefaultReporter) CommandNotFound(command string)

+ func (reporter *DefaultReporter) Exit(code int)

+ func (reporter *DefaultReporter) Failure(err error)

+ func (reporter *DefaultReporter) ListExecuted(migrations []Migration, err error)

+ func (reporter *DefaultReporter) ListPending(migrations []Migration, err error)

+ func (reporter *DefaultReporter) MigrationSummary(migration *Summary, err error)

+ func (reporter *DefaultReporter) MigrationsStarved(migrations []Migration)

+ func (reporter *DefaultReporter) NoCommand()

+ func (reporter *DefaultReporter) Usage()

+ type Direction uint

+ const DirectionDo

+ const DirectionUndo

+ type DirectorySource struct

+ Directory string

+ Extension string

+ func (s *DirectorySource) List() ([]Migration, error)

+ type FileMigration struct

+ func (m *FileMigration) Do() error

+ func (m *FileMigration) GetDescription() string

+ func (m *FileMigration) GetID() time.Time

+ func (m *FileMigration) GetManager() Manager

+ func (m *FileMigration) SetManager(manager Manager) Migration

+ func (m *FileMigration) Undo() error

+ type Handler func() error

+ type Manager interface

+ Do func(listener Reporter) (*Summary, error)

+ Migrate func(listener Reporter) ([]*Summary, error)

+ MigrationsExecuted func() ([]Migration, error)

+ MigrationsPending func() ([]Migration, error)

+ Reset func(listener Reporter) ([]*Summary, []*Summary, error)

+ Rewind func(listener Reporter) ([]*Summary, error)

+ Source func() Source

+ Target func() Target

+ Undo func(listener Reporter) (*Summary, error)

+ func NewDefaultManager(target Target, source Source) Manager

+ type ManagerDefault struct

+ func (manager *ManagerDefault) Do(reporter Reporter) (*Summary, error)

+ func (manager *ManagerDefault) Migrate(reporter Reporter) ([]*Summary, error)

+ func (manager *ManagerDefault) MigrationsExecuted() ([]Migration, error)

+ func (manager *ManagerDefault) MigrationsPending() ([]Migration, error)

+ func (manager *ManagerDefault) Reset(reporter Reporter) ([]*Summary, []*Summary, error)

+ func (manager *ManagerDefault) Rewind(reporter Reporter) ([]*Summary, error)

+ func (manager *ManagerDefault) Source() Source

+ func (manager *ManagerDefault) Target() Target

+ func (manager *ManagerDefault) Undo(reporter Reporter) (*Summary, error)

+ type Migration interface

+ Do func() error

+ GetDescription func() string

+ GetID func() time.Time

+ GetManager func() Manager

+ SetManager func(manager Manager) Migration

+ Undo func() error

+ type MongoDBTarget struct

+ func NewMongoDB(session *mgo.Session) *MongoDBTarget

+ func (t *MongoDBTarget) AddMigration(summary *Summary) error

+ func (t *MongoDBTarget) MigrationsExecuted() ([]time.Time, error)

+ func (t *MongoDBTarget) RemoveMigration(summary *Summary) error

+ func (t *MongoDBTarget) Session() *mgo.Session

+ func (t *MongoDBTarget) SetCollectionName(collection string) *MongoDBTarget

+ func (t *MongoDBTarget) Version() (migrationID time.Time, err error)

+ type MySQLTarget struct

+ func NewMySQL(conn *sql.DB) *MySQLTarget

+ func (target *MySQLTarget) Connection() *sql.DB

+ func (target *MySQLTarget) SetTableName(collection string) *MySQLTarget

+ func (target *MySQLTarget) SetVersion(id time.Time) error

+ func (target *MySQLTarget) Version() (time.Time, error)

+ type Reporter interface

+ AfterMigrate func(migrations []*Summary, err error)

+ AfterMigration func(migration Summary, err error)

+ AfterReset func(rewindSummary []*Summary, migrateSummary []*Summary, err error)

+ AfterRewind func(migrations []*Summary, err error)

+ BeforeMigrate func(migrations []Migration)

+ BeforeMigration func(migration Summary, err error)

+ BeforeReset func()

+ BeforeRewind func(migrations []Migration)

+ CommandNotFound func(command string)

+ Exit func(code int)

+ Failure func(err error)

+ ListExecuted func(migrations []Migration, err error)

+ ListPending func(migrations []Migration, err error)

+ MigrationSummary func(migration *Summary, err error)

+ MigrationsStarved func(migrations []Migration)

+ NoCommand func()

+ Usage func()

+ type Runner interface

+ Run func()

+ func NewArgsRunner(reporter Reporter, manager Manager, exitFnc func(code int)) Runner

+ func NewArgsRunnerCustom(reporter Reporter, manager Manager, exitFnc func(code int), args ...string) Runner

+ type Source interface

+ List func() ([]Migration, error)

+ type Summary struct

+ Migration Migration

+ func NewSummary(migration Migration) *Summary

+ func (summary *Summary) Direction() Direction

+ func (summary *Summary) Failed() bool

+ func (summary *Summary) Failure() error

+ func (summary *Summary) PanicData() interface{}

+ func (summary *Summary) Panicked() bool

+ type Target interface

+ AddMigration func(summary *Summary) error

+ MigrationsExecuted func() ([]time.Time, error)

+ RemoveMigration func(summary *Summary) error

+ Version func() (time.Time, error)

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL