package shell import ( "flag" "github.com/seaweedfs/seaweedfs/weed/pb" "io" "github.com/seaweedfs/seaweedfs/weed/storage/needle" ) func init() { Commands = append(Commands, &commandVolumeDelete{}) } type commandVolumeDelete struct { } func (c *commandVolumeDelete) Name() string { return "volume.delete" } func (c *commandVolumeDelete) Help() string { return `delete a live volume from one volume server volume.delete -node -volumeId This command deletes a volume from one volume server. ` } func (c *commandVolumeDelete) HasTag(CommandTag) bool { return false } func (c *commandVolumeDelete) Do(args []string, commandEnv *CommandEnv, writer io.Writer) (err error) { volDeleteCommand := flag.NewFlagSet(c.Name(), flag.ContinueOnError) volumeIdInt := volDeleteCommand.Int("volumeId", 0, "the volume id") nodeStr := volDeleteCommand.String("node", "", "the volume server :") if err = volDeleteCommand.Parse(args); err != nil { return nil } if err = commandEnv.confirmIsLocked(args); err != nil { return } sourceVolumeServer := pb.ServerAddress(*nodeStr) volumeId := needle.VolumeId(*volumeIdInt) return deleteVolume(commandEnv.option.GrpcDialOption, volumeId, sourceVolumeServer, false) }