Documentation
¶
Index ¶
- Constants
- Variables
- func ApplySQLFileToPGServiceInstance(unattendedMode bool, namespace, serviceInstanceName, sqlFileToUpload string, ...)
- func ApplySQLStatementToPGServiceInstance(unattendedMode bool, namespace, serviceInstanceName, sqlStatement string)
- func BackupToYAML(backup Backup) string
- func DoesBackupExist(namespace, backupName string) bool
- func DoesServiceInstanceExist(namespace, name string) bool
- func ExecuteSQLFileWithinPod(unattendedMode bool, namespace, serviceInstanceName, remoteSQLFilePath string) error
- func ExecuteSQLStatementWithinPod(unattendedMode bool, namespace, serviceInstanceName, sqlStatement string) (*exec.Cmd, []byte, error)
- func FindPrimaryPodOfServiceInstance(namespace, serviceInstanceName string) string
- func RestoreToYAML(restore Restore) string
- func ServiceBindingToYAML(binding ServiceBinding) string
- func ServiceInstanceToYAML(instance ServiceInstance) string
- func WaitForPGBackupResourceToBecomeReady(namespace, name string, resource string) error
- func WaitForPGBackupToBecomeReady(namespace, name string)
- func WaitForPGRestoreToBecomeReady(namespace, name string)
- func WaitForPGServiceBindingToBecomeReady(binding ServiceBinding) error
- type Backup
- type Restore
- type ServiceBinding
- type ServiceInstance
Constants ¶
const A8sPGBackupAPIGroup = "backups.anynines.com"
Backup
const A8sPGBackupKind = "Backup"
const A8sPGBackupKindPlural = "backups"
const A8sPGLabelPrimary = "a8s.a9s/replication-role=master"
const A8sPGRestoreKind = "Restore"
Restore
const A8sPGServiceBindingAPIGroup = "servicebindings.anynines.com"
const A8sPGServiceBindingKind = "ServiceBinding"
Service Binding
const A8sPGServiceInstanceAPIGroup = "postgresql.anynines.com"
Instance
const A8sPGServiceInstanceAPIGroupLabel = "a8s.a9s/dsi-group=" + A8sPGServiceInstanceAPIGroup
const A8sPGServiceInstanceKind = "Postgresql"
const A8sPGServiceInstanceKindLabel = "a8s.a9s/dsi-kind=" + A8sPGServiceInstanceKind
const A8sPGServiceInstanceKindPlural = "postgresqls"
const A8sPGServiceInstanceNameLabelKey = "a8s.a9s/dsi-name"
const DefaultPGAPIVersion = "v1beta3"
const RemoteUploadContainerName = "postgres"
Name of the container within the target pod to upload the file to.
const RemoteUploadDir = "/tmp"
Variables ¶
var SQLFilename = ""
Filename when used with option --file or -f
Functions ¶
func ApplySQLFileToPGServiceInstance ¶
func ApplySQLFileToPGServiceInstance(unattendedMode bool, namespace, serviceInstanceName, sqlFileToUpload string, noDelete bool)
Upload and execute psql for the given file on the primary of the given service instance.
If noDelete is set to true, the uploaded file won't be deleted after a successful apply. Not that, if errors occur, the process will be stopped and hence, an uploaded file will remain in the pod and not be deleted, in case its execution failed.
Example kubectl command: kubectl exec -n default clustered-0 -c postgres -- psql -U postgres -d a9s_apps_default_db -f demo_data.sql
func ApplySQLStatementToPGServiceInstance ¶
func ApplySQLStatementToPGServiceInstance(unattendedMode bool, namespace, serviceInstanceName, sqlStatement string)
TODO Reduce code duplication with ApplySQLFileToPGServiceInstance
func BackupToYAML ¶
Creates a backup YAML manifest for the given service instance name.
Returns a string.
func DoesBackupExist ¶
func ExecuteSQLFileWithinPod ¶
func ExecuteSQLFileWithinPod(unattendedMode bool, namespace, serviceInstanceName, remoteSQLFilePath string) error
Executes a SQL file within a Pod using PSQL. Both the sql file and the psql command must be present in the target pod.
Example: kubectl exec -n default clustered-0 -c postgres -- psql -U postgres -d a9s_apps_default_db -f demo_data.sql
func ExecuteSQLStatementWithinPod ¶
func ExecuteSQLStatementWithinPod(unattendedMode bool, namespace, serviceInstanceName, sqlStatement string) (*exec.Cmd, []byte, error)
TODO Remove code duplication with ExecuteSQLFileWithinPod
func FindPrimaryPodOfServiceInstance ¶
Identifies the current primary of the given PG service instance.
Executes: kubectl get pods -n default -l 'a8s.a9s/replication-role=master,a8s.a9s/dsi-group=postgresql.anynines.com,a8s.a9s/dsi-kind=Postgresql,a8s.a9s/dsi-name=clustered' -o=jsonpath='{.items[*].metadata.name}'
func RestoreToYAML ¶
Creates a restore YAML manifest to restore a backup.
func ServiceBindingToYAML ¶
func ServiceBindingToYAML(binding ServiceBinding) string
func ServiceInstanceToYAML ¶
func ServiceInstanceToYAML(instance ServiceInstance) string
func WaitForPGBackupResourceToBecomeReady ¶
Similar to kubectl watch ... Needed: Namespace and name of the resource to be observed.
func WaitForPGBackupToBecomeReady ¶
func WaitForPGBackupToBecomeReady(namespace, name string)
func WaitForPGRestoreToBecomeReady ¶
func WaitForPGRestoreToBecomeReady(namespace, name string)
func WaitForPGServiceBindingToBecomeReady ¶
func WaitForPGServiceBindingToBecomeReady(binding ServiceBinding) error
Source Files