ridv/gorealis
1
0
Fork 0
Code Issues Pull requests Projects Releases 23 Packages Wiki Activity Actions

Move monitor output to logger interface.

Browse source
This commit is contained in:
Renan DelValle 2017-11-30 08:35:54 -08:00
parent ac0a432f5d
commit 98db8b6b9d
1 changed files with 4 additions and 5 deletions
Download patch file Download diff file Expand all files Collapse all files

9
monitors.go
View file

@ -16,7 +16,6 @@
package realis package realis
import ( import (
"fmt"
"time" "time"
"github.com/paypal/gorealis/gen-go/apache/aurora" "github.com/paypal/gorealis/gen-go/apache/aurora"
@ -59,7 +58,7 @@ func (m *Monitor) JobUpdate(updateKey aurora.JobUpdateKey, interval int, timeout
updateDetail := response.JobUpdateDetails(respDetail) updateDetail := response.JobUpdateDetails(respDetail)
if len(updateDetail) == 0 { if len(updateDetail) == 0 {
fmt.Println("No update found") m.Client.RealisConfig().logger.Println("No update found")
return false, errors.New("No update found for " + updateKey.String()) return false, errors.New("No update found for " + updateKey.String())
} }
status := updateDetail[0].Update.Summary.State.Status status := updateDetail[0].Update.Summary.State.Status
@ -70,13 +69,13 @@ func (m *Monitor) JobUpdate(updateKey aurora.JobUpdateKey, interval int, timeout
// if we encounter an inactive state and it is not at rolled forward, update failed // if we encounter an inactive state and it is not at rolled forward, update failed
switch status { switch status {
case aurora.JobUpdateStatus_ROLLED_FORWARD: case aurora.JobUpdateStatus_ROLLED_FORWARD:
fmt.Println("Update succeded") m.Client.RealisConfig().logger.Println("Update succeded")
return true, nil return true, nil
case aurora.JobUpdateStatus_FAILED: case aurora.JobUpdateStatus_FAILED:
fmt.Println("Update failed") m.Client.RealisConfig().logger.Println("Update failed")
return false, errors.New(UpdateFailed) return false, errors.New(UpdateFailed)
case aurora.JobUpdateStatus_ROLLED_BACK: case aurora.JobUpdateStatus_ROLLED_BACK:
fmt.Println("rolled back") m.Client.RealisConfig().logger.Println("rolled back")
return false, errors.New(RolledBack) return false, errors.New(RolledBack)
default: default:
return false, nil return false, nil