106 lines
2.7 KiB
Go
106 lines
2.7 KiB
Go
package upgrade
|
|
|
|
import (
|
|
"fmt"
|
|
"os"
|
|
"path/filepath"
|
|
"text/tabwriter"
|
|
|
|
"github.com/influxdata/influxdb/v2/fluxinit"
|
|
"github.com/spf13/cobra"
|
|
)
|
|
|
|
var v1DumpMetaCommand = &cobra.Command{
|
|
Use: "v1-dump-meta",
|
|
Short: "Dump InfluxDB 1.x meta.db",
|
|
Args: cobra.NoArgs,
|
|
Hidden: true,
|
|
RunE: func(cmd *cobra.Command, args []string) error {
|
|
fluxinit.FluxInit()
|
|
svc, err := newInfluxDBv1(&v1DumpMetaOptions)
|
|
if err != nil {
|
|
return fmt.Errorf("error opening 1.x meta.db: %w", err)
|
|
}
|
|
meta := svc.meta
|
|
|
|
tw := tabwriter.NewWriter(os.Stdout, 15, 4, 1, ' ', 0)
|
|
|
|
showBool := func(b bool) string {
|
|
if b {
|
|
return "✓"
|
|
}
|
|
return ""
|
|
}
|
|
|
|
fmt.Fprintln(os.Stdout, "Databases")
|
|
fmt.Fprintln(os.Stdout, "---------")
|
|
fmt.Fprintf(tw, "%s\t%s\t%s\n", "Name", "Default RP", "Shards")
|
|
for _, row := range meta.Databases() {
|
|
fmt.Fprintf(tw, "%s\t%s\t", row.Name, row.DefaultRetentionPolicy)
|
|
for i, si := range row.ShardInfos() {
|
|
if i > 0 {
|
|
fmt.Fprint(tw, ",")
|
|
}
|
|
fmt.Fprintf(tw, "%d", si.ID)
|
|
}
|
|
fmt.Fprintln(tw)
|
|
}
|
|
_ = tw.Flush()
|
|
fmt.Fprintln(os.Stdout)
|
|
|
|
fmt.Fprintln(os.Stdout, "Retention policies")
|
|
fmt.Fprintln(os.Stdout, "---------")
|
|
fmt.Fprintf(tw, "%s\t%s\t%s\t%s\n", "Database", "Name", "Duration", "Shard Group duration")
|
|
for _, db := range meta.Databases() {
|
|
for _, rp := range db.RetentionPolicies {
|
|
fmt.Fprintf(tw, "%s\t%s\t%s\t%s\n", db.Name, rp.Name, rp.Duration.String(), rp.ShardGroupDuration.String())
|
|
}
|
|
}
|
|
_ = tw.Flush()
|
|
fmt.Fprintln(os.Stdout)
|
|
|
|
fmt.Fprintln(os.Stdout, "Shard groups")
|
|
fmt.Fprintln(os.Stdout, "---------")
|
|
fmt.Fprintf(tw, "%s\t%s\t%s\t%s\n", "Database/RP", "Start Time", "End Time", "Shards")
|
|
for _, db := range meta.Databases() {
|
|
for _, rp := range db.RetentionPolicies {
|
|
for _, sg := range rp.ShardGroups {
|
|
fmt.Fprintf(tw, "%s/%s\t%s\t%s\t", db.Name, rp.Name, sg.StartTime.String(), sg.EndTime.String())
|
|
for i, si := range sg.Shards {
|
|
if i > 0 {
|
|
fmt.Fprint(tw, ",")
|
|
}
|
|
fmt.Fprintf(tw, "%d", si.ID)
|
|
}
|
|
fmt.Fprintln(tw)
|
|
}
|
|
}
|
|
}
|
|
_ = tw.Flush()
|
|
fmt.Fprintln(os.Stdout)
|
|
|
|
fmt.Fprintln(os.Stdout, "Users")
|
|
fmt.Fprintln(os.Stdout, "-----")
|
|
fmt.Fprintf(tw, "%s\t%s\n", "Name", "Admin")
|
|
for _, row := range meta.Users() {
|
|
fmt.Fprintf(tw, "%s\t%s\n", row.Name, showBool(row.Admin))
|
|
}
|
|
_ = tw.Flush()
|
|
fmt.Fprintln(os.Stdout)
|
|
return nil
|
|
},
|
|
}
|
|
|
|
var v1DumpMetaOptions = optionsV1{}
|
|
|
|
func init() {
|
|
flags := v1DumpMetaCommand.Flags()
|
|
|
|
v1dir, err := influxDirV1()
|
|
if err != nil {
|
|
panic("error fetching default InfluxDB 1.x dir: " + err.Error())
|
|
}
|
|
|
|
flags.StringVar(&v1DumpMetaOptions.metaDir, "v1-meta-dir", filepath.Join(v1dir, "meta"), "Path to meta.db directory")
|
|
}
|