⚙️ DEFAULT_MAX_STORAGE_MB

Author: RTLS

config/runtime.exs

@@ -215,7 +215,7 @@ if config_env() == :prod and self_hosted do
     release_version: System.get_env("RELEASE_VERSION"),
     backfill_max_pending_messages: backfill_max_pending_messages,
     max_memory_bytes: ConfigParser.max_memory_bytes(env_vars),
-    max_storage_bytes: ConfigParser.max_storage_bytes(env_vars)
+    default_max_storage_bytes: ConfigParser.default_max_storage_bytes(env_vars)
 end
 
 if config_env() == :prod and not self_hosted do

lib/sequin/config_parser.ex

@@ -130,8 +130,8 @@ defmodule Sequin.ConfigParser do
     end
   end
 
-  def max_storage_bytes(env) do
-    case env["MAX_STORAGE_MB"] do
+  def default_max_storage_bytes(env) do
+    case env["DEFAULT_MAX_STORAGE_MB"] do
       nil ->
         nil
 

lib/sequin/consumers/sink_consumer.ex

@@ -335,7 +335,7 @@ defmodule Sequin.Consumers.SinkConsumer do
   def preload_http_endpoint(consumer), do: consumer
 
   defp default_max_storage_mb do
-    case Application.get_env(:sequin, :max_storage_bytes) do
+    case Application.get_env(:sequin, :default_max_storage_bytes) do
       nil -> nil
       bytes -> round(bytes / 1024 / 1024)
     end