postgres

Documentation

Index

• Constants
• type PatroniCluster
• type PatroniMember
• type PostgresDB
  • func GetPostgresDB(client *kommons.Client, name string, resticEnabled bool) (*PostgresDB, error)
  • func (db *PostgresDB) GetClusterName() string
  • func (db *PostgresDB) GetPatroniClient() (*http.Client, error)
  • func (db *PostgresDB) OpenDB(database string) (*pgx.Conn, error)
  • func (db *PostgresDB) String() string
  • func (db *PostgresDB) Terminate() error
  • func (db *PostgresDB) TriggerBackup(timeout time.Duration) error
  • func (db *PostgresDB) WaitFor(timeout time.Duration) error
  • func (db *PostgresDB) WithConnection(database string, fn func(*pgx.Conn) error) error
• type PostgresqlDB
  • func GetPostgresqlDB(p *platform.Platform, name string) (*PostgresqlDB, error)
  • func (db *PostgresqlDB) Backup() error
  • func (db *PostgresqlDB) GenerateBackupJob() *kommons.DeploymentBuilder
  • func (db *PostgresqlDB) ListBackups(limit int, quiet bool) ([]string, error)
  • func (db *PostgresqlDB) ListResticBackups(limit int, quiet bool) ([]string, error)
  • func (db *PostgresqlDB) ListS3Backups(limit int, quiet bool) ([]string, error)
  • func (db *PostgresqlDB) Restore(fullBackupPath string, trace bool) error
  • func (db *PostgresqlDB) RestoreRestic(fullBackupPath string, trace bool) error
  • func (db *PostgresqlDB) RestoreS3(backup string, trace bool) error
• type ResticSnapshot

Constants

const Namespace = "postgres-operator"

Types

type PatroniCluster

type PatroniCluster struct {
	Members []PatroniMember `json:"members"`
}

type PatroniMember

type PatroniMember struct {
	Name     string      `json:"name"`
	Host     string      `json:"host"`
	Port     int         `json:"port"`
	Role     string      `json:"role"`
	State    string      `json:"state"`
	URL      string      `json:"api_url"`
	Timeline int         `json:"timeline"`
	Lag      interface{} `json:"lag"`
}

type PostgresDB

type PostgresDB struct {
	Name      string
	Namespace string
	Superuser string
	Secret    string
	// contains filtered or unexported fields
}

nolint: revive

func GetPostgresDB

func GetPostgresDB(client *kommons.Client, name string, resticEnabled bool) (*PostgresDB, error)

func (*PostgresDB) GetClusterName

func (db *PostgresDB) GetClusterName() string

func (*PostgresDB) GetPatroniClient

func (db *PostgresDB) GetPatroniClient() (*http.Client, error)

func (*PostgresDB) OpenDB

func (db *PostgresDB) OpenDB(database string) (*pgx.Conn, error)

func (*PostgresDB) String

func (db *PostgresDB) String() string

func (*PostgresDB) Terminate

func (db *PostgresDB) Terminate() error

func (*PostgresDB) TriggerBackup

func (db *PostgresDB) TriggerBackup(timeout time.Duration) error

func (*PostgresDB) WaitFor

func (db *PostgresDB) WaitFor(timeout time.Duration) error

func (*PostgresDB) WithConnection

func (db *PostgresDB) WithConnection(database string, fn func(*pgx.Conn) error) error

type PostgresqlDB

type PostgresqlDB struct {
	*PostgresDB
	Restic       bool
	BackupBucket string
	// contains filtered or unexported fields
}

func GetPostgresqlDB

func GetPostgresqlDB(p *platform.Platform, name string) (*PostgresqlDB, error)

func (*PostgresqlDB) Backup

func (db *PostgresqlDB) Backup() error

func (*PostgresqlDB) GenerateBackupJob

func (db *PostgresqlDB) GenerateBackupJob() *kommons.DeploymentBuilder

func (*PostgresqlDB) ListBackups

func (db *PostgresqlDB) ListBackups(limit int, quiet bool) ([]string, error)

func (*PostgresqlDB) ListResticBackups

func (db *PostgresqlDB) ListResticBackups(limit int, quiet bool) ([]string, error)

func (*PostgresqlDB) ListS3Backups

func (db *PostgresqlDB) ListS3Backups(limit int, quiet bool) ([]string, error)

func (*PostgresqlDB) Restore

func (db *PostgresqlDB) Restore(fullBackupPath string, trace bool) error

Restore executes a job to retrieve the logical backup specified and then applies it to the database if trace is true, restore commands are printed to stdout

func (*PostgresqlDB) RestoreRestic

func (db *PostgresqlDB) RestoreRestic(fullBackupPath string, trace bool) error

func (*PostgresqlDB) RestoreS3

func (db *PostgresqlDB) RestoreS3(backup string, trace bool) error

type ResticSnapshot

type ResticSnapshot struct {
	Time    time.Time
	Paths   []string
	Tags    []string
	ID      string
	ShortID string `json:"short_id"`
}