Skip to content

Commit e645348

Browse files
committed
minor: Use ?STORE_ID rather than ?RA_CLUSTER_NAME for projection registration
This is a cosmetic change: `?RA_CLUSTER_NAME` is defined as `?STORE_ID`. `?STORE_ID` is used for other Khepri commands that use the functions in the `khepri` module (for example `get` or `put`) while `?RA_CLUSTER_NAME` is used for commands against the `khepri_cluster` functions.
1 parent d3919de commit e645348

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
@@ -1160,7 +1160,7 @@ register_rabbit_user_permissions_projection() ->
11601160
register_simple_projection(Name, PathPattern, KeyPos) ->
11611161
Options = #{keypos => KeyPos},
11621162
Projection = khepri_projection:new(Name, copy, Options),
1163-
khepri:register_projection(?RA_CLUSTER_NAME, PathPattern, Projection).
1163+
khepri:register_projection(?STORE_ID, PathPattern, Projection).
11641164

11651165
register_rabbit_bindings_projection() ->
11661166
MapFun = fun(_Path, Binding) ->
@@ -1177,7 +1177,7 @@ register_rabbit_bindings_projection() ->
11771177
_Kind = ?KHEPRI_WILDCARD_STAR,
11781178
_DstName = ?KHEPRI_WILDCARD_STAR,
11791179
_RoutingKey = ?KHEPRI_WILDCARD_STAR],
1180-
khepri:register_projection(?RA_CLUSTER_NAME, PathPattern, Projection).
1180+
khepri:register_projection(?STORE_ID, PathPattern, Projection).
11811181

11821182
register_rabbit_index_route_projection() ->
11831183
MapFun = fun(Path, _) ->
@@ -1204,7 +1204,7 @@ register_rabbit_index_route_projection() ->
12041204
_Kind = ?KHEPRI_WILDCARD_STAR,
12051205
_DstName = ?KHEPRI_WILDCARD_STAR,
12061206
_RoutingKey = ?KHEPRI_WILDCARD_STAR],
1207-
khepri:register_projection(?RA_CLUSTER_NAME, PathPattern, Projection).
1207+
khepri:register_projection(?STORE_ID, PathPattern, Projection).
12081208

12091209
%% Routing information is stored in the Khepri store as a `set'.
12101210
%% In order to turn these bindings into records in an ETS `bag', we use a
@@ -1300,7 +1300,7 @@ register_rabbit_topic_graph_projection() ->
13001300
_Kind = ?KHEPRI_WILDCARD_STAR,
13011301
_DstName = ?KHEPRI_WILDCARD_STAR,
13021302
_RoutingKey = ?KHEPRI_WILDCARD_STAR],
1303-
khepri:register_projection(?RA_CLUSTER_NAME, PathPattern, Projection).
1303+
khepri:register_projection(?STORE_ID, PathPattern, Projection).
13041304

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

0 commit comments

Comments
 (0)