210 lines
10 KiB
Go
210 lines
10 KiB
Go
package controller
|
|
|
|
import (
|
|
"context"
|
|
"fmt"
|
|
|
|
"time"
|
|
|
|
acidv1 "github.com/zalando/postgres-operator/pkg/apis/acid.zalan.do/v1"
|
|
"github.com/zalando/postgres-operator/pkg/util"
|
|
"github.com/zalando/postgres-operator/pkg/util/config"
|
|
"github.com/zalando/postgres-operator/pkg/util/constants"
|
|
metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
|
|
)
|
|
|
|
func (c *Controller) readOperatorConfigurationFromCRD(configObjectNamespace, configObjectName string) (*acidv1.OperatorConfiguration, error) {
|
|
|
|
config, err := c.KubeClient.AcidV1ClientSet.AcidV1().OperatorConfigurations(configObjectNamespace).Get(
|
|
context.TODO(), configObjectName, metav1.GetOptions{})
|
|
if err != nil {
|
|
return nil, fmt.Errorf("could not get operator configuration object %q: %v", configObjectName, err)
|
|
}
|
|
|
|
return config, nil
|
|
}
|
|
|
|
func int32ToPointer(value int32) *int32 {
|
|
return &value
|
|
}
|
|
|
|
// importConfigurationFromCRD is a transitional function that converts CRD configuration to the one based on the configmap
|
|
func (c *Controller) importConfigurationFromCRD(fromCRD *acidv1.OperatorConfigurationData) *config.Config {
|
|
result := &config.Config{}
|
|
|
|
// general config
|
|
result.EnableCRDValidation = util.CoalesceBool(fromCRD.EnableCRDValidation, util.True())
|
|
result.EnableLazySpiloUpgrade = fromCRD.EnableLazySpiloUpgrade
|
|
result.EtcdHost = fromCRD.EtcdHost
|
|
result.KubernetesUseConfigMaps = fromCRD.KubernetesUseConfigMaps
|
|
result.DockerImage = util.Coalesce(fromCRD.DockerImage, "registry.opensource.zalan.do/acid/spilo-12:1.6-p3")
|
|
result.Workers = fromCRD.Workers
|
|
result.MinInstances = fromCRD.MinInstances
|
|
result.MaxInstances = fromCRD.MaxInstances
|
|
result.ResyncPeriod = time.Duration(fromCRD.ResyncPeriod)
|
|
result.RepairPeriod = time.Duration(fromCRD.RepairPeriod)
|
|
result.SetMemoryRequestToLimit = fromCRD.SetMemoryRequestToLimit
|
|
result.ShmVolume = util.CoalesceBool(fromCRD.ShmVolume, util.True())
|
|
result.SidecarImages = fromCRD.SidecarImages
|
|
result.SidecarContainers = fromCRD.SidecarContainers
|
|
|
|
// user config
|
|
result.SuperUsername = util.Coalesce(fromCRD.PostgresUsersConfiguration.SuperUsername, "postgres")
|
|
result.ReplicationUsername = util.Coalesce(fromCRD.PostgresUsersConfiguration.ReplicationUsername, "standby")
|
|
|
|
// kubernetes config
|
|
result.CustomPodAnnotations = fromCRD.Kubernetes.CustomPodAnnotations
|
|
result.PodServiceAccountName = util.Coalesce(fromCRD.Kubernetes.PodServiceAccountName, "postgres-pod")
|
|
result.PodServiceAccountDefinition = fromCRD.Kubernetes.PodServiceAccountDefinition
|
|
result.PodServiceAccountRoleBindingDefinition = fromCRD.Kubernetes.PodServiceAccountRoleBindingDefinition
|
|
result.PodEnvironmentConfigMap = fromCRD.Kubernetes.PodEnvironmentConfigMap
|
|
result.PodTerminateGracePeriod = time.Duration(fromCRD.Kubernetes.PodTerminateGracePeriod)
|
|
result.SpiloPrivileged = fromCRD.Kubernetes.SpiloPrivileged
|
|
result.SpiloFSGroup = fromCRD.Kubernetes.SpiloFSGroup
|
|
result.ClusterDomain = util.Coalesce(fromCRD.Kubernetes.ClusterDomain, "cluster.local")
|
|
result.WatchedNamespace = fromCRD.Kubernetes.WatchedNamespace
|
|
result.PDBNameFormat = fromCRD.Kubernetes.PDBNameFormat
|
|
result.EnablePodDisruptionBudget = util.CoalesceBool(fromCRD.Kubernetes.EnablePodDisruptionBudget, util.True())
|
|
result.EnableInitContainers = util.CoalesceBool(fromCRD.Kubernetes.EnableInitContainers, util.True())
|
|
result.EnableSidecars = util.CoalesceBool(fromCRD.Kubernetes.EnableSidecars, util.True())
|
|
result.SecretNameTemplate = fromCRD.Kubernetes.SecretNameTemplate
|
|
result.OAuthTokenSecretName = fromCRD.Kubernetes.OAuthTokenSecretName
|
|
result.InfrastructureRolesSecretName = fromCRD.Kubernetes.InfrastructureRolesSecretName
|
|
result.PodRoleLabel = util.Coalesce(fromCRD.Kubernetes.PodRoleLabel, "spilo-role")
|
|
result.ClusterLabels = fromCRD.Kubernetes.ClusterLabels
|
|
result.InheritedLabels = fromCRD.Kubernetes.InheritedLabels
|
|
result.DownscalerAnnotations = fromCRD.Kubernetes.DownscalerAnnotations
|
|
result.ClusterNameLabel = util.Coalesce(fromCRD.Kubernetes.ClusterNameLabel, "cluster-name")
|
|
result.NodeReadinessLabel = fromCRD.Kubernetes.NodeReadinessLabel
|
|
result.PodPriorityClassName = fromCRD.Kubernetes.PodPriorityClassName
|
|
result.PodManagementPolicy = util.Coalesce(fromCRD.Kubernetes.PodManagementPolicy, "ordered_ready")
|
|
result.MasterPodMoveTimeout = time.Duration(fromCRD.Kubernetes.MasterPodMoveTimeout)
|
|
result.EnablePodAntiAffinity = fromCRD.Kubernetes.EnablePodAntiAffinity
|
|
result.PodAntiAffinityTopologyKey = util.Coalesce(fromCRD.Kubernetes.PodAntiAffinityTopologyKey, "kubernetes.io/hostname")
|
|
|
|
// Postgres Pod resources
|
|
result.DefaultCPURequest = util.Coalesce(fromCRD.PostgresPodResources.DefaultCPURequest, "100m")
|
|
result.DefaultMemoryRequest = util.Coalesce(fromCRD.PostgresPodResources.DefaultMemoryRequest, "100Mi")
|
|
result.DefaultCPULimit = util.Coalesce(fromCRD.PostgresPodResources.DefaultCPULimit, "1")
|
|
result.DefaultMemoryLimit = util.Coalesce(fromCRD.PostgresPodResources.DefaultMemoryLimit, "500Mi")
|
|
result.MinCPULimit = util.Coalesce(fromCRD.PostgresPodResources.MinCPULimit, "250m")
|
|
result.MinMemoryLimit = util.Coalesce(fromCRD.PostgresPodResources.MinMemoryLimit, "250Mi")
|
|
|
|
// timeout config
|
|
result.ResourceCheckInterval = time.Duration(fromCRD.Timeouts.ResourceCheckInterval)
|
|
result.ResourceCheckTimeout = time.Duration(fromCRD.Timeouts.ResourceCheckTimeout)
|
|
result.PodLabelWaitTimeout = time.Duration(fromCRD.Timeouts.PodLabelWaitTimeout)
|
|
result.PodDeletionWaitTimeout = time.Duration(fromCRD.Timeouts.PodDeletionWaitTimeout)
|
|
result.ReadyWaitInterval = time.Duration(fromCRD.Timeouts.ReadyWaitInterval)
|
|
result.ReadyWaitTimeout = time.Duration(fromCRD.Timeouts.ReadyWaitTimeout)
|
|
|
|
// load balancer config
|
|
result.DbHostedZone = fromCRD.LoadBalancer.DbHostedZone
|
|
result.EnableMasterLoadBalancer = fromCRD.LoadBalancer.EnableMasterLoadBalancer
|
|
result.EnableReplicaLoadBalancer = fromCRD.LoadBalancer.EnableReplicaLoadBalancer
|
|
result.CustomServiceAnnotations = fromCRD.LoadBalancer.CustomServiceAnnotations
|
|
result.MasterDNSNameFormat = fromCRD.LoadBalancer.MasterDNSNameFormat
|
|
result.ReplicaDNSNameFormat = fromCRD.LoadBalancer.ReplicaDNSNameFormat
|
|
|
|
// AWS or GCP config
|
|
result.WALES3Bucket = fromCRD.AWSGCP.WALES3Bucket
|
|
result.AWSRegion = fromCRD.AWSGCP.AWSRegion
|
|
result.LogS3Bucket = fromCRD.AWSGCP.LogS3Bucket
|
|
result.KubeIAMRole = fromCRD.AWSGCP.KubeIAMRole
|
|
result.AdditionalSecretMount = fromCRD.AWSGCP.AdditionalSecretMount
|
|
result.AdditionalSecretMountPath = fromCRD.AWSGCP.AdditionalSecretMountPath
|
|
|
|
// logical backup config
|
|
result.LogicalBackupSchedule = util.Coalesce(fromCRD.LogicalBackup.Schedule, "30 00 * * *")
|
|
result.LogicalBackupDockerImage = util.Coalesce(fromCRD.LogicalBackup.DockerImage, "registry.opensource.zalan.do/acid/logical-backup")
|
|
result.LogicalBackupS3Bucket = fromCRD.LogicalBackup.S3Bucket
|
|
result.LogicalBackupS3Region = fromCRD.LogicalBackup.S3Region
|
|
result.LogicalBackupS3Endpoint = fromCRD.LogicalBackup.S3Endpoint
|
|
result.LogicalBackupS3AccessKeyID = fromCRD.LogicalBackup.S3AccessKeyID
|
|
result.LogicalBackupS3SecretAccessKey = fromCRD.LogicalBackup.S3SecretAccessKey
|
|
result.LogicalBackupS3SSE = fromCRD.LogicalBackup.S3SSE
|
|
|
|
// debug config
|
|
result.DebugLogging = fromCRD.OperatorDebug.DebugLogging
|
|
result.EnableDBAccess = fromCRD.OperatorDebug.EnableDBAccess
|
|
|
|
// Teams API config
|
|
result.EnableTeamsAPI = fromCRD.TeamsAPI.EnableTeamsAPI
|
|
result.TeamsAPIUrl = fromCRD.TeamsAPI.TeamsAPIUrl
|
|
result.TeamAPIRoleConfiguration = fromCRD.TeamsAPI.TeamAPIRoleConfiguration
|
|
result.EnableTeamSuperuser = fromCRD.TeamsAPI.EnableTeamSuperuser
|
|
result.EnableAdminRoleForUsers = fromCRD.TeamsAPI.EnableAdminRoleForUsers
|
|
result.TeamAdminRole = fromCRD.TeamsAPI.TeamAdminRole
|
|
result.PamRoleName = fromCRD.TeamsAPI.PamRoleName
|
|
result.PamConfiguration = fromCRD.TeamsAPI.PamConfiguration
|
|
result.ProtectedRoles = fromCRD.TeamsAPI.ProtectedRoles
|
|
result.PostgresSuperuserTeams = fromCRD.TeamsAPI.PostgresSuperuserTeams
|
|
|
|
// logging REST API config
|
|
result.APIPort = fromCRD.LoggingRESTAPI.APIPort
|
|
result.RingLogLines = fromCRD.LoggingRESTAPI.RingLogLines
|
|
result.ClusterHistoryEntries = fromCRD.LoggingRESTAPI.ClusterHistoryEntries
|
|
|
|
// Scalyr config
|
|
result.ScalyrAPIKey = fromCRD.Scalyr.ScalyrAPIKey
|
|
result.ScalyrImage = fromCRD.Scalyr.ScalyrImage
|
|
result.ScalyrServerURL = fromCRD.Scalyr.ScalyrServerURL
|
|
result.ScalyrCPURequest = fromCRD.Scalyr.ScalyrCPURequest
|
|
result.ScalyrMemoryRequest = fromCRD.Scalyr.ScalyrMemoryRequest
|
|
result.ScalyrCPULimit = fromCRD.Scalyr.ScalyrCPULimit
|
|
result.ScalyrMemoryLimit = fromCRD.Scalyr.ScalyrMemoryLimit
|
|
|
|
// Connection pooler. Looks like we can't use defaulting in CRD before 1.17,
|
|
// so ensure default values here.
|
|
result.ConnectionPooler.NumberOfInstances = util.CoalesceInt32(
|
|
fromCRD.ConnectionPooler.NumberOfInstances,
|
|
int32ToPointer(2))
|
|
|
|
result.ConnectionPooler.NumberOfInstances = util.MaxInt32(
|
|
result.ConnectionPooler.NumberOfInstances,
|
|
int32ToPointer(2))
|
|
|
|
result.ConnectionPooler.Schema = util.Coalesce(
|
|
fromCRD.ConnectionPooler.Schema,
|
|
constants.ConnectionPoolerSchemaName)
|
|
|
|
result.ConnectionPooler.User = util.Coalesce(
|
|
fromCRD.ConnectionPooler.User,
|
|
constants.ConnectionPoolerUserName)
|
|
|
|
if result.ConnectionPooler.User == result.SuperUsername {
|
|
msg := "Connection pool user is not allowed to be the same as super user, username: %s"
|
|
panic(fmt.Errorf(msg, result.ConnectionPooler.User))
|
|
}
|
|
|
|
result.ConnectionPooler.Image = util.Coalesce(
|
|
fromCRD.ConnectionPooler.Image,
|
|
"registry.opensource.zalan.do/acid/pgbouncer")
|
|
|
|
result.ConnectionPooler.Mode = util.Coalesce(
|
|
fromCRD.ConnectionPooler.Mode,
|
|
constants.ConnectionPoolerDefaultMode)
|
|
|
|
result.ConnectionPooler.ConnectionPoolerDefaultCPURequest = util.Coalesce(
|
|
fromCRD.ConnectionPooler.DefaultCPURequest,
|
|
constants.ConnectionPoolerDefaultCpuRequest)
|
|
|
|
result.ConnectionPooler.ConnectionPoolerDefaultMemoryRequest = util.Coalesce(
|
|
fromCRD.ConnectionPooler.DefaultMemoryRequest,
|
|
constants.ConnectionPoolerDefaultMemoryRequest)
|
|
|
|
result.ConnectionPooler.ConnectionPoolerDefaultCPULimit = util.Coalesce(
|
|
fromCRD.ConnectionPooler.DefaultCPULimit,
|
|
constants.ConnectionPoolerDefaultCpuLimit)
|
|
|
|
result.ConnectionPooler.ConnectionPoolerDefaultMemoryLimit = util.Coalesce(
|
|
fromCRD.ConnectionPooler.DefaultMemoryLimit,
|
|
constants.ConnectionPoolerDefaultMemoryLimit)
|
|
|
|
result.ConnectionPooler.MaxDBConnections = util.CoalesceInt32(
|
|
fromCRD.ConnectionPooler.MaxDBConnections,
|
|
int32ToPointer(constants.ConnectionPoolerMaxDBConnections))
|
|
|
|
return result
|
|
}
|