feast-dev
diff --git a/‎infra/terraform/aws/helm.tf‎
Lines changed: 1 addition & 0 deletions b/‎infra/terraform/aws/helm.tf‎
Lines changed: 1 addition & 0 deletions
diff --git a/‎protos/feast/core/Store.proto‎
Lines changed: 2 additions & 0 deletions b/‎protos/feast/core/Store.proto‎
Lines changed: 2 additions & 0 deletions
diff --git a/‎storage/connectors/redis/src/main/java/feast/storage/connectors/redis/retriever/RedisClient.java‎
Lines changed: 7 additions & 3 deletions b/‎storage/connectors/redis/src/main/java/feast/storage/connectors/redis/retriever/RedisClient.java‎
Lines changed: 7 additions & 3 deletions
@@ -62,6 +62,7 @@ locals {
               config = {
                 host = module.redis.endpoint
                 port = 6379
+                ssl  = true
               }
               subscriptions = [
                 {
 
@@ -110,6 +110,8 @@ message Store {
     int32 max_retries = 4;
     // Optional. How often flush data to redis
     int32 flush_frequency_seconds = 5;
+    // Optional. Connect over SSL.
+    bool ssl = 6;
   }
 
   message BigQueryConfig {
 
@@ -47,10 +47,14 @@ private RedisClient(StatefulRedisConnection<byte[], byte[]> connection) {
   }
 
   public static RedisClientAdapter create(Map<String, String> config) {
+
+    RedisURI uri = RedisURI.create(config.get("host"), Integer.parseInt(config.get("port")));
+
+    if (Boolean.parseBoolean(config.get("ssl"))) {
+      uri.setSsl(true);
+    }
     StatefulRedisConnection<byte[], byte[]> connection =
-        io.lettuce.core.RedisClient.create(
-                RedisURI.create(config.get("host"), Integer.parseInt(config.get("port"))))
-            .connect(new ByteArrayCodec());
+        io.lettuce.core.RedisClient.create(uri).connect(new ByteArrayCodec());
 
     return new RedisClient(connection);
   }
Original file line number	Diff line number	Diff line change
`@@ -62,6 +62,7 @@ locals {`
`62`	`62`	`config = {`
`63`	`63`	`host = module.redis.endpoint`
`64`	`64`	`port = 6379`
	`65`	`+ ssl = true`
`65`	`66`	`}`
`66`	`67`	`subscriptions = [`
`67`	`68`	`{`
Original file line number	Diff line number	Diff line change
`@@ -110,6 +110,8 @@ message Store {`
`110`	`110`	`int32 max_retries = 4;`
`111`	`111`	`// Optional. How often flush data to redis`
`112`	`112`	`int32 flush_frequency_seconds = 5;`
	`113`	`+ // Optional. Connect over SSL.`
	`114`	`+ bool ssl = 6;`
`113`	`115`	`}`
`114`	`116`
`115`	`117`	`message BigQueryConfig {`