(client *master.MasterClient)
| 232 | } |
| 233 | |
| 234 | func newDataNodeQueryDecommissionSuccessDisk(client *master.MasterClient) *cobra.Command { |
| 235 | cmd := &cobra.Command{ |
| 236 | Use: CliOpQueryDecommissionSuccessDisk + " [{HOST}:{PORT}]", |
| 237 | Short: cmdDataNodeQueryDecommissionSuccessDisksShort, |
| 238 | Args: cobra.MinimumNArgs(1), |
| 239 | RunE: func(cmd *cobra.Command, args []string) error { |
| 240 | disks, err := client.NodeAPI().QueryDecommissionSuccessDisks(args[0]) |
| 241 | if err != nil { |
| 242 | stdout("%v", err) |
| 243 | return err |
| 244 | } |
| 245 | stdoutln("[DecommissionSuccess disks]") |
| 246 | for _, disk := range disks.Disks { |
| 247 | stdout("%v\n", disk) |
| 248 | } |
| 249 | return nil |
| 250 | }, |
| 251 | } |
| 252 | return cmd |
| 253 | } |
| 254 | |
| 255 | func newDataNodeCancelDecommissionCmd(client *master.MasterClient) *cobra.Command { |
| 256 | cmd := &cobra.Command{ |
no test coverage detected