migrate

Feb 19, 2019

Changes in this version

+ var ErrInvalidVersion = errors.New("version must be >= -1")

Oct 10, 2018

Changes in this version

+ var DefaultBufferSize = uint(100000)

+ var DefaultLockTimeout = 15 * time.Second

+ var DefaultPrefetchMigrations = uint(10)

+ var ErrLockTimeout = fmt.Errorf("timeout: can't acquire database lock")

+ var ErrLocked = fmt.Errorf("database locked")

+ var ErrNilVersion = fmt.Errorf("no migration")

+ var ErrNoChange = fmt.Errorf("no change")

+ func FilterCustomQuery(u *nurl.URL) *nurl.URL

+ type ErrDirty struct

+ Version int

+ func (e ErrDirty) Error() string

+ type ErrShortLimit struct

+ Short uint

+ func (e ErrShortLimit) Error() string

+ type Logger interface

+ Printf func(format string, v ...interface{})

+ Verbose func() bool

+ type Migrate struct

+ GracefulStop chan bool

+ LockTimeout time.Duration

+ Log Logger

+ PrefetchMigrations uint

+ func New(sourceUrl, databaseUrl string) (*Migrate, error)

+ func NewWithDatabaseInstance(sourceUrl string, databaseName string, databaseInstance database.Driver) (*Migrate, error)

+ func NewWithInstance(sourceName string, sourceInstance source.Driver, databaseName string, ...) (*Migrate, error)

+ func NewWithSourceInstance(sourceName string, sourceInstance source.Driver, databaseUrl string) (*Migrate, error)

+ func (m *Migrate) Close() (source error, database error)

+ func (m *Migrate) Down() error

+ func (m *Migrate) Drop() error

+ func (m *Migrate) Force(version int) error

+ func (m *Migrate) Migrate(version uint) error

+ func (m *Migrate) Run(migration ...*Migration) error

+ func (m *Migrate) Steps(n int) error

+ func (m *Migrate) Up() error

+ func (m *Migrate) Version() (version uint, dirty bool, err error)

+ type Migration struct

+ Body io.ReadCloser

+ BufferSize uint

+ BufferedBody io.Reader

+ BytesRead int64

+ FinishedBuffering time.Time

+ FinishedReading time.Time

+ Identifier string

+ Scheduled time.Time

+ StartedBuffering time.Time

+ TargetVersion int

+ Version uint

+ func NewMigration(body io.ReadCloser, identifier string, version uint, targetVersion int) (*Migration, error)

+ func (m *Migration) Buffer() error

+ func (m *Migration) LogString() string

+ func (m *Migration) String() string

+ type MultiError struct

+ Errs []error

+ func NewMultiError(errs ...error) MultiError

+ func (m MultiError) Error() string