util

package

v1.3.2 Latest Latest Go to latest Published: Jun 29, 2017 License: Apache-2.0 Imports: 25 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/jufi-git/postgres-operator

Links

Open Source Insights

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)

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func CopySecrets ¶ added in v1.3.0

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

func CreateBackupPVCSnippet ¶ added in v1.2.0

func CreateBackupPVCSnippet(BACKUP_PVC_NAME string) string

func CreateDatabaseSecrets ¶ added in v1.2.0

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 ¶ added in v1.2.0

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

create the secret, user, and master secrets

func DeleteDatabaseSecrets ¶ added in v1.2.0

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 ¶ added in v1.3.0

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

execs the cmd

func GetFullVersion ¶ added in v1.2.0

func GetFullVersion(imageTag string) string

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

func GetLabels ¶ added in v1.3.0

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

func GetPasswordFromSecret ¶ added in v1.3.0

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 ¶ added in v1.2.0

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 ¶ added in v1.3.0

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

Types ¶

type RoundTripCallback ¶ added in v1.3.0

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 ¶ added in v1.3.0

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

func (*WebsocketRoundTripper) RoundTrip ¶ added in v1.3.0

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

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL