backrest

Documentation

Index

• func Backrest(namespace string, clientset kubernetes.Interface, task *crv1.Pgtask)
• func CleanBackupResources(restclient *rest.RESTClient, clientset kubernetes.Interface, ...) 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.Interface, cluster *crv1.Pgcluster, ...) error
• func Restore(restclient *rest.RESTClient, namespace string, clientset kubernetes.Interface, ...)
• func S3RepoTypeCLIOptionExists(opts string) bool
• func StanzaCreate(namespace, clusterName string, clientset kubernetes.Interface, ...)
• func UpdateResources(clientset kubernetes.Interface, restConfig *rest.Config, ...) error
• func UpdateRestoreWorkflow(restclient *rest.RESTClient, clientset kubernetes.Interface, ...)
• type BackrestRestoreJobTemplateFields
• type RepoDeploymentTemplateFields
• type RepoServiceTemplateFields

Functions

func Backrest

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

Backrest ...

func CleanBackupResources

func CleanBackupResources(restclient *rest.RESTClient, clientset kubernetes.Interface, 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.Interface, cluster *crv1.Pgcluster,
	createPVC, bootstrapRepo bool, replicas int) error

CreateRepoDeployment creates a pgBackRest repository deployment for a PostgreSQL cluster, while also creating the associated Service and PersistentVolumeClaim.

func Restore

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

Restore ...

func S3RepoTypeCLIOptionExists

func S3RepoTypeCLIOptionExists(opts string) bool

S3RepoTypeCLIOptionExists detects if a S3 restore was requested via the '--repo-type' command line option

func StanzaCreate

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

func UpdateResources

func UpdateResources(clientset kubernetes.Interface, 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.Interface, 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
	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
	BootstrapCluster          string
}

type RepoServiceTemplateFields

type RepoServiceTemplateFields struct {
	Name        string
	ClusterName string
	Port        string
}