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

added onStatus hook

Browse Source
This commit is contained in:
Shlomi Noach 2016-08-22 16:24:41 +02:00
parent 6acbe7e3ae
commit 972728cf40
2 changed files with 8 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
go/logic/hooks.go
View File

@ -108,3 +108,7 @@ func (this *HooksExecutor) onSuccess() error {
func (this *HooksExecutor) onFailure() error { func (this *HooksExecutor) onFailure() error {
return nil return nil
} }
func (this *HooksExecutor) onStatus(statusMessage string) error {
return nil
}

4
go/logic/migrator.go
View File

@ -1065,6 +1065,10 @@ func (this *Migrator) printStatus(rule PrintStatusRule, writers ...io.Writer) {
) )
w := io.MultiWriter(writers...) w := io.MultiWriter(writers...)
fmt.Fprintln(w, status) fmt.Fprintln(w, status)
if elapsedSeconds%60 == 0 {
this.hooksExecutor.onStatus(status)
}
} }
// initiateHeartbeatListener listens for heartbeat events. gh-ost implements its own // initiateHeartbeatListener listens for heartbeat events. gh-ost implements its own