crash.software
Projects
Pull Requests
Issues
Builds
graphql-engine
Code
Files
Commits
Branches
Tags
Pull Requests
Code Comments
Code Compare
Issues
List
Boards
Milestones
Builds
Statistics
Contributions
Source Lines
Child Projects
Projects
STRLCPY
graphql-engine
Files
🤬
Sign In
release/v2.36
ROOT
/
cli
/
migrate
/
migrate.go
Search
History
1947 lines
|
ISO-8859-1
|
44 KB
Blame
Outline
2
4
8
No wrap
Soft wrap
Outline
DefaultPrefetchMigrations
DefaultLockTimeout
ErrNoChange
ErrNilVersion
ErrLocked
ErrNoMigrationFiles
ErrLockTimeout
ErrApplied
ErrNotApplied
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)
ErrShortLimit
Short
:
uint64
Error
()
:
string
ErrDirty
Version
:
int64
Error
()
:
string
Migrate
sourceName
:
string
sourceURL
:
string
sourceDrv
:
source.Driver
databaseName
:
string
databaseURL
:
string
databaseDrv
:
database.Driver
Logger
:
*log.Logger
stderr
:
io.Writer
stdout
:
io.Writer
GracefulStop
:
chan bool
isGracefulStop
:
bool
isLockedMu
:
*sync.Mutex
isLocked
:
bool
PrefetchMigrations
:
uint64
LockTimeout
:
time.Duration
isCMD
:
bool
status
:
*Status
SkipExecution
:
bool
DryRun
:
bool
ProgressBarLogs
:
bool
NewMigrateOpts
sourceUrl
:
string
databaseUrl
:
string
cmd
:
bool
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
*Migrate
ReScan
()
:
error
Close
()
:
error
calculateStatus
()
:
error
readStatusFromSource
()
:
error
readStatusFromDatabase
()
:
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
Up
()
:
error
Down
()
:
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)
stop
()
:
bool
lock
()
:
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)
All occurrences
Please wait...
Page is in error, reload to recover