util

Documentation

Index

• func CreateBackupPVCSnippet(BACKUP_PVC_NAME string) string
• func CreateDatabaseSecrets(clientset *kubernetes.Clientset, tprclient *rest.RESTClient, cl *tpr.PgCluster, ...) error
• func CreateSecContext(FS_GROUP string, SUPP string) string
• func CreateSecret(clientset *kubernetes.Clientset, ...) error
• func DeleteDatabaseSecrets(clientset *kubernetes.Clientset, db, namespace string)
• func DrainDeployment(clientset *kubernetes.Clientset, name string, namespace string) error
• func GetFullVersion(imageTag string) string
• func LoadTemplate(path string) *template.Template
• func Patch(tprclient *rest.RESTClient, path string, value string, resource string, ...) error
• func ScaleDeployment(clientset *kubernetes.Clientset, deploymentName, namespace string, ...) error
• func WaitUntilDeploymentIsDeleted(clientset *kubernetes.Clientset, depname string, timeout time.Duration, ...) error
• func WaitUntilPod(clientset *kubernetes.Clientset, lo v1.ListOptions, podPhase v1.PodPhase, ...) error
• func WaitUntilPodIsDeleted(clientset *kubernetes.Clientset, podname string, timeout time.Duration, ...) error
• func WaitUntilReplicasetIsDeleted(clientset *kubernetes.Clientset, rcname string, timeout time.Duration, ...) error
• type ThingSpec

Functions

func CreateBackupPVCSnippet

func CreateBackupPVCSnippet(BACKUP_PVC_NAME string) string

func CreateDatabaseSecrets

func CreateDatabaseSecrets(clientset *kubernetes.Clientset, tprclient *rest.RESTClient, cl *tpr.PgCluster, namespace string) error

create pgroot, pgmaster, and pguser secrets

func CreateSecContext

func CreateSecContext(FS_GROUP string, SUPP string) string

func CreateSecret

func CreateSecret(clientset *kubernetes.Clientset, db, secretName, username, password, namespace string) error

create the secret, user, and master secrets

func DeleteDatabaseSecrets

func DeleteDatabaseSecrets(clientset *kubernetes.Clientset, db, namespace string)

delete pgroot, pgmaster, and pguser secrets

func DrainDeployment

func DrainDeployment(clientset *kubernetes.Clientset, name string, namespace string) error

func GetFullVersion

func GetFullVersion(imageTag string) string

from docker, get a map of postgres images plus the full version numbers

func LoadTemplate

func LoadTemplate(path string) *template.Template

func Patch

func Patch(tprclient *rest.RESTClient, path string, value string, resource string, name string, namespace string) error

func ScaleDeployment

func ScaleDeployment(clientset *kubernetes.Clientset, deploymentName, namespace string, replicaCount int) error

func WaitUntilDeploymentIsDeleted

func WaitUntilDeploymentIsDeleted(clientset *kubernetes.Clientset, depname string, timeout time.Duration, namespace string) error

timeout := time.Minute

func WaitUntilPod

func WaitUntilPod(clientset *kubernetes.Clientset, lo v1.ListOptions, podPhase v1.PodPhase, timeout time.Duration, namespace string) error

lo := v1.ListOptions{LabelSelector: "pg-database=" + "testpod"} podPhase is v1.PodRunning timeout := time.Minute

func WaitUntilPodIsDeleted

func WaitUntilPodIsDeleted(clientset *kubernetes.Clientset, podname string, timeout time.Duration, namespace string) error

timeout := time.Minute

func WaitUntilReplicasetIsDeleted

func WaitUntilReplicasetIsDeleted(clientset *kubernetes.Clientset, rcname string, timeout time.Duration, namespace string) error

timeout := time.Minute

Types

type ThingSpec

type ThingSpec struct {
	Op    string `json:"op"`
	Path  string `json:"path"`
	Value string `json:"value"`
}