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
Constants ¶
This section is empty.
Variables ¶
This section is empty.
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 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
}
Source Files
Click to show internal directories.
Click to hide internal directories.