Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

engine

package

Go to main page

Versions in this module

v0

v0.2.3

Feb 20, 2019

v0.2.2

Jan 14, 2019

Changes in this version

type ChangeFile

+ func (c *ChangeFile) UnmarshalJSON(data []byte) error

type Migration

+ func NewMultiMigration(m []*MigrationFile, workingDir string, changelogPath string, hash hash.Hash) (Migration, custom_error.CustomError)

+ type MultipleMigration struct

+ func (s *MultipleMigration) Apply(visitor DocumentApplier) custom_error.CustomError

v0.2.1

Jan 7, 2019

Changes in this version

+ const COLLECTION_NAME_MIGRATIONS_LOG

+ type Change struct

+ Backward Migration

+ Forward Migration

+ Hash string

+ ID string

+ func NewChange(c *ChangeFile, workingDir string, changelogPath string, id string) (*Change, custom_error.CustomError)

+ type ChangeFile struct

+ Backward *MigrationFile

+ Forward MigrationFile

+ type ChangeLog interface

+ Apply func(processor ChangeSetProcessor) custom_error.CustomError

+ GetChangeSetSource func() ChangeSetSource

+ GetChangeSets func() []*ChangeSet

+ GetConnectionString func() string

+ GetDBName func() string

+ func NewChangeLog(path string) (ChangeLog, custom_error.CustomError)

+ func NewRollbackChangeLog(path string) (ChangeLog, custom_error.CustomError)

+ type ChangeSet struct

+ Changes []*Change

+ ID string

+ type ChangeSetApplyStrategy func(sets []*ChangeSet, processor ChangeSetProcessor) custom_error.CustomError

+ type ChangeSetFile struct

+ Changes []ChangeFile

+ ID string

+ type ChangeSetProcessor interface

+ Process func(changeSet *ChangeSet) custom_error.CustomError

+ func NewChangeSetApplier(startTransaction TransactionFactory) (ChangeSetProcessor, custom_error.CustomError)

+ func NewRollbackChangeSetApplier(startTransaction TransactionFactory) (ChangeSetProcessor, custom_error.CustomError)

+ type ChangeSetSource interface

+ Apply func(processor ChangeSetProcessor) custom_error.CustomError

+ func NewArrayChangeLog(changeSets []*ChangeSet) (ChangeSetSource, custom_error.CustomError)

+ type DocumentApplier interface

+ Apply func(value interface{}) custom_error.CustomError

+ type DummyMigration struct

+ func (d *DummyMigration) Apply(visitor DocumentApplier) custom_error.CustomError

+ type LimitCounter interface

+ Dec func()

+ Get func() int64

+ type Migration interface

+ Apply func(visitor DocumentApplier) custom_error.CustomError

+ func NewMigration(m *MigrationFile, workingDir string, changelogPath string, hash hash.Hash) (Migration, custom_error.CustomError)

+ type MigrationExtractor func(change *Change) Migration

+ type MigrationFile struct

+ Path string

+ RelativePath bool

+ type SimpleMigration struct

+ func (s *SimpleMigration) Apply(visitor DocumentApplier) custom_error.CustomError

+ type SimulatedTransaction struct

+ func (t *SimulatedTransaction) Apply(change *Change) custom_error.CustomError

+ func (t *SimulatedTransaction) Commit() custom_error.CustomError

+ func (t *SimulatedTransaction) Rollback() custom_error.CustomError

+ type Transaction interface

+ Apply func(changeSet *Change) custom_error.CustomError

+ Commit func() custom_error.CustomError

+ Rollback func() custom_error.CustomError

+ type TransactionFactory func(changeID string) (Transaction, custom_error.CustomError)

+ func NewDummyTransactionFactory(log logs.Logger) TransactionFactory

+ func NewRollbackSimulatedTransactionFactory(dbChanger DocumentApplier, transactionRecFactory TransactionRecordFactory, ...) (TransactionFactory, custom_error.CustomError)

+ func NewSimulatedTransactionFactory(dbChanger DocumentApplier, transactionRecFactory TransactionRecordFactory, ...) (TransactionFactory, custom_error.CustomError)

+ type TransactionRecordFactory func(changeID string, hashValue string) (interface{}, custom_error.CustomError)

+ func NewRollbackTransactionRecordFactory(collectionName string) TransactionRecordFactory

+ func NewTransactionRecordFactory(collectionName string) TransactionRecordFactory