2014-08-01 20:20:28 +00:00
|
|
|
package main
|
|
|
|
|
|
|
|
import (
|
2014-10-05 12:44:59 +00:00
|
|
|
"errors"
|
|
|
|
"fmt"
|
|
|
|
|
2014-08-01 20:20:28 +00:00
|
|
|
"github.com/fd0/khepri"
|
2014-09-23 20:39:12 +00:00
|
|
|
"github.com/fd0/khepri/backend"
|
2014-08-01 20:20:28 +00:00
|
|
|
)
|
|
|
|
|
2014-11-30 21:39:58 +00:00
|
|
|
func init() {
|
|
|
|
commands["list"] = commandList
|
|
|
|
}
|
|
|
|
|
2014-09-23 20:39:12 +00:00
|
|
|
func commandList(be backend.Server, key *khepri.Key, args []string) error {
|
2014-10-05 12:44:59 +00:00
|
|
|
if len(args) != 1 {
|
2014-11-16 12:22:19 +00:00
|
|
|
return errors.New("usage: list [data|trees|snapshots|keys|locks]")
|
2014-10-05 12:44:59 +00:00
|
|
|
}
|
2014-08-01 20:20:28 +00:00
|
|
|
|
2014-10-05 12:44:59 +00:00
|
|
|
var (
|
|
|
|
t backend.Type
|
|
|
|
each func(backend.Server, backend.Type, func(backend.ID, []byte, error)) error = backend.Each
|
|
|
|
)
|
|
|
|
switch args[0] {
|
2014-11-16 12:22:19 +00:00
|
|
|
case "data":
|
|
|
|
t = backend.Data
|
2014-10-05 12:44:59 +00:00
|
|
|
each = key.Each
|
|
|
|
case "trees":
|
|
|
|
t = backend.Tree
|
|
|
|
each = key.Each
|
|
|
|
case "snapshots":
|
|
|
|
t = backend.Snapshot
|
2014-11-23 22:29:29 +00:00
|
|
|
case "maps":
|
|
|
|
t = backend.Map
|
2014-10-05 12:44:59 +00:00
|
|
|
case "keys":
|
|
|
|
t = backend.Key
|
|
|
|
case "locks":
|
|
|
|
t = backend.Lock
|
|
|
|
default:
|
|
|
|
return errors.New("invalid type")
|
|
|
|
}
|
2014-08-01 20:20:28 +00:00
|
|
|
|
2014-10-05 12:44:59 +00:00
|
|
|
return each(be, t, func(id backend.ID, data []byte, err error) {
|
2014-11-16 12:22:19 +00:00
|
|
|
if t == backend.Data || t == backend.Tree {
|
2014-10-05 12:44:59 +00:00
|
|
|
fmt.Printf("%s %s\n", id, backend.Hash(data))
|
|
|
|
} else {
|
|
|
|
fmt.Printf("%s\n", id)
|
|
|
|
}
|
|
|
|
})
|
2014-08-01 20:20:28 +00:00
|
|
|
}
|