wal-g

1
package gp
2

3
import (
4
	"github.com/spf13/cobra"
5
	"github.com/wal-g/tracelog"
6
	"github.com/wal-g/wal-g/internal"
7
	"github.com/wal-g/wal-g/internal/databases/greenplum"
8
)
9

10
var (
11
	port        string
12
	segnum      string
13
	checkBackup bool
14
	backupName  string
15
)
16

17
var checkAOLengthSegmentCmd = &cobra.Command{
18
	Use:   "check-ao-aocs-length-segment",
19
	Short: "Checks ao and aocs tables` EOF on disk is no less than in metadata for current segment",
20
	Run: func(cmd *cobra.Command, args []string) {
21
		handler, err := greenplum.NewAOLengthCheckSegmentHandler(port, segnum)
22
		tracelog.ErrorLogger.FatalOnError(err)
23
		if checkBackup {
24
			handler.CheckAOBackupLengthSegment(backupName)
25
		} else {
26
			handler.CheckAOTableLengthSegment()
27
		}
28
	},
29
}
30

31
func init() {
32
	checkAOLengthSegmentCmd.PersistentFlags().StringVarP(&port, "port", "p", "5432", `database port (default: "5432")`)
33
	checkAOLengthSegmentCmd.PersistentFlags().StringVarP(&segnum, "segnum", "s", "", `database segment number`)
34
	checkAOLengthSegmentCmd.PersistentFlags().BoolVar(&checkBackup, "check-backup", false,
35
		"if the flag is set, checks backup`s length")
36
	checkAOLengthSegmentCmd.PersistentFlags().StringVarP(&backupName, "backup-name", "n", internal.LatestString,
37
		"sets name of backup to check, checks last when empty")
38

39
	cmd.AddCommand(checkAOLengthSegmentCmd)
40
}
41