Skip to content

Commit a40b3a4

Browse files
fix: wire Redis TLS into segmentUserPersister's redis client
1 parent c78800e commit a40b3a4

1 file changed

Lines changed: 13 additions & 0 deletions

File tree

pkg/subscriber/processor/segment_user_persister.go

Lines changed: 13 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -63,6 +63,12 @@ type segmentUserPersisterConfig struct {
6363
RedisPartitionCount int `json:"redisPartitionCount"` // Redis partition count
6464
RedisMode string `json:"redisMode"` // Redis client mode: cluster, standalone, or auto
6565
Project string `json:"project"` // Google Cloud project ID
66+
// Redis TLS configuration
67+
RedisTLSEnabled bool `json:"redisTLSEnabled"`
68+
RedisTLSCACert string `json:"redisTLSCACert"`
69+
RedisTLSCert string `json:"redisTLSCert"`
70+
RedisTLSKey string `json:"redisTLSKey"`
71+
RedisTLSInsecureSkipVerify bool `json:"redisTLSInsecureSkipVerify"`
6672
}
6773

6874
type segmentUserPersister struct {
@@ -203,6 +209,13 @@ func createRedisClientForSegmentPersister(
203209
v3.WithRedisMode(redisMode),
204210
v3.WithMetrics(registerer),
205211
v3.WithLogger(logger),
212+
v3.WithTLS(v3.TLSConfig{
213+
Enabled: conf.RedisTLSEnabled,
214+
CACert: conf.RedisTLSCACert,
215+
Cert: conf.RedisTLSCert,
216+
Key: conf.RedisTLSKey,
217+
InsecureSkipVerify: conf.RedisTLSInsecureSkipVerify,
218+
}),
206219
)
207220
}
208221

0 commit comments

Comments
 (0)