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
Constants ¶
This section is empty.
Variables ¶
This section is empty.
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 ¶
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 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 BootstrapCluster string }