From cbd3b8ccb3e08e04b5e5de63b2040543ae06a552 Mon Sep 17 00:00:00 2001 From: William Will <10997562+willwill96@users.noreply.github.com> Date: Fri, 8 Aug 2025 11:29:49 -0600 Subject: [PATCH] rename alpha option to be more explicit --- pkg/apis/options/alpha_options.go | 6 +++--- pkg/apis/options/aws_iam.go | 2 +- pkg/apis/options/sessions.go | 2 +- pkg/sessions/redis/redis_store_test.go | 4 +--- 4 files changed, 6 insertions(+), 8 deletions(-) diff --git a/pkg/apis/options/alpha_options.go b/pkg/apis/options/alpha_options.go index b40d650b..44a60b26 100644 --- a/pkg/apis/options/alpha_options.go +++ b/pkg/apis/options/alpha_options.go @@ -47,7 +47,7 @@ type AlphaOptions struct { Providers Providers `json:"providers,omitempty"` // AWS IAM Options is used to configure IAM authentication for your redis instance. - AWSIAMOptions *AWSIAMOptions `json:"awsIAM,omitempty"` + redisSessionAWSIAMConfig *AWSIAMConfig `json:"redisSessionAWSIAMConfig,omitempty"` } // MergeInto replaces alpha options in the Options struct with the values @@ -59,7 +59,7 @@ func (a *AlphaOptions) MergeInto(opts *Options) { opts.Server = a.Server opts.MetricsServer = a.MetricsServer opts.Providers = a.Providers - opts.Session.Redis.AWSIAMConfig = a.AWSIAMOptions + opts.Session.Redis.AWSIAMConfig = a.redisSessionAWSIAMConfig } // ExtractFrom populates the fields in the AlphaOptions with the values from @@ -71,5 +71,5 @@ func (a *AlphaOptions) ExtractFrom(opts *Options) { a.Server = opts.Server a.MetricsServer = opts.MetricsServer a.Providers = opts.Providers - a.AWSIAMOptions = opts.Session.Redis.AWSIAMConfig + a.redisSessionAWSIAMConfig = opts.Session.Redis.AWSIAMConfig } diff --git a/pkg/apis/options/aws_iam.go b/pkg/apis/options/aws_iam.go index 01093b45..54743a28 100644 --- a/pkg/apis/options/aws_iam.go +++ b/pkg/apis/options/aws_iam.go @@ -1,6 +1,6 @@ package options -type AWSIAMOptions struct { +type AWSIAMConfig struct { // AWS service redis service being used. "elasticache" or "memorydb" ServiceName string `json:"serviceName,omitempty` // AWS Cluster name diff --git a/pkg/apis/options/sessions.go b/pkg/apis/options/sessions.go index 4fd8d59f..80f0050c 100644 --- a/pkg/apis/options/sessions.go +++ b/pkg/apis/options/sessions.go @@ -34,7 +34,7 @@ type RedisStoreOptions struct { CAPath string `flag:"redis-ca-path" cfg:"redis_ca_path"` InsecureSkipTLSVerify bool `flag:"redis-insecure-skip-tls-verify" cfg:"redis_insecure_skip_tls_verify"` IdleTimeout int `flag:"redis-connection-idle-timeout" cfg:"redis_connection_idle_timeout"` - AWSIAMConfig *AWSIAMOptions `cfg:",internal"` + AWSIAMConfig *AWSIAMConfig `cfg:",internal"` } func sessionOptionsDefaults() SessionOptions { diff --git a/pkg/sessions/redis/redis_store_test.go b/pkg/sessions/redis/redis_store_test.go index 6edd5b2e..26044317 100644 --- a/pkg/sessions/redis/redis_store_test.go +++ b/pkg/sessions/redis/redis_store_test.go @@ -288,10 +288,8 @@ var _ = Describe("Redis SessionStore Tests", func() { opt = &redis.Options{} err := setupAWSIAMAuth(redisOpts, opt) - Expect(err).ToNot(HaveOccurred()) Expect(opt.CredentialsProvider).ToNot(BeNil()) - // Verify the CredentialsProvider returns the expected username username, _ := opt.CredentialsProvider() Expect(username).To(Equal("test-user")) }) @@ -304,7 +302,7 @@ var _ = Describe("Redis SessionStore Tests", func() { opt = &redis.Options{} err := setupAWSIAMAuth(redisOpts, opt) - Expect(err).ToNot(HaveOccurred()) + Expect(opt.CredentialsProvider).To(BeNil()) }) })