FilesExpand file tree

master

/

promote.go

Copy path

Blame

More file actions

Blame

More file actions

Latest commit

 

History

History

History

38 lines (34 loc) · 1.1 KB

master

/

promote.go

Copy path

Top

File metadata and controls

• Code
• Blame

38 lines (34 loc) · 1.1 KB

Raw

Copy raw file

Download raw file

Open symbols panel

Edit and raw actions

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

20

21

22

23

24

25

26

27

28

29

30

31

32

33

34

35

36

37

38

package node

import (

"context"

"fmt"

"github.com/docker/cli/cli"

"github.com/docker/cli/cli/command"

"github.com/moby/moby/api/types/swarm"

"github.com/spf13/cobra"

)

func newPromoteCommand(dockerCLI command.Cli) *cobra.Command {

return &cobra.Command{

Use: "promote NODE [NODE...]",

Short: "Promote one or more nodes to manager in the swarm",

Args: cli.RequiresMinArgs(1),

RunE: func(cmd *cobra.Command, args []string) error {

return runPromote(cmd.Context(), dockerCLI, args)

},

ValidArgsFunction: completeNodeNames(dockerCLI),

DisableFlagsInUseLine: true,

}

}

func runPromote(ctx context.Context, dockerCLI command.Cli, nodes []string) error {

promote := func(node *swarm.Node) error {

if node.Spec.Role == swarm.NodeRoleManager {

_, _ = fmt.Fprintf(dockerCLI.Out(), "Node %s is already a manager.\n", node.ID)

return errNoRoleChange

}

node.Spec.Role = swarm.NodeRoleManager

return nil

}

return updateNodes(ctx, dockerCLI.Client(), nodes, promote, func(nodeID string) {

_, _ = fmt.Fprintf(dockerCLI.Out(), "Node %s promoted to a manager in the swarm.\n", nodeID)

})

}