operator

Documentation

Index

• Constants
• Variables
• func GetAffinity(nodeLabelKey, nodeLabelValue string, affoperator string) string
• func GetBadgerAddon(clientset *kubernetes.Clientset, namespace string, cluster *crv1.Pgcluster, ...) string
• func GetCollectAddon(clientset *kubernetes.Clientset, namespace string, spec *crv1.PgclusterSpec) string
• func GetCollectVolume(clientset *kubernetes.Clientset, cl *crv1.Pgcluster, namespace string) string
• func GetConfVolume(clientset *kubernetes.Clientset, cl *crv1.Pgcluster, namespace string) string
• func GetContainerResourcesJSON(resources *crv1.PgContainerResources) string
• func GetLabelsFromMap(labels map[string]string) string
• func GetPgbackrestEnvVars(backrestEnabled, clusterName, depName, port, storageType string) string
• func GetPgbackrestS3EnvVars(backrestLabel, backRestStorageTypeLabel string, ...) string
• func GetPgmonitorEnvVars(metricsEnabled string) string
• func GetReplicaAffinity(clusterLabels, replicaLabels map[string]string) string
• func GetRepoType(backrestStorageType string) string
• func Initialize(clientset *kubernetes.Clientset)
• func IsLocalAndS3Storage(backrestStorageType string) bool
• type DeploymentTemplateFields
• type PgbackrestEnvVarsTemplateFields
• type PgbackrestS3EnvVarsTemplateFields
• type PgmonitorEnvVarsTemplateFields

Constants

const AFFINITY_NOTINOperator = "NotIn"

const AffinityInOperator = "In"

consolidate with cluster.affinityTemplateFields

Variables

var CRUNCHY_DEBUG bool

var EventTCPAddress = "localhost:4150"

var InstallationName string

var NAMESPACE string

var Pgo config.PgoConfig

var PgoNamespace string

Functions

func GetAffinity

func GetAffinity(nodeLabelKey, nodeLabelValue string, affoperator string) string

GetAffinity ...

func GetBadgerAddon

func GetBadgerAddon(clientset *kubernetes.Clientset, namespace string, cluster *crv1.Pgcluster, pgbadger_target string) string

func GetCollectAddon

func GetCollectAddon(clientset *kubernetes.Clientset, namespace string, spec *crv1.PgclusterSpec) string

func GetCollectVolume

func GetCollectVolume(clientset *kubernetes.Clientset, cl *crv1.Pgcluster, namespace string) string

sets the proper collect secret in the deployment spec if collect is enabled

func GetConfVolume

func GetConfVolume(clientset *kubernetes.Clientset, cl *crv1.Pgcluster, namespace string) string

consolidate with cluster.GetConfVolume

func GetContainerResourcesJSON

func GetContainerResourcesJSON(resources *crv1.PgContainerResources) string

GetContainerResources ...

func GetLabelsFromMap

func GetLabelsFromMap(labels map[string]string) string

needs to be consolidated with cluster.GetLabelsFromMap GetLabelsFromMap ...

func GetPgbackrestEnvVars

func GetPgbackrestEnvVars(backrestEnabled, clusterName, depName, port, storageType string) string

consolidate with cluster.GetPgbackrestEnvVars

func GetPgbackrestS3EnvVars

func GetPgbackrestS3EnvVars(backrestLabel, backRestStorageTypeLabel string,
	clientset *kubernetes.Clientset, ns string) string

func GetPgmonitorEnvVars

func GetPgmonitorEnvVars(metricsEnabled string) string

func GetReplicaAffinity

func GetReplicaAffinity(clusterLabels, replicaLabels map[string]string) string

GetReplicaAffinity ... use NotIn as an operator when a node-label is not specified on the replica, use the node labels from the primary in this case use In as an operator when a node-label is specified on the replica use the node labels from the replica in this case

func GetRepoType

func GetRepoType(backrestStorageType string) string

GetRepoType returns the proper repo type to set in container based on the backrest storage type provided

func Initialize

func Initialize(clientset *kubernetes.Clientset)

func IsLocalAndS3Storage

func IsLocalAndS3Storage(backrestStorageType string) bool

IsLocalAndS3Storage a boolean indicating whether or not local and s3 storage should be enabled for pgBackRest based on the backrestStorageType string provided

Types

type DeploymentTemplateFields

type DeploymentTemplateFields struct {
	Name                    string
	ClusterName             string
	Port                    string
	PgMode                  string
	LogStatement            string
	LogMinDurationStatement string
	CCPImagePrefix          string
	CCPImageTag             string
	CCPImage                string
	Database                string
	DeploymentLabels        string
	PodLabels               string
	DataPathOverride        string
	ArchiveMode             string
	ArchivePVCName          string
	ArchiveTimeout          string
	XLOGDir                 string
	BackrestPVCName         string
	PVCName                 string
	RootSecretName          string
	UserSecretName          string
	PrimarySecretName       string
	SecurityContext         string
	ContainerResources      string
	NodeSelector            string
	ConfVolume              string
	CollectAddon            string
	CollectVolume           string
	BadgerAddon             string
	PgbackrestEnvVars       string
	PgbackrestS3EnvVars     string
	PgmonitorEnvVars        string
	//next 2 are for the replica deployment only
	Replicas    string
	PrimaryHost string
	// PgBouncer deployment only
	PgbouncerPass string
}

needs to be consolidated with cluster.DeploymentTemplateFields DeploymentTemplateFields ...

type PgbackrestEnvVarsTemplateFields

type PgbackrestEnvVarsTemplateFields struct {
	PgbackrestStanza            string
	PgbackrestDBPath            string
	PgbackrestRepo1Path         string
	PgbackrestRepo1Host         string
	PgbackrestRepo1Type         string
	PgbackrestLocalAndS3Storage bool
	PgbackrestPGPort            string
}

type PgbackrestS3EnvVarsTemplateFields

type PgbackrestS3EnvVarsTemplateFields struct {
	PgbackrestS3Bucket    string
	PgbackrestS3Endpoint  string
	PgbackrestS3Region    string
	PgbackrestS3Key       string
	PgbackrestS3KeySecret string
}

type PgmonitorEnvVarsTemplateFields

type PgmonitorEnvVarsTemplateFields struct {
	PgmonitorPassword string
}