Versions in this module Expand all Collapse all v0 v0.0.5 Mar 21, 2023 v0.0.4 Mar 21, 2023 v0.0.3 May 4, 2022 Changes in this version + var AnalyzeQuery string + var BaseBackupQuery string + var ClusterQuery string + var CopyQuery string + var CreateIndexQuery string + var VacuumQuery string type Analyze + func (v Analyze) Color() (string, string) type BaseBackup + func (v BaseBackup) Color() (string, string) type Cluster + func (v Cluster) Color() (string, string) type Copy + func (v Copy) Color() (string, string) type CreateIndex + func (v CreateIndex) Color() (string, string) + type Pgsp struct + DB *sqlx.DB + StatProgress StatProgress + func New(dsn string) (*Pgsp, error) + func (p *Pgsp) DisConnect() error + func (p *Pgsp) TargetString() string + func (p *Pgsp) Targets(target []string) + type Progress interface + Color func() (string, string) + Name func() string + Pid func() int + Progress func() float64 + Table func() string + Vertical func() string + type SPTable struct + Enable bool + Get func(ctx context.Context, db *sqlx.DB) ([]Progress, error) + type SPTaget string + const SPAnalyze + const SPBaseBackup + const SPCluster + const SPCopy + const SPCreateIndex + const SPVacuum + type StatProgress map[SPTaget]*SPTable + func NewMonitor() StatProgress type Vacuum + func (v Vacuum) Color() (string, string) v0.0.2 Nov 29, 2021 Changes in this version + var CopyColumns = []string + var CopyTableName = "pg_stat_progress_copy" + var VacuumTableName = "pg_stat_progress_vacuum" + type Copy struct + BYTESProcessed int64 + BYTESTotal int64 + COMMAND string + CTYPE string + DATID int + DATNAME string + PID int + RELID int + TUPLESExcluded int64 + TUPLESProcessed int64 + func GetCopy(ctx context.Context, db *sql.DB) ([]Copy, error) + func (v Copy) Name() string + func (v Copy) Pid() int + func (v Copy) Progress() float64 + func (v Copy) Table() string + func (v Copy) Vertical() string v0.0.1 Jul 14, 2021 Changes in this version + var AnalyzeColumns = []string + var AnalyzeTableName = "pg_stat_progress_analyze" + var BaseBackupColumns = []string + var BaseBackupTableName = "pg_stat_progress_basebackup" + var ClusterColumns = []string + var ClusterTableName = "pg_stat_progress_cluster" + var CreateIndexColumns = []string + var CreateIndexTableName = "pg_stat_progress_create_index" + var VacuumColumns = []string + func Connect(dsn string) (*sql.DB, error) + func DisConnect(db *sql.DB) error + type Analyze struct + ChildTablesDone int64 + ChildTablesTotal int64 + CurrentChildTableRelid int + DATID int + DATNAME string + ExtStatsComputed int64 + ExtStatsTotal int64 + PHASE string + PID int + RELID int + SampleBLKSScanned int64 + SampleBLKSTotal int64 + func GetAnalyze(db *sql.DB) ([]Analyze, error) + func (v Analyze) Name() string + func (v Analyze) Pid() int + func (v Analyze) Progress() float64 + func (v Analyze) String() []string + func (v Analyze) Table() string + func (v Analyze) Vertical() string + type BaseBackup struct + BackupStreamed int64 + BackupTotal int64 + PHASE string + PID int + TablespacesStreamed int64 + TablespacesTotal int64 + func GetBaseBackup(db *sql.DB) ([]BaseBackup, error) + func (v BaseBackup) Name() string + func (v BaseBackup) Pid() int + func (v BaseBackup) Progress() float64 + func (v BaseBackup) String() []string + func (v BaseBackup) Table() string + func (v BaseBackup) Vertical() string + type Cluster struct + ClusterIndexRelid int64 + Command string + DATID int + DATNAME string + HeapBlksScanned int64 + HeapBlksTotal int64 + HeapTuplesScanned int64 + HeapTuplesWritten int64 + IndexRebuildCount int64 + PHASE string + PID int + RELID int + func GetCluster(db *sql.DB) ([]Cluster, error) + func (v Cluster) Name() string + func (v Cluster) Pid() int + func (v Cluster) Progress() float64 + func (v Cluster) String() []string + func (v Cluster) Table() string + func (v Cluster) Vertical() string + type CreateIndex struct + BlocksDone int64 + BlocksTotal int64 + Command string + DATID int + DATNAME string + IndexRelid int + LockersDone int64 + LockersPid int + LockersTotal int64 + PHASE string + PID int + PartitionsDone int64 + PartitionsTotal int64 + RELID int + TuplesDone int64 + TuplesTotal int64 + func GetCreateIndex(db *sql.DB) ([]CreateIndex, error) + func (v CreateIndex) Name() string + func (v CreateIndex) Pid() int + func (v CreateIndex) Progress() float64 + func (v CreateIndex) String() []string + func (v CreateIndex) Table() string + func (v CreateIndex) Vertical() string + type PGSProgress interface + Name func() string + Pid func() int + Progress func() float64 + Table func() string + Vertical func() string + type Vacuum struct + DATID int + DATNAME string + HeapBLKSScanned int64 + HeapBLKSTotal int64 + HeapBLKSVacuumed int64 + IndexVacuumCount int64 + MaxDeadTuples int64 + NumDeadTuples int64 + PHASE string + PID int + RELID int + func GetVacuum(db *sql.DB) ([]Vacuum, error) + func (v Vacuum) Name() string + func (v Vacuum) Pid() int + func (v Vacuum) Progress() float64 + func (v Vacuum) String() []string + func (v Vacuum) Table() string + func (v Vacuum) Vertical() string
Go to main page