octoleo/gh-ost
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

status hint shows [set] next to existing flag files

Browse Source
This commit is contained in:
Shlomi Noach 2016-07-27 10:36:24 +02:00
parent 3b377f1bf0
commit dbcc0e09c7
1 changed files with 18 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

24
go/logic/migrator.go
View File

@ -874,13 +874,21 @@ func (this *Migrator) printMigrationStatusHint(writers ...io.Writer) {
)) ))
} }
if this.migrationContext.ThrottleFlagFile != "" { if this.migrationContext.ThrottleFlagFile != "" {
fmt.Fprintln(w, fmt.Sprintf("# Throttle flag file: %+v", setIndicator := ""
this.migrationContext.ThrottleFlagFile, if base.FileExists(this.migrationContext.ThrottleFlagFile) {
setIndicator = "[set]"
}
fmt.Fprintln(w, fmt.Sprintf("# Throttle flag file: %+v %+v",
this.migrationContext.ThrottleFlagFile, setIndicator,
)) ))
} }
if this.migrationContext.ThrottleAdditionalFlagFile != "" { if this.migrationContext.ThrottleAdditionalFlagFile != "" {
fmt.Fprintln(w, fmt.Sprintf("# Throttle additional flag file: %+v", setIndicator := ""
this.migrationContext.ThrottleAdditionalFlagFile, if base.FileExists(this.migrationContext.ThrottleAdditionalFlagFile) {
setIndicator = "[set]"
}
fmt.Fprintln(w, fmt.Sprintf("# Throttle additional flag file: %+v %+v",
this.migrationContext.ThrottleAdditionalFlagFile, setIndicator,
)) ))
} }
if throttleQuery := this.migrationContext.GetThrottleQuery(); throttleQuery != "" { if throttleQuery := this.migrationContext.GetThrottleQuery(); throttleQuery != "" {
@ -889,8 +897,12 @@ func (this *Migrator) printMigrationStatusHint(writers ...io.Writer) {
)) ))
} }
if this.migrationContext.PostponeCutOverFlagFile != "" { if this.migrationContext.PostponeCutOverFlagFile != "" {
fmt.Fprintln(w, fmt.Sprintf("# Postpone cut-over flag file: %+v", setIndicator := ""
this.migrationContext.PostponeCutOverFlagFile, if base.FileExists(this.migrationContext.PostponeCutOverFlagFile) {
setIndicator = "[set]"
}
fmt.Fprintln(w, fmt.Sprintf("# Postpone cut-over flag file: %+v %+v",
this.migrationContext.PostponeCutOverFlagFile, setIndicator,
)) ))
} }
if this.migrationContext.PanicFlagFile != "" { if this.migrationContext.PanicFlagFile != "" {