postgres

Documentation

Index

• Constants
• type PatroniCluster
• type PatroniMember
• type PostgresDB
  • func GetPostgresDB(client *kommons.Client, name string) (*PostgresDB, error)
  • func (db *PostgresDB) Backup() error
  • func (db *PostgresDB) GenerateBackupJob() *kommons.DeploymentBuilder
  • func (db *PostgresDB) GetClusterName() string
  • func (db *PostgresDB) GetPatroniClient() (*http.Client, error)
  • func (db *PostgresDB) ListBackups(s3Bucket string, limit int, quiet bool) ([]string, error)
  • func (db *PostgresDB) OpenDB(database string) (*pg.DB, error)
  • func (db *PostgresDB) Restore(fullBackupPath string) error
  • func (db *PostgresDB) ScheduleBackup(schedule string) 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(*pg.DB) error) 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: golint

func GetPostgresDB

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

func (*PostgresDB) Backup

func (db *PostgresDB) Backup() error

func (*PostgresDB) GenerateBackupJob

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

func (*PostgresDB) GetClusterName

func (db *PostgresDB) GetClusterName() string

func (*PostgresDB) GetPatroniClient

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

func (*PostgresDB) ListBackups

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

func (*PostgresDB) OpenDB

func (db *PostgresDB) OpenDB(database string) (*pg.DB, error)

func (*PostgresDB) Restore

func (db *PostgresDB) Restore(fullBackupPath string) error

func (*PostgresDB) ScheduleBackup

func (db *PostgresDB) ScheduleBackup(schedule string) 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(*pg.DB) error) error

type ResticSnapshot

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