migrate.go at release/v2.11 - STRLCPY/graphql-engine

ROOT /

cli /

migrate.go

1837 lines | ISO-8859-1 | 40 KB

Blame Outline

Outline

DefaultPrefetchMigrations

DefaultLockTimeout

ErrNoMigrationFiles

ErrNoMigrationMode

ErrMigrationMode

applyingMigrationsMessage

newProgressBar(str string, w io.Writer, pbLogs bool) : *pb.ProgressBar

startProgressBar(bar *pb.ProgressBar)

finishProgressBar(bar *pb.ProgressBar)

incrementProgressBar(bar *pb.ProgressBar)

setTotalProgressBar(bar *pb.ProgressBar, val int64)

setWidthProgressBar(bar *pb.ProgressBar, pbLogs bool)

Error() : string

Version : int64

Error() : string

sourceUrl : string

databaseUrl : string

configVersion : int

logger : *log.Logger

Stdout : io.Writer

Stderr : io.Writer

hasuraOpts : *database.HasuraOpts

New(opts NewMigrateOpts) : (*Migrate, error)

newCommon(cmd bool) : *Migrate

printDryRunStatus(migrations []*Migration) : *bytes.Buffer

ReScan() : error

Close() : (source error)

calculateStatus() : (err error)

readStatusFromSource() : (err error)

readStatusFromDatabase() : (err error)

newMigrationStatus(version uint64, driverType string, dirty bool) : *MigrationStatus

GetStatus() : (*Status, error)

GetSetting(name string) : (string, error)

UpdateSetting(name string, value string) : error

Version() : (version uint64, dirty bool, err error)

GetUnappliedMigrations(version uint64) : []uint64

ExportSchemaDump(includeSchemas []string, excludeSchemas []string, sourceName string, sourceKind hasura.SourceKind) : ([]byte, error)

RemoveVersions(versions []uint64) : error

Query(data interface{}) : error

Squash(v1 uint64, v2 int64) : (vs []int64, us []byte, ds []byte, err error)

Migrate(version uint64, direction string) : error

QueryWithVersion(version uint64, data io.ReadCloser, skipExecution bool) : error

Steps(n int64) : error

squashUp(from uint64, to int64, ret chan<- interface{})

squashDown(v1 uint64, v2 int64, ret chan<- interface{})

read(version uint64, direction string, ret chan<- interface{}, bar *pb.ProgressBar)

readUp(limit int64, ret chan<- interface{}, bar *pb.ProgressBar)

readDown(limit int64, ret chan<- interface{}, bar *pb.ProgressBar)

runMigrations(ret <-chan interface{}, bar *pb.ProgressBar) : error

runDryRun(ret <-chan interface{}) : error

squashMigrations(retUp <-chan interface{}, retDown <-chan interface{}, dataUp chan<- interface{}, dataDown chan<- interface{}, versions chan<- int64) : error

versionUpExists(version uint64) : error

versionDownExists(version uint64) : error

newMigration(version uint64, targetVersion int64) : (*Migration, error)

unlock() : error

unlockErr(prevErr error) : error

GotoVersion(gotoVersion int64) : error

readUpFromVersion(from int64, to int64, ret chan<- interface{}, bar *pb.ProgressBar)

readDownFromVersion(from int64, to int64, ret chan<- interface{}, bar *pb.ProgressBar)

Please wait...

Page is in error, reload to recover