util

Documentation

Index

• func CopySecrets(clientset *kubernetes.Clientset, namespace string, ...) error
• 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 Exec(config *rest.Config, namespace, podname, containername string, cmd []string) error
• func GetFullVersion(imageTag string) string
• func GetLabels(name, clustername string, clone, replica bool) string
• func GetPasswordFromSecret(clientset *kubernetes.Clientset, namespace string, secretName string) (string, error)
• 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
• func WebsocketCallback(ws *websocket.Conn, resp *http.Response, err error) error
• type RoundTripCallback
• type ThingSpec
• type WebsocketRoundTripper
  • func (d *WebsocketRoundTripper) RoundTrip(r *http.Request) (*http.Response, error)

Functions

func CopySecrets

func CopySecrets(clientset *kubernetes.Clientset, namespace string, fromCluster, toCluster string) error

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 Exec

func Exec(config *rest.Config, namespace, podname, containername string, cmd []string) error

execs the cmd

func GetFullVersion

func GetFullVersion(imageTag string) string

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

func GetLabels

func GetLabels(name, clustername string, clone, replica bool) string

func GetPasswordFromSecret

func GetPasswordFromSecret(clientset *kubernetes.Clientset, namespace string, secretName string) (string, error)

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

func WebsocketCallback

func WebsocketCallback(ws *websocket.Conn, resp *http.Response, err error) error

Types

type RoundTripCallback

type RoundTripCallback func(conn *websocket.Conn, resp *http.Response, err error) error

type ThingSpec

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

type WebsocketRoundTripper

type WebsocketRoundTripper struct {
	Dialer *websocket.Dialer
	Do     RoundTripCallback
}

func (*WebsocketRoundTripper) RoundTrip

func (d *WebsocketRoundTripper) RoundTrip(r *http.Request) (*http.Response, error)