diff --git a/deps/rabbit/priv/schema/rabbit.schema b/deps/rabbit/priv/schema/rabbit.schema index 1b4d43593ce..e6017f23f2a 100644 --- a/deps/rabbit/priv/schema/rabbit.schema +++ b/deps/rabbit/priv/schema/rabbit.schema @@ -2776,6 +2776,19 @@ fun(Conf) -> end end}. +{mapping, "stream.data_dir", "osiris.data_dir", [ + {datatype, string} +]}. + +{translation, "osiris.data_dir", + fun(Conf) -> + case cuttlefish:conf_get("stream.data_dir", Conf, undefined) of + undefined -> cuttlefish:unset(); + Val -> Val + end + end +}. + {mapping, "stream.read_ahead", "rabbit.stream_read_ahead", [{datatype, {enum, [true, false]}}]}. diff --git a/deps/rabbit/test/config_schema_SUITE_data/rabbit.snippets b/deps/rabbit/test/config_schema_SUITE_data/rabbit.snippets index dc214a17076..a68868e4631 100644 --- a/deps/rabbit/test/config_schema_SUITE_data/rabbit.snippets +++ b/deps/rabbit/test/config_schema_SUITE_data/rabbit.snippets @@ -1253,6 +1253,16 @@ credential_validator.regexp = ^abc\\d+", [{rabbit, [ {stream_read_ahead, false} ]}], + []}, + + %% + %% Stream data dir + %% + {stream_data_dir, + "stream.data_dir = /data/rabbitmq/stream", + [{osiris, [ + {data_dir, "/data/rabbitmq/stream"} + ]}], []} ].