// Copyright 2015 CoreOS, Inc. // // Licensed under the Apache License, Version 2.0 (the "License"); // you may not use this file except in compliance with the License. // You may obtain a copy of the License at // // http://www.apache.org/licenses/LICENSE-2.0 // // Unless required by applicable law or agreed to in writing, software // distributed under the License is distributed on an "AS IS" BASIS, // WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. // See the License for the specific language governing permissions and // limitations under the License. package command import ( "fmt" "github.com/coreos/etcd/Godeps/_workspace/src/github.com/spf13/cobra" "github.com/coreos/etcd/Godeps/_workspace/src/golang.org/x/net/context" "github.com/coreos/etcd/clientv3" ) // NewDelCommand returns the cobra command for "del". func NewDelCommand() *cobra.Command { return &cobra.Command{ Use: "del [options] [range_end]", Short: "Removes the specified key or range of keys [key, range_end).", Run: delCommandFunc, } } // delCommandFunc executes the "del" command. func delCommandFunc(cmd *cobra.Command, args []string) { if len(args) == 0 || len(args) > 2 { ExitWithError(ExitBadArgs, fmt.Errorf("del command needs one argument as key and an optional argument as range_end.")) } opts := []clientv3.OpOption{} key := args[0] if len(args) > 1 { opts = append(opts, clientv3.WithRange(args[1])) } c := mustClientFromCmd(cmd) kvapi := clientv3.NewKV(c) _, err := kvapi.Delete(context.TODO(), key, opts...) if err != nil { ExitWithError(ExitError, err) } // TODO: add number of key removed into the response of delete. // TODO: print out the number of removed keys. fmt.Println(0) }