(nodeUser, node, containerName string)
| 21 | } |
| 22 | |
| 23 | func rmContainerOnNode(nodeUser, node, containerName string) (string, error) { |
| 24 | if ok, _ := checkContainerExistence(nodeUser, node, containerName); ok { |
| 25 | cmd := exec.Command("ssh", nodeUser+"@"+node, "docker rm ", containerName) |
| 26 | _, err := cmd.Output() |
| 27 | if err != nil { |
| 28 | return fmt.Sprintf("failed rm %s on node %s", containerName, node), err |
| 29 | } |
| 30 | return fmt.Sprintf("successful rm %s on node %s", containerName, node), nil |
| 31 | } |
| 32 | return fmt.Sprintf("%s on node %s already removed", containerName, node), nil |
| 33 | } |
| 34 | |
| 35 | func startMasterContainerOnNode(nodeUser, node, containerName, dataDir string) (string, error) { |
| 36 | cmd := exec.Command("ssh", nodeUser+"@"+node, |
no test coverage detected