first draft

Signed-off-by: Krasi Georgiev <[email protected]>

Author: Krasi Georgiev

cmd/tsdb/main.go

@@ -46,6 +46,8 @@ func main() {
 		benchSamplesFile     = benchWriteCmd.Arg("file", "input file with samples data, default is (../../testdata/20k.series)").Default("../../testdata/20k.series").String()
 		listCmd              = cli.Command("ls", "list db blocks")
 		listPath             = listCmd.Arg("db path", "database path (default is benchout/storage)").Default("benchout/storage").String()
+		scanCmd              = cli.Command("scan", "scans the db and lists corrupted blocks")
+		scanPath             = scanCmd.Arg("dir", "database path (default is current dir ./)").Default("./").String()
 	)
 
 	switch kingpin.MustParse(cli.Parse(os.Args[1:])) {
@@ -62,6 +64,12 @@ func main() {
 			exitWithError(err)
 		}
 		printBlocks(db.Blocks())
+	case scanCmd.FullCommand():
+		corrupted, err := tsdb.Scan(*scanPath)
+		if err != nil {
+			exitWithError(err)
+		}
+		// list corrupted blocks with date ranges and prompt: "Do you want to delete corrupted blocks N,y ?"
 	}
 	flag.CommandLine.Set("log.level", "debug")
 }

db.go

@@ -250,6 +250,11 @@ func (db *DB) Dir() string {
 	return db.dir
 }
 
+// Scan checks the integrity of the db for a given directory and returns a list of unreadable blocks that can be deleted to allow a clean startup.
+func Scan(dir string) ([]string, error) {
+	return nil, nil
+}
+
 func (db *DB) run() {
 	defer close(db.donec)