Skip to content

Commit

Permalink
THREESCALE-11021 add redis ACL credentials to system and backend
Browse files Browse the repository at this point in the history
  • Loading branch information
@valerymo
valerymo committed Dec 22, 2024
1 parent 97cf9f0 commit b60047c
Show file tree
Hide file tree
Showing 11 changed files with 244 additions and 3 deletions.
26 changes: 26 additions & 0 deletions apis/apps/v1alpha1/apimanager_types.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -84,6 +84,8 @@ type APIManagerSpec struct {
PodDisruptionBudget *PodDisruptionBudgetSpec `json:"podDisruptionBudget,omitempty"`
// +optional
Monitoring *MonitoringSpec `json:"monitoring,omitempty"`
// +optional
SentinelIsUsed *bool `json:"sentinelIsUsed,omitempty"`
}

// APIManagerStatus defines the observed state of APIManager
Expand Down Expand Up @@ -1535,3 +1537,27 @@ type APIManagerList struct {
func init() {
SchemeBuilder.Register(&APIManager{}, &APIManagerList{})
}

func (apimanager *APIManager) IsSystemSentinelUsed() bool {
tlsEnabled := false
if apimanager.Spec.SentinelIsUsed != nil &&
*apimanager.Spec.SentinelIsUsed &&
apimanager.Spec.ExternalComponents != nil &&
apimanager.Spec.ExternalComponents.System != nil &&
apimanager.Spec.ExternalComponents.Backend != nil &&
*apimanager.Spec.ExternalComponents.System.Redis {
tlsEnabled = true
}
return tlsEnabled
}
func (apimanager *APIManager) IsBackendSentinelUsed() bool {
tlsEnabled := false
if apimanager.Spec.SentinelIsUsed != nil &&
*apimanager.Spec.SentinelIsUsed &&
apimanager.Spec.ExternalComponents != nil &&
apimanager.Spec.ExternalComponents.Backend != nil &&
*apimanager.Spec.ExternalComponents.Backend.Redis {
tlsEnabled = true
}
return tlsEnabled
}
5 changes: 5 additions & 0 deletions apis/apps/v1alpha1/zz_generated.deepcopy.go
View file

Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.

27 changes: 26 additions & 1 deletion pkg/3scale/amp/component/backend.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -29,6 +29,16 @@ const (
BackendSecretBackendRedisStorageSentinelRoleFieldName = "REDIS_STORAGE_SENTINEL_ROLE"
BackendSecretBackendRedisQueuesSentinelHostsFieldName = "REDIS_QUEUES_SENTINEL_HOSTS"
BackendSecretBackendRedisQueuesSentinelRoleFieldName = "REDIS_QUEUES_SENTINEL_ROLE"

// ACL
BackendSecretBackendRedisConfigRedisUsernameFieldName = "CONFIG_REDIS_USERNAME"
BackendSecretBackendRedisConfigRedisPasswordFieldName = "CONFIG_REDIS_PASSWORD"
BackendSecretBackendRedisConfigRedisSentinelUsernameFieldName = "CONFIG_REDIS_SENTINEL_USERNAME"
BackendSecretBackendRedisConfigRedisSentinelPasswordFieldName = "CONFIG_REDIS_SENTINEL_PASSWORD"
BackendSecretBackendRedisConfigQueuesUsernameFieldName = "CONFIG_QUEUES_USERNAME"
BackendSecretBackendRedisConfigQueuesPasswordFieldName = "CONFIG_QUEUES_PASSWORD"
BackendSecretBackendRedisConfigQueuesSentinelUsernameFieldName = "CONFIG_QUEUES_SENTINEL_USERNAME"
BackendSecretBackendRedisConfigQueuesSentinelPasswordFieldName = "CONFIG_QUEUES_SENTINEL_PASSWORD"
)

const (
Expand Down Expand Up @@ -372,15 +382,30 @@ func (backend *Backend) EnvironmentConfigMap() *v1.ConfigMap {
}

func (backend *Backend) buildBackendCommonEnv() []v1.EnvVar {
return []v1.EnvVar{
result := []v1.EnvVar{}
result = append(result,
helper.EnvVarFromSecret("CONFIG_REDIS_PROXY", BackendSecretBackendRedisSecretName, BackendSecretBackendRedisStorageURLFieldName),
helper.EnvVarFromSecret("CONFIG_REDIS_SENTINEL_HOSTS", BackendSecretBackendRedisSecretName, BackendSecretBackendRedisStorageSentinelHostsFieldName),
helper.EnvVarFromSecret("CONFIG_REDIS_SENTINEL_ROLE", BackendSecretBackendRedisSecretName, BackendSecretBackendRedisStorageSentinelRoleFieldName),
helper.EnvVarFromSecret("CONFIG_QUEUES_MASTER_NAME", BackendSecretBackendRedisSecretName, BackendSecretBackendRedisQueuesURLFieldName),
helper.EnvVarFromSecret("CONFIG_QUEUES_SENTINEL_HOSTS", BackendSecretBackendRedisSecretName, BackendSecretBackendRedisQueuesSentinelHostsFieldName),
helper.EnvVarFromSecret("CONFIG_QUEUES_SENTINEL_ROLE", BackendSecretBackendRedisSecretName, BackendSecretBackendRedisQueuesSentinelRoleFieldName),
helper.EnvVarFromConfigMap("RACK_ENV", "backend-environment", "RACK_ENV"),
// ACL
helper.EnvVarFromSecret("CONFIG_REDIS_USERNAME", BackendSecretBackendRedisSecretName, BackendSecretBackendRedisConfigRedisUsernameFieldName),
helper.EnvVarFromSecret("CONFIG_REDIS_PASSWORD", BackendSecretBackendRedisSecretName, BackendSecretBackendRedisConfigRedisPasswordFieldName),
helper.EnvVarFromSecret("CONFIG_QUEUES_USERNAME", BackendSecretBackendRedisSecretName, BackendSecretBackendRedisConfigQueuesUsernameFieldName),
helper.EnvVarFromSecret("CONFIG_QUEUES_PASSWORD", BackendSecretBackendRedisSecretName, BackendSecretBackendRedisConfigQueuesPasswordFieldName),
)
if backend.Options.RedisSentinelIsUsed { //ACL
result = append(result,
helper.EnvVarFromSecret("CONFIG_REDIS_SENTINEL_USERNAME", BackendSecretBackendRedisSecretName, BackendSecretBackendRedisConfigRedisSentinelUsernameFieldName),
helper.EnvVarFromSecret("CONFIG_REDIS_SENTINEL_PASSWORD", BackendSecretBackendRedisSecretName, BackendSecretBackendRedisConfigRedisSentinelPasswordFieldName),
helper.EnvVarFromSecret("CONFIG_QUEUES_SENTINEL_USERNAME", BackendSecretBackendRedisSecretName, BackendSecretBackendRedisConfigQueuesSentinelUsernameFieldName),
helper.EnvVarFromSecret("CONFIG_QUEUES_SENTINEL_PASSWORD", BackendSecretBackendRedisSecretName, BackendSecretBackendRedisConfigQueuesSentinelPasswordFieldName),
)
}
return result
}

func (backend *Backend) buildBackendWorkerEnv() []v1.EnvVar {
Expand Down
2 changes: 2 additions & 0 deletions pkg/3scale/amp/component/backend_options.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -54,6 +54,8 @@ type BackendOptions struct {
// that need namespace filtering because they are "global" once imported
// to the prometheus or grafana services.
Namespace string `validate:"required"`

RedisSentinelIsUsed bool
}

func NewBackendOptions() *BackendOptions {
Expand Down
18 changes: 18 additions & 0 deletions pkg/3scale/amp/component/redis.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -297,6 +297,15 @@ func (redis *Redis) BackendRedisSecret() *v1.Secret {
BackendSecretBackendRedisStorageSentinelRoleFieldName: redis.Options.BackendRedisStorageSentinelRole,
BackendSecretBackendRedisQueuesSentinelHostsFieldName: redis.Options.BackendRedisQueuesSentinelHosts,
BackendSecretBackendRedisQueuesSentinelRoleFieldName: redis.Options.BackendRedisQueuesSentinelRole,
// ACL
BackendSecretBackendRedisConfigRedisUsernameFieldName: redis.Options.BackendRedisConfigRedisUsername,
BackendSecretBackendRedisConfigRedisPasswordFieldName: redis.Options.BackendRedisConfigRedisPassword,
BackendSecretBackendRedisConfigRedisSentinelUsernameFieldName: redis.Options.BackendRedisConfigRedisSentinelUsername,
BackendSecretBackendRedisConfigRedisSentinelPasswordFieldName: redis.Options.BackendRedisConfigRedisSentinelPassword,
BackendSecretBackendRedisConfigQueuesUsernameFieldName: redis.Options.BackendRedisConfigQueuesUsername,
BackendSecretBackendRedisConfigQueuesPasswordFieldName: redis.Options.BackendRedisConfigQueuesPassword,
BackendSecretBackendRedisConfigQueuesSentinelUsernameFieldName: redis.Options.BackendRedisConfigQueuesSentinelUsername,
BackendSecretBackendRedisConfigQueuesSentinelPasswordFieldName: redis.Options.BackendRedisConfigQueuesSentinelPassword,
},
Type: v1.SecretTypeOpaque,
}
Expand Down Expand Up @@ -476,6 +485,15 @@ func (redis *Redis) SystemRedisSecret() *v1.Secret {
SystemSecretSystemRedisURLFieldName: redis.Options.SystemRedisURL,
SystemSecretSystemRedisSentinelHosts: redis.Options.SystemRedisSentinelsHosts,
SystemSecretSystemRedisSentinelRole: redis.Options.SystemRedisSentinelsRole,
// ACL
SystemSecretSystemRedisUsernameFieldName: redis.Options.SystemRedisUsername,
SystemSecretSystemRedisPasswordFieldName: redis.Options.SystemRedisPassword,
SystemSecretSystemRedisSentinelUsernameFieldName: redis.Options.SystemRedisSentinelUsername,
SystemSecretSystemRedisSentinelPasswordFieldName: redis.Options.SystemRedisSentinelPassword,
SystemSecretBackendRedisUsernameFieldName: redis.Options.SystemBackendRedisUsername,
SystemSecretBackendRedisPasswordFieldName: redis.Options.SystemBackendRedisPassword,
SystemSecretBackendRedisSentinelUsernameFieldName: redis.Options.SystemBackendRedisSentinelUsername,
SystemSecretBackendRedisSentinelPasswordFieldName: redis.Options.SystemBackendRedisSentinelPassword,
},
Type: v1.SecretTypeOpaque,
}
Expand Down
19 changes: 19 additions & 0 deletions pkg/3scale/amp/component/redis_options.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -47,6 +47,25 @@ type RedisOptions struct {
SystemRedisSentinelsHosts string
SystemRedisSentinelsRole string
SystemRedisNamespace string

// ACL
SystemRedisUsername string
SystemRedisPassword string
SystemRedisSentinelUsername string
SystemRedisSentinelPassword string
SystemBackendRedisUsername string
SystemBackendRedisPassword string
SystemBackendRedisSentinelUsername string
SystemBackendRedisSentinelPassword string

BackendRedisConfigRedisUsername string
BackendRedisConfigRedisPassword string
BackendRedisConfigRedisSentinelUsername string
BackendRedisConfigRedisSentinelPassword string
BackendRedisConfigQueuesUsername string
BackendRedisConfigQueuesPassword string
BackendRedisConfigQueuesSentinelUsername string
BackendRedisConfigQueuesSentinelPassword string
}

func NewRedisOptions() *RedisOptions {
Expand Down
33 changes: 31 additions & 2 deletions pkg/3scale/amp/component/system.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -47,6 +47,16 @@ const (
SystemSecretSystemRedisURLFieldName = "URL"
SystemSecretSystemRedisSentinelHosts = "SENTINEL_HOSTS"
SystemSecretSystemRedisSentinelRole = "SENTINEL_ROLE"

// ACL env vars
SystemSecretSystemRedisUsernameFieldName = "REDIS_USERNAME"
SystemSecretSystemRedisPasswordFieldName = "REDIS_PASSWORD"
SystemSecretSystemRedisSentinelUsernameFieldName = "REDIS_SENTINEL_USERNAME"
SystemSecretSystemRedisSentinelPasswordFieldName = "REDIS_SENTINEL_PASSWORD"
SystemSecretBackendRedisUsernameFieldName = "BACKEND_REDIS_USERNAME"
SystemSecretBackendRedisPasswordFieldName = "BACKEND_REDIS_PASSWORD"
SystemSecretBackendRedisSentinelUsernameFieldName = "BACKEND_REDIS_SENTINEL_USERNAME"
SystemSecretBackendRedisSentinelPasswordFieldName = "BACKEND_REDIS_SENTINEL_PASSWORD"
)

const (
Expand Down Expand Up @@ -165,12 +175,20 @@ func (system *System) getSystemSMTPEnvsFromSMTPSecret() []v1.EnvVar {

func (system *System) SystemRedisEnvVars() []v1.EnvVar {
result := []v1.EnvVar{}

result = append(result,
helper.EnvVarFromSecret("REDIS_URL", SystemSecretSystemRedisSecretName, SystemSecretSystemRedisURLFieldName),
helper.EnvVarFromSecret("REDIS_SENTINEL_HOSTS", SystemSecretSystemRedisSecretName, SystemSecretSystemRedisSentinelHosts),
helper.EnvVarFromSecret("REDIS_SENTINEL_ROLE", SystemSecretSystemRedisSecretName, SystemSecretSystemRedisSentinelRole),
//ACL
helper.EnvVarFromSecretOptional("REDIS_USERNAME", SystemSecretSystemRedisSecretName, SystemSecretSystemRedisUsernameFieldName),
helper.EnvVarFromSecretOptional("REDIS_PASSWORD", SystemSecretSystemRedisSecretName, SystemSecretSystemRedisPasswordFieldName),
)
if system.Options.RedisSentinelIsUsed { //ACL
result = append(result,
helper.EnvVarFromSecretOptional("REDIS_SENTINEL_USERNAME", SystemSecretSystemRedisSecretName, SystemSecretSystemRedisSentinelUsernameFieldName),
helper.EnvVarFromSecretOptional("REDIS_SENTINEL_PASSWORD", SystemSecretSystemRedisSecretName, SystemSecretSystemRedisSentinelPasswordFieldName),
)
}

return result
}
Expand Down Expand Up @@ -321,11 +339,22 @@ func (system *System) buildSystemAppPostHookEnv() []v1.EnvVar {
}

func (system *System) BackendRedisEnvVars() []v1.EnvVar {
return []v1.EnvVar{
result := []v1.EnvVar{}
result = append(result,
helper.EnvVarFromSecret("BACKEND_REDIS_URL", BackendSecretBackendRedisSecretName, BackendSecretBackendRedisStorageURLFieldName),
helper.EnvVarFromSecret("BACKEND_REDIS_SENTINEL_HOSTS", BackendSecretBackendRedisSecretName, BackendSecretBackendRedisStorageSentinelHostsFieldName),
helper.EnvVarFromSecret("BACKEND_REDIS_SENTINEL_ROLE", BackendSecretBackendRedisSecretName, BackendSecretBackendRedisStorageSentinelRoleFieldName),
//ACL
helper.EnvVarFromSecret("BACKEND_REDIS_USERNAME", SystemSecretSystemRedisSecretName, SystemSecretBackendRedisUsernameFieldName),
helper.EnvVarFromSecret("BACKEND_REDIS_PASSWORD", SystemSecretSystemRedisSecretName, SystemSecretBackendRedisPasswordFieldName),
)
if system.Options.RedisSentinelIsUsed { //ACL
result = append(result,
helper.EnvVarFromSecret("BACKEND_REDIS_SENTINEL_USERNAME", SystemSecretSystemRedisSecretName, SystemSecretBackendRedisSentinelUsernameFieldName),
helper.EnvVarFromSecret("BACKEND_REDIS_SENTINEL_PASSWORD", SystemSecretSystemRedisSecretName, SystemSecretBackendRedisSentinelPasswordFieldName),
)
}
return result
}

func (system *System) EnvironmentConfigMap() *v1.ConfigMap {
Expand Down
2 changes: 2 additions & 0 deletions pkg/3scale/amp/component/system_options.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -104,6 +104,8 @@ type SystemOptions struct {
// that need namespace filtering because they are "global" once imported
// to the prometheus or grafana services.
Namespace string `validate:"required"`

RedisSentinelIsUsed bool
}

func NewSystemOptions() *SystemOptions {
Expand Down
6 changes: 6 additions & 0 deletions pkg/3scale/amp/operator/backend_options_provider.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -47,6 +47,7 @@ func (o *OperatorBackendOptionsProvider) GetBackendOptions() (*component.Backend
o.setPriorityClassNames()
o.setTopologySpreadConstraints()
o.setPodTemplateAnnotations()
o.setSentinelIsUsed()

o.backendOptions.CommonLabels = o.commonLabels()
o.backendOptions.CommonListenerLabels = o.commonListenerLabels()
Expand Down Expand Up @@ -276,3 +277,8 @@ func (o *OperatorBackendOptionsProvider) setTopologySpreadConstraints() {
o.backendOptions.TopologySpreadConstraintsCron = o.apimanager.Spec.Backend.CronSpec.TopologySpreadConstraints
}
}

// ACL
func (o *OperatorBackendOptionsProvider) setSentinelIsUsed() {
o.backendOptions.RedisSentinelIsUsed = o.apimanager.IsBackendSentinelUsed()
}
104 changes: 104 additions & 0 deletions pkg/3scale/amp/operator/redis_options_provider.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -148,6 +148,110 @@ func (r *RedisOptionsProvider) setSecretBasedOptions() error {
component.SystemSecretSystemRedisSentinelRole,
component.DefaultSystemRedisSentinelRole(),
},

// ACL
{
&r.options.SystemRedisUsername,
component.SystemSecretSystemRedisSecretName,
component.SystemSecretSystemRedisUsernameFieldName,
"",
},
{
&r.options.SystemRedisPassword,
component.SystemSecretSystemRedisSecretName,
component.SystemSecretSystemRedisPasswordFieldName,
"",
},
{
&r.options.SystemRedisSentinelUsername,
component.SystemSecretSystemRedisSecretName,
component.SystemSecretSystemRedisSentinelUsernameFieldName,
"",
},
{
&r.options.SystemRedisSentinelPassword,
component.SystemSecretSystemRedisSecretName,
component.SystemSecretSystemRedisSentinelPasswordFieldName,
"",
},
// ACL
{
&r.options.SystemBackendRedisUsername,
component.SystemSecretSystemRedisSecretName,
component.SystemSecretBackendRedisUsernameFieldName,
"",
},
{
&r.options.SystemBackendRedisPassword,
component.SystemSecretSystemRedisSecretName,
component.SystemSecretBackendRedisPasswordFieldName,
"",
},
{
&r.options.SystemBackendRedisSentinelUsername,
component.SystemSecretSystemRedisSecretName,
component.SystemSecretBackendRedisSentinelUsernameFieldName,
"",
},
{
&r.options.SystemBackendRedisSentinelPassword,
component.SystemSecretSystemRedisSecretName,
component.SystemSecretBackendRedisSentinelPasswordFieldName,
"",
},
// -------
// ACL
{
&r.options.BackendRedisConfigRedisUsername,
component.BackendSecretBackendRedisSecretName,
component.BackendSecretBackendRedisConfigRedisUsernameFieldName,
"",
},
{
&r.options.BackendRedisConfigRedisPassword,
component.BackendSecretBackendRedisSecretName,
component.BackendSecretBackendRedisConfigRedisPasswordFieldName,
"",
},
{
&r.options.BackendRedisConfigRedisSentinelUsername,
component.BackendSecretBackendRedisSecretName,
component.BackendSecretBackendRedisConfigRedisSentinelUsernameFieldName,
"",
},
{
&r.options.BackendRedisConfigRedisSentinelPassword,
component.BackendSecretBackendRedisSecretName,
component.BackendSecretBackendRedisConfigRedisSentinelPasswordFieldName,
"",
},
// ACL
{
&r.options.BackendRedisConfigQueuesUsername,
component.BackendSecretBackendRedisSecretName,
component.BackendSecretBackendRedisConfigQueuesUsernameFieldName,
"",
},
{
&r.options.BackendRedisConfigQueuesPassword,
component.BackendSecretBackendRedisSecretName,
component.BackendSecretBackendRedisConfigQueuesPasswordFieldName,
"",
},
{
&r.options.BackendRedisConfigQueuesSentinelUsername,
component.BackendSecretBackendRedisSecretName,
component.BackendSecretBackendRedisConfigQueuesSentinelUsernameFieldName,
"",
},
{
&r.options.BackendRedisConfigQueuesSentinelPassword,
component.BackendSecretBackendRedisSecretName,
component.BackendSecretBackendRedisConfigQueuesSentinelPasswordFieldName,
"",
},
// -------

}

for _, option := range cases {
Expand Down
5 changes: 5 additions & 0 deletions pkg/3scale/amp/operator/system_options_provider.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -65,6 +65,7 @@ func (s *SystemOptionsProvider) GetSystemOptions() (*component.SystemOptions, er
s.setPriorityClassNames()
s.setTopologySpreadConstraints()
s.setPodTemplateAnnotations()
s.setSentinelIsUsed()

s.options.SideKiqMetrics = true
s.options.AppMetrics = true
Expand Down Expand Up @@ -626,3 +627,7 @@ func (s *SystemOptionsProvider) setPodTemplateAnnotations() {
s.options.AppPodTemplateAnnotations = s.apimanager.Spec.System.AppSpec.Annotations
s.options.SideKiqPodTemplateAnnotations = s.apimanager.Spec.System.SidekiqSpec.Annotations
}

func (s *SystemOptionsProvider) setSentinelIsUsed() {
s.options.RedisSentinelIsUsed = s.apimanager.IsSystemSentinelUsed()
}

0 comments on commit b60047c

Please sign in to comment.