Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

util

package

Go to main page

Versions in this module

v1

v1.6.0

May 16, 2024

v1.5.1

Jan 25, 2024

v1.5.0

Dec 11, 2023

v1.4.0

Mar 31, 2023

v1.3.0

Aug 4, 2022

v1.2.0

Apr 6, 2022

v1.1.0

Dec 7, 2021

v1.0.0

Oct 1, 2021

v0

v0.2.0

Aug 23, 2021

Changes in this version

+ const BackRestRepoSecretKeyAWSS3KeyGCSKey

+ const BootstrapConfigPrefix

+ func CreatePerconaRMDataTask(clientset kubeapi.Interface, cluster *crv1.PerconaPGCluster, ...) error

+ func GetCustomLabels(cluster *crv1.Pgcluster) map[string]string

+ func ValidatePVCResize(oldSize, newSize string) error

type BackrestRepoConfig

+ BackrestGCSKey []byte

+ CustomLabels map[string]string

+ type GCSSecret struct

+ Key []byte

+ func GetGCSCredsFromBackrestRepoSecret(clientset kubernetes.Interface, namespace, clusterName string) (GCSSecret, error)

v0.1.0

May 4, 2021

Changes in this version

+ const BackRestRepoSecretKeyAWSS3KeyAWSS3CACert

+ const BackRestRepoSecretKeyAWSS3KeyAWSS3Key

+ const BackRestRepoSecretKeyAWSS3KeyAWSS3KeySecret

+ const BackrestRepoDeploymentName

+ const BackrestRepoPVCName

+ const BackrestRepoSecretName

+ const BackrestRepoServiceName

+ const DefaultGeneratedPasswordLength

+ const DefaultPasswordValidUntilDays

+ const InstanceRolePrimary

+ const InstanceRoleReplica

+ const SQLValidUntilAlways

+ const SQLValidUntilNever

+ var ErrLabelInvalid = errors.New("invalid label")

+ var ErrMissingConfigAnnotation error = errors.New(...)

+ func CreateBackrestRepoSecrets(clientset kubernetes.Interface, backrestRepoConfig BackrestRepoConfig) error

+ func CreateRMDataTask(clientset kubeapi.Interface, cluster *crv1.Pgcluster, replicaName string, ...) error

+ func CreateSecret(clientset kubernetes.Interface, ...) error

+ func CreateUserSecret(clientset kubernetes.Interface, cluster *crv1.Pgcluster, ...) error

+ func CurrentPrimaryUpdate(clientset pgo.Interface, cluster *crv1.Pgcluster, ...) error

+ func ExecPolicy(clientset kubeapi.Interface, restconfig *rest.Config, ...) error

+ func GenerateExporterSecretName(clusterName string) string

+ func GenerateNodeAffinity(affinityType crv1.NodeAffinityType, key string, values []string) *v1.NodeAffinity

+ func GeneratePassword(length int) (string, error)

+ func GeneratePgBouncerConfigMapName(clusterName string) string

+ func GeneratePgBouncerSecretName(clusterName string) string

+ func GeneratePgBouncerUsersFileBytes(hashedPassword string) []byte

+ func GeneratedPasswordLength(configuredPasswordLength string) int

+ func GeneratedPasswordValidUntilDays(configuredValidUntilDays string) int

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

+ func GetPasswordFromSecret(clientset kubernetes.Interface, namespace, secretName string) (string, error)

+ func GetPolicySQL(clientset pgo.Interface, namespace, policyName string) (string, error)

+ func GetPrimaryPod(clientset kubernetes.Interface, cluster *crv1.Pgcluster) (*v1.Pod, error)

+ func GetSecretPassword(clientset kubernetes.Interface, db, suffix, Namespace string) (string, error)

+ func GetStandardImageTag(imageName, imageTag string) string

+ func GetTolerations(tolerations []v1.Toleration) string

+ func GetValueOrDefault(value, defaultValue string) string

+ func IsPostgreSQLUserSystemAccount(username string) bool

+ func IsStringOneOf(testVal string, acceptedVals ...string) bool

+ func PatchClusterCRD(clientset pgo.Interface, labelMap map[string]string, oldCrd *crv1.Pgcluster, ...) error

+ func RandStringBytesRmndr(n int) string

+ func SQLQuoteIdentifier(identifier string) string

+ func SQLQuoteLiteral(literal string) string

+ func SetPostgreSQLPassword(clientset kubernetes.Interface, restconfig *rest.Config, pod *v1.Pod, ...) error

+ func StopPostgreSQLInstance(clientset kubernetes.Interface, restconfig *rest.Config, pod *v1.Pod, ...) error

+ func ToggleAutoFailover(clientset kubernetes.Interface, enable bool, pghaScope, namespace string) error

+ func UpdateUserSecret(clientset kubernetes.Interface, cluster *crv1.Pgcluster, ...) error

+ func ValidateLabels(labels map[string]string) error

+ func ValidatePolicy(clientset pgo.Interface, namespace string, policyName string) error

+ type AWSS3Secret struct

+ AWSS3CA []byte

+ AWSS3Key string

+ AWSS3KeySecret string

+ func GetS3CredsFromBackrestRepoSecret(clientset kubernetes.Interface, namespace, clusterName string) (AWSS3Secret, error)

+ type BackrestRepoConfig struct

+ BackrestS3CA []byte

+ BackrestS3Key string

+ BackrestS3KeySecret string

+ ClusterName string

+ ClusterNamespace string

+ OperatorNamespace string

+ type InstanceReplicationInfo struct

+ Name string

+ Node string

+ PendingRestart bool

+ PodName string

+ ReplicationLag int

+ Role string

+ Status string

+ Timeline int

+ type ReplicationStatusRequest struct

+ Clientset kubernetes.Interface

+ ClusterName string

+ Namespace string

+ RESTConfig *rest.Config

+ type ReplicationStatusResponse struct

+ Instances []InstanceReplicationInfo

+ func ReplicationStatus(request ReplicationStatusRequest, includePrimary, includeBusted bool) (ReplicationStatusResponse, error)

+ type SSHKey struct

+ Private []byte

+ Public []byte

+ func NewPrivatePublicKeyPair() (SSHKey, error)