backrest

Documentation

Index

• func Backrest(namespace string, clientset *kubernetes.Clientset, task *crv1.Pgtask)
• 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 CreateRepoDeployment(clientset *kubernetes.Clientset, namespace string, cluster *crv1.Pgcluster) error
• func CreateRestoredDeployment(restclient *rest.RESTClient, cluster *crv1.Pgcluster, ...) error
• func Restore(restclient *rest.RESTClient, namespace string, clientset *kubernetes.Clientset, ...)
• func StanzaCreate(namespace, clusterName string, clientset *kubernetes.Clientset, ...)
• func UpdateDBPath(clientset *kubernetes.Clientset, cluster *crv1.Pgcluster, ...) error
• func UpdateRestoreWorkflow(restclient *rest.RESTClient, clientset *kubernetes.Clientset, ...)
• type RepoDeploymentTemplateFields
• type RepoServiceTemplateFields

Functions

func Backrest

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

Backrest ...

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 CreateRepoDeployment

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

func CreateRestoredDeployment

func CreateRestoredDeployment(restclient *rest.RESTClient, cluster *crv1.Pgcluster, clientset *kubernetes.Clientset,
	namespace, restoreToName, workflowID string, affinity *v1.Affinity) 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 UpdateDBPath

func UpdateDBPath(clientset *kubernetes.Clientset, cluster *crv1.Pgcluster, target, namespace string) error

update the PGBACKREST_DB_PATH env var of the backrest-repo deployment for a given cluster, the deployment is bounced as part of this process

func UpdateRestoreWorkflow

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

Types

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
}

type RepoServiceTemplateFields

type RepoServiceTemplateFields struct {
	Name        string
	ClusterName string
	Port        string
}