postgres

Documentation

Index

• Variables
• type Postgres
  • func For(ctx context.Context, restConfig *rest.Config, ...) *Postgres
  • func (pg *Postgres) Backup() (string, error)
  • func (pg *Postgres) DeclaredInstances() int64
  • func (pg *Postgres) DestroyReplicas() error
  • func (pg *Postgres) Execute(pod corev1.Pod, command []string, stdout io.Writer) error
  • func (pg *Postgres) GetCronJob() (batchv1beta1.CronJob, error)
  • func (pg *Postgres) GetMasterPod() (corev1.Pod, error)
  • func (pg *Postgres) GetName() string
  • func (pg *Postgres) GetNamespace() string
  • func (pg *Postgres) GetNamespaceName() string
  • func (pg *Postgres) GetPods(role Role) ([]corev1.Pod, error)
  • func (pg *Postgres) IsHealthy() error
  • func (pg *Postgres) LogicalBackup() error
  • func (pg *Postgres) Switchover() error
  • func (pg *Postgres) WaitHealthy(timeout time.Duration) error
  • func (pg *Postgres) WrapError(err error) error
• type Role

Variables

var ErrCronJobFailed = errors.New("cron job failed")

var ErrInvalidMemberCount = errors.New("the number of members don't match intention")

var ErrInvalidMemberList = errors.New("failed to parse member list")

var ErrLeaderNotRunning = errors.New("leader is not running")

var ErrLeaderNumber = errors.New("there is not exactly one Leader")

var ErrMembersOutOfSync = errors.New("members are out of sync (not the same TL)")

var ErrMultipleCronJobs = errors.New("multiple dump cron jobs found")

var ErrNoCronJob = errors.New("no dump cron job found")

var ErrPositivLag = errors.New("replica lag is not 0")

var ErrReplicaNotStreaming = errors.New("replica is not streaming")

var ErrSwitchoverFailed = errors.New("failed to switchover")

var ErrUnknownLag = errors.New("unknown lag")

var ErrUnknownRole = errors.New("the member is in an unkown role")

var GroupVersionResource = schema.GroupVersionResource{
	Group:    "acid.zalan.do",
	Version:  "v1",
	Resource: "postgresqls",
}

Types

type Postgres

type Postgres struct {
	// contains filtered or unexported fields
}

func For

func For(ctx context.Context, restConfig *rest.Config, resource unstructured.Unstructured) *Postgres

func (*Postgres) Backup

func (pg *Postgres) Backup() (string, error)

func (*Postgres) DeclaredInstances

func (pg *Postgres) DeclaredInstances() int64

func (*Postgres) DestroyReplicas

func (pg *Postgres) DestroyReplicas() error

func (*Postgres) Execute

func (pg *Postgres) Execute(pod corev1.Pod, command []string, stdout io.Writer) error

func (*Postgres) GetCronJob

func (pg *Postgres) GetCronJob() (batchv1beta1.CronJob, error)

func (*Postgres) GetMasterPod

func (pg *Postgres) GetMasterPod() (corev1.Pod, error)

func (*Postgres) GetName

func (pg *Postgres) GetName() string

func (*Postgres) GetNamespace

func (pg *Postgres) GetNamespace() string

func (*Postgres) GetNamespaceName

func (pg *Postgres) GetNamespaceName() string

func (*Postgres) GetPods

func (pg *Postgres) GetPods(role Role) ([]corev1.Pod, error)

func (*Postgres) IsHealthy

func (pg *Postgres) IsHealthy() error

func (*Postgres) LogicalBackup

func (pg *Postgres) LogicalBackup() error

func (*Postgres) Switchover

func (pg *Postgres) Switchover() error

func (*Postgres) WaitHealthy

func (pg *Postgres) WaitHealthy(timeout time.Duration) error

func (*Postgres) WrapError

func (pg *Postgres) WrapError(err error) error

type Role

type Role string

var (
	MasterRole  Role = "master"
	ReplicaRole Role = "replica"
)