backrest

Documentation

Index

• func Backrest(namespace string, clientset *kubernetes.Clientset, task *crv1.Pgtask)
• func CleanBackupResources(restclient *rest.RESTClient, clientset *kubernetes.Clientset, ...) error
• func CreateBackup(restclient *rest.RESTClient, namespace, clusterName, podName string, ...) (*crv1.Pgtask, error)
• func CreateInitialBackup(restclient *rest.RESTClient, namespace, clusterName, podName string) (*crv1.Pgtask, error)
• func CreatePostFailoverBackup(restclient *rest.RESTClient, namespace, clusterName, podName string) (*crv1.Pgtask, error)
• func CreateRepoDeployment(clientset *kubernetes.Clientset, namespace string, cluster *crv1.Pgcluster, ...) error
• func Restore(restclient *rest.RESTClient, namespace string, clientset *kubernetes.Clientset, ...)
• func StanzaCreate(namespace, clusterName string, clientset *kubernetes.Clientset, ...)
• func UpdateResources(clientset *kubernetes.Clientset, restConfig *rest.Config, ...) error
• func UpdateRestoreWorkflow(restclient *rest.RESTClient, clientset *kubernetes.Clientset, ...)
• type BackrestRestoreJobTemplateFields
• type RepoDeploymentTemplateFields
• type RepoServiceTemplateFields

Functions

func Backrest

func Backrest(namespace string, clientset *kubernetes.Clientset, task *crv1.Pgtask)

Backrest ...

func CleanBackupResources

func CleanBackupResources(restclient *rest.RESTClient, clientset *kubernetes.Clientset, namespace,
	clusterName string) error

CleanBackupResources is responsible for cleaning up Kubernetes resources from a previous pgBackRest backup. Specifically, this function deletes the pgptask and job associate with a previous pgBackRest backup for the cluster.

func CreateBackup

func CreateBackup(restclient *rest.RESTClient, namespace, clusterName, podName string, params map[string]string,
	backupOpts string) (*crv1.Pgtask, error)

CreateBackup creates a Pgtask in order to initiate a pgBackRest backup

func CreateInitialBackup

func CreateInitialBackup(restclient *rest.RESTClient, namespace, clusterName, podName string) (*crv1.Pgtask, error)

CreateInitialBackup creates a Pgtask in order to initiate the initial pgBackRest backup for a cluster as needed to support replica creation

func CreatePostFailoverBackup

func CreatePostFailoverBackup(restclient *rest.RESTClient, namespace, clusterName, podName string) (*crv1.Pgtask, error)

CreatePostFailoverBackup creates a Pgtask in order to initiate the a pgBackRest backup following a failure event to ensure proper replica creation and/or reinitialization

func CreateRepoDeployment

func CreateRepoDeployment(clientset *kubernetes.Clientset, namespace string, cluster *crv1.Pgcluster, createPVC bool,
	replicas int) error

func Restore

func Restore(restclient *rest.RESTClient, namespace string, clientset *kubernetes.Clientset, task *crv1.Pgtask)

Restore ...

func StanzaCreate

func StanzaCreate(namespace, clusterName string, clientset *kubernetes.Clientset, RESTClient *rest.RESTClient)

func UpdateResources

func UpdateResources(clientset *kubernetes.Clientset, restConfig *rest.Config, cluster *crv1.Pgcluster) error

UpdateResources updates the pgBackRest repository Deployment to reflect any resource updates

func UpdateRestoreWorkflow

func UpdateRestoreWorkflow(restclient *rest.RESTClient, clientset *kubernetes.Clientset, clusterName, status, namespace,
	workflowID, restoreToName string, affinity *v1.Affinity)

Types

type BackrestRestoreJobTemplateFields

type BackrestRestoreJobTemplateFields struct {
	JobName                string
	ClusterName            string
	WorkflowID             string
	ToClusterPVCName       string
	SecurityContext        string
	PGOImagePrefix         string
	PGOImageTag            string
	CommandOpts            string
	PITRTarget             string
	PgbackrestStanza       string
	PgbackrestDBPath       string
	PgbackrestRepo1Path    string
	PgbackrestRepo1Host    string
	PgbackrestRepoType     string
	PgbackrestS3EnvVars    string
	NodeSelector           string
	Tablespaces            string
	TablespaceVolumes      string
	TablespaceVolumeMounts string
}

type RepoDeploymentTemplateFields

type RepoDeploymentTemplateFields struct {
	SecurityContext           string
	PGOImagePrefix            string
	PGOImageTag               string
	ContainerResources        string
	BackrestRepoClaimName     string
	SshdSecretsName           string
	PGbackrestDBHost          string
	PgbackrestRepoPath        string
	PgbackrestDBPath          string
	PgbackrestPGPort          string
	SshdPort                  int
	PgbackrestStanza          string
	PgbackrestRepoType        string
	PgbackrestS3EnvVars       string
	Name                      string
	ClusterName               string
	PodAntiAffinity           string
	PodAntiAffinityLabelName  string
	PodAntiAffinityLabelValue string
	Replicas                  int
}

type RepoServiceTemplateFields

type RepoServiceTemplateFields struct {
	Name        string
	ClusterName string
	Port        string
}