migrate

Documentation

Index

• type DefaultMigrator
  • func (d *DefaultMigrator) GetSourceInstance() source.Driver
  • func (d DefaultMigrator) Migrate() (err error)
  • func (d *DefaultMigrator) SetDatabaseURL(dsn string) IMigrator
  • func (d *DefaultMigrator) SetSourceInstance(instance source.Driver) IMigrator
  • func (d *DefaultMigrator) SetSourceURL(url string) IMigrator
• type EmbedDriver
  • func NewFsDriver() *EmbedDriver
  • func (e *EmbedDriver) Add(f fs.FS)
  • func (e *EmbedDriver) Close() error
  • func (e *EmbedDriver) First() (version uint, err error)
  • func (e *EmbedDriver) Next(version uint) (nextVersion uint, err error)
  • func (e *EmbedDriver) Open(url string) (source.Driver, error)
  • func (e *EmbedDriver) Prev(version uint) (prevVersion uint, err error)
  • func (e *EmbedDriver) ReadDown(version uint) (r io.ReadCloser, identifier string, err error)
  • func (e *EmbedDriver) ReadUp(version uint) (r io.ReadCloser, identifier string, err error)
• type IMigrator
• type Module
  • func NewModule() *Module
  • func (m Module) Boot()

Types

type DefaultMigrator

type DefaultMigrator struct {
	SourceUrl      string
	SourceInstance source.Driver
	DatabaseUrl    string
}

func (*DefaultMigrator) GetSourceInstance

func (d *DefaultMigrator) GetSourceInstance() source.Driver

func (DefaultMigrator) Migrate

func (d DefaultMigrator) Migrate() (err error)

func (*DefaultMigrator) SetDatabaseURL

func (d *DefaultMigrator) SetDatabaseURL(dsn string) IMigrator

func (*DefaultMigrator) SetSourceInstance

func (d *DefaultMigrator) SetSourceInstance(instance source.Driver) IMigrator

func (*DefaultMigrator) SetSourceURL

func (d *DefaultMigrator) SetSourceURL(url string) IMigrator

type EmbedDriver

type EmbedDriver struct {
	// contains filtered or unexported fields
}

func NewFsDriver

func NewFsDriver() *EmbedDriver

func (*EmbedDriver) Add

func (e *EmbedDriver) Add(f fs.FS)

func (*EmbedDriver) Close

func (e *EmbedDriver) Close() error

func (*EmbedDriver) First

func (e *EmbedDriver) First() (version uint, err error)

func (*EmbedDriver) Next

func (e *EmbedDriver) Next(version uint) (nextVersion uint, err error)

func (*EmbedDriver) Open

func (e *EmbedDriver) Open(url string) (source.Driver, error)

func (*EmbedDriver) Prev

func (e *EmbedDriver) Prev(version uint) (prevVersion uint, err error)

func (*EmbedDriver) ReadDown

func (e *EmbedDriver) ReadDown(version uint) (r io.ReadCloser, identifier string, err error)

func (*EmbedDriver) ReadUp

func (e *EmbedDriver) ReadUp(version uint) (r io.ReadCloser, identifier string, err error)

type IMigrator

type IMigrator interface {
	SetSourceURL(url string) IMigrator
	SetSourceInstance(instance source.Driver) IMigrator
	GetSourceInstance() source.Driver
	SetDatabaseURL(dsn string) IMigrator
	Migrate() error
}

type Module

type Module struct {
	*module.BaseModule
}

func NewModule

func NewModule() *Module

func (Module) Boot

func (m Module) Boot()