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
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
}
Source Files