Skip to content

Commit

Permalink
Generic handling of server region errors
Browse files Browse the repository at this point in the history
  • Loading branch information
dadgar committed Mar 30, 2018
1 parent 97d39b1 commit 9f99b9d
Showing 1 changed file with 14 additions and 11 deletions.
25 changes: 14 additions & 11 deletions command/server_members.go
Original file line number Diff line number Diff line change
Expand Up @@ -6,6 +6,7 @@ import (
"sort"
"strings"

multierror "github.com/hashicorp/go-multierror"
"github.com/hashicorp/nomad/api"
"github.com/posener/complete"
"github.com/ryanuber/columnize"
Expand Down Expand Up @@ -92,11 +93,7 @@ func (c *ServerMembersCommand) Run(args []string) int {
sort.Sort(api.AgentMembersNameSort(srvMembers.Members))

// Determine the leaders per region.
leaders, err := regionLeaders(client, srvMembers.Members)
if err != nil {
c.Ui.Error(fmt.Sprintf("Error determining leaders: %s", err))
return 1
}
leaders, leaderErr := regionLeaders(client, srvMembers.Members)

// Format the list
var out []string
Expand All @@ -108,6 +105,14 @@ func (c *ServerMembersCommand) Run(args []string) int {

// Dump the list
c.Ui.Output(columnize.SimpleFormat(out))

// If there were leader errors display a warning
if leaderErr != nil {
c.Ui.Output("")
c.Ui.Warn(fmt.Sprintf("Error determining leaders: %s", leaderErr))
return 1
}

return 0
}

Expand Down Expand Up @@ -181,19 +186,17 @@ func regionLeaders(client *api.Client, mem []*api.AgentMember) (map[string]strin
return leaders, nil
}

var mErr multierror.Error
status := client.Status()
for reg := range regions {
l, err := status.RegionLeader(reg)
if err != nil {
// This error means that region has no leader.
if strings.Contains(err.Error(), "No cluster leader") {
continue
}
return nil, err
multierror.Append(&mErr, fmt.Errorf("Region %q: %v", reg, err))
continue
}

leaders[reg] = l
}

return leaders, nil
return leaders, mErr.ErrorOrNil()
}

0 comments on commit 9f99b9d

Please sign in to comment.