Skip to content

Commit 06337f2

Browse files
committed
rabbit_khepri: Use ?STORE_ID for projection registration functions
This is a cosmetic change. `?RA_CLUSTER_NAME` is equivalent but is used for clustering commands. Commands sent via the `khepri`/`khepri_adv` APIs consistently use the `?STORE_ID` macro instead.
1 parent d40948f commit 06337f2

File tree

1 file changed

+4
-4
lines changed

1 file changed

+4
-4
lines changed

deps/rabbit/src/rabbit_khepri.erl

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -1164,7 +1164,7 @@ register_rabbit_user_permissions_projection() ->
11641164
register_simple_projection(Name, PathPattern, KeyPos) ->
11651165
Options = #{keypos => KeyPos},
11661166
Projection = khepri_projection:new(Name, copy, Options),
1167-
khepri:register_projection(?RA_CLUSTER_NAME, PathPattern, Projection).
1167+
khepri:register_projection(?STORE_ID, PathPattern, Projection).
11681168

11691169
register_rabbit_bindings_projection() ->
11701170
MapFun = fun(_Path, Binding) ->
@@ -1180,7 +1180,7 @@ register_rabbit_bindings_projection() ->
11801180
_Kind = ?KHEPRI_WILDCARD_STAR,
11811181
_DstName = ?KHEPRI_WILDCARD_STAR,
11821182
_RoutingKey = ?KHEPRI_WILDCARD_STAR),
1183-
khepri:register_projection(?RA_CLUSTER_NAME, PathPattern, Projection).
1183+
khepri:register_projection(?STORE_ID, PathPattern, Projection).
11841184

11851185
register_rabbit_index_route_projection() ->
11861186
MapFun = fun(Path, _) ->
@@ -1211,7 +1211,7 @@ register_rabbit_index_route_projection() ->
12111211
_Kind = ?KHEPRI_WILDCARD_STAR,
12121212
_DstName = ?KHEPRI_WILDCARD_STAR,
12131213
_RoutingKey = ?KHEPRI_WILDCARD_STAR),
1214-
khepri:register_projection(?RA_CLUSTER_NAME, PathPattern, Projection).
1214+
khepri:register_projection(?STORE_ID, PathPattern, Projection).
12151215

12161216
%% Routing information is stored in the Khepri store as a `set'.
12171217
%% In order to turn these bindings into records in an ETS `bag', we use a
@@ -1311,7 +1311,7 @@ register_rabbit_topic_graph_projection() ->
13111311
_Kind = ?KHEPRI_WILDCARD_STAR,
13121312
_DstName = ?KHEPRI_WILDCARD_STAR,
13131313
_RoutingKey = ?KHEPRI_WILDCARD_STAR),
1314-
khepri:register_projection(?RA_CLUSTER_NAME, PathPattern, Projection).
1314+
khepri:register_projection(?STORE_ID, PathPattern, Projection).
13151315

13161316
-spec follow_down_update(Table, Exchange, Words, UpdateFn) -> Ret when
13171317
Table :: ets:tid(),

0 commit comments

Comments
 (0)