mirror of
https://github.com/moby/moby.git
synced 2022-11-09 12:21:53 -05:00
change join node role judge
Signed-off-by: allencloud <allen.sun@daocloud.io>
This commit is contained in:
parent
f11a588d75
commit
e41c0370b4
1 changed files with 3 additions and 9 deletions
|
@ -2,7 +2,6 @@ package swarm
|
|||
|
||||
import (
|
||||
"fmt"
|
||||
"strings"
|
||||
|
||||
"github.com/docker/docker/api/types/swarm"
|
||||
"github.com/docker/docker/cli"
|
||||
|
@ -61,15 +60,10 @@ func runJoin(dockerCli *command.DockerCli, opts joinOptions) error {
|
|||
return err
|
||||
}
|
||||
|
||||
_, _, err = client.NodeInspectWithRaw(ctx, info.Swarm.NodeID)
|
||||
if err != nil {
|
||||
// TODO(aaronl): is there a better way to do this?
|
||||
if strings.Contains(err.Error(), "This node is not a swarm manager.") {
|
||||
fmt.Fprintln(dockerCli.Out(), "This node joined a swarm as a worker.")
|
||||
}
|
||||
} else {
|
||||
if info.Swarm.ControlAvailable {
|
||||
fmt.Fprintln(dockerCli.Out(), "This node joined a swarm as a manager.")
|
||||
} else {
|
||||
fmt.Fprintln(dockerCli.Out(), "This node joined a swarm as a worker.")
|
||||
}
|
||||
|
||||
return nil
|
||||
}
|
||||
|
|
Loading…
Reference in a new issue