Dump individual indexes
This commit is contained in:
parent
96f2165067
commit
de2c20be84
1 changed files with 32 additions and 0 deletions
|
@ -17,6 +17,8 @@ import (
|
||||||
|
|
||||||
type CmdDump struct {
|
type CmdDump struct {
|
||||||
global *GlobalOptions
|
global *GlobalOptions
|
||||||
|
|
||||||
|
repo *repository.Repository
|
||||||
}
|
}
|
||||||
|
|
||||||
func init() {
|
func init() {
|
||||||
|
@ -94,6 +96,27 @@ func printTrees(repo *repository.Repository, wr io.Writer) error {
|
||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
|
|
||||||
|
func (cmd CmdDump) DumpIndexes() error {
|
||||||
|
done := make(chan struct{})
|
||||||
|
defer close(done)
|
||||||
|
|
||||||
|
for id := range cmd.repo.List(backend.Index, done) {
|
||||||
|
fmt.Printf("index_id: %v\n", id)
|
||||||
|
|
||||||
|
idx, err := repository.LoadIndex(cmd.repo, id.String())
|
||||||
|
if err != nil {
|
||||||
|
return err
|
||||||
|
}
|
||||||
|
|
||||||
|
err = idx.Dump(os.Stdout)
|
||||||
|
if err != nil {
|
||||||
|
return err
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
return nil
|
||||||
|
}
|
||||||
|
|
||||||
func (cmd CmdDump) Execute(args []string) error {
|
func (cmd CmdDump) Execute(args []string) error {
|
||||||
if len(args) != 1 {
|
if len(args) != 1 {
|
||||||
return fmt.Errorf("type not specified, Usage: %s", cmd.Usage())
|
return fmt.Errorf("type not specified, Usage: %s", cmd.Usage())
|
||||||
|
@ -103,6 +126,7 @@ func (cmd CmdDump) Execute(args []string) error {
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
|
cmd.repo = repo
|
||||||
|
|
||||||
lock, err := lockRepo(repo)
|
lock, err := lockRepo(repo)
|
||||||
defer unlockRepo(lock)
|
defer unlockRepo(lock)
|
||||||
|
@ -120,6 +144,8 @@ func (cmd CmdDump) Execute(args []string) error {
|
||||||
switch tpe {
|
switch tpe {
|
||||||
case "index":
|
case "index":
|
||||||
return repo.Index().Dump(os.Stdout)
|
return repo.Index().Dump(os.Stdout)
|
||||||
|
case "indexes":
|
||||||
|
return cmd.DumpIndexes()
|
||||||
case "snapshots":
|
case "snapshots":
|
||||||
return printSnapshots(repo, os.Stdout)
|
return printSnapshots(repo, os.Stdout)
|
||||||
case "trees":
|
case "trees":
|
||||||
|
@ -138,6 +164,12 @@ func (cmd CmdDump) Execute(args []string) error {
|
||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
|
|
||||||
|
fmt.Printf("\nindexes:\n")
|
||||||
|
err = cmd.DumpIndexes()
|
||||||
|
if err != nil {
|
||||||
|
return err
|
||||||
|
}
|
||||||
|
|
||||||
fmt.Printf("\nindex:\n")
|
fmt.Printf("\nindex:\n")
|
||||||
|
|
||||||
err = repo.Index().Dump(os.Stdout)
|
err = repo.Index().Dump(os.Stdout)
|
||||||
|
|
Loading…
Reference in a new issue