engine

type Change struct {
	Forward  Migration
	Backward Migration
	Hash     string
	ID       string
}

type ChangeFile struct {
	Forward  []*MigrationFile `json:"migration"`
	Backward []*MigrationFile `json:"rollback,omitempty"`
}

type ChangeLog interface {
	GetConnectionString() string
	GetDBName() string
	GetChangeSets() []*ChangeSet
	GetChangeSetSource() ChangeSetSource
	Apply(processor ChangeSetProcessor) custom_error.CustomError
}

type ChangeSet struct {
	ID      string
	Changes []*Change
}

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

type ChangeSetFile struct {
	ID      string       `json:"id"`
	Changes []ChangeFile `json:"changes,omitempty"`
}

type ChangeSetProcessor interface {
	Process(changeSet *ChangeSet) custom_error.CustomError
}

type ChangeSetSource interface {
	Apply(processor ChangeSetProcessor) custom_error.CustomError
}

type DocumentApplier interface {
	Apply(value interface{}) custom_error.CustomError
}

type DummyMigration struct {
}

type LimitCounter interface {
	Get() int64
	Dec()
}

type Migration interface {
	Apply(visitor DocumentApplier) custom_error.CustomError
}

type MigrationExtractor func(change *Change) Migration

type MigrationFile struct {
	Path         string `json:"include,omitempty"`
	RelativePath bool   `json:"relativeToChangelogFile"`
}

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

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

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

type Transaction interface {
	Commit() custom_error.CustomError
	Apply(changeSet *Change) custom_error.CustomError
	Rollback() custom_error.CustomError
}

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

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