Skip to content

Commit a15d198

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 1b72c64 commit a15d198

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
@@ -1179,7 +1179,7 @@ register_rabbit_user_permissions_projection() ->
11791179
register_simple_projection(Name, PathPattern, KeyPos) ->
11801180
Options = #{keypos => KeyPos},
11811181
Projection = khepri_projection:new(Name, copy, Options),
1182-
khepri:register_projection(?RA_CLUSTER_NAME, PathPattern, Projection).
1182+
khepri:register_projection(?STORE_ID, PathPattern, Projection).
11831183

11841184
register_rabbit_bindings_projection() ->
11851185
MapFun = fun(_Path, Binding) ->
@@ -1195,7 +1195,7 @@ register_rabbit_bindings_projection() ->
11951195
_Kind = ?KHEPRI_WILDCARD_STAR,
11961196
_DstName = ?KHEPRI_WILDCARD_STAR,
11971197
_RoutingKey = ?KHEPRI_WILDCARD_STAR),
1198-
khepri:register_projection(?RA_CLUSTER_NAME, PathPattern, Projection).
1198+
khepri:register_projection(?STORE_ID, PathPattern, Projection).
11991199

12001200
register_rabbit_index_route_projection() ->
12011201
MapFun = fun(Path, _) ->
@@ -1226,7 +1226,7 @@ register_rabbit_index_route_projection() ->
12261226
_Kind = ?KHEPRI_WILDCARD_STAR,
12271227
_DstName = ?KHEPRI_WILDCARD_STAR,
12281228
_RoutingKey = ?KHEPRI_WILDCARD_STAR),
1229-
khepri:register_projection(?RA_CLUSTER_NAME, PathPattern, Projection).
1229+
khepri:register_projection(?STORE_ID, PathPattern, Projection).
12301230

12311231
%% Routing information is stored in the Khepri store as a `set'.
12321232
%% In order to turn these bindings into records in an ETS `bag', we use a
@@ -1326,7 +1326,7 @@ register_rabbit_topic_graph_projection() ->
13261326
_Kind = ?KHEPRI_WILDCARD_STAR,
13271327
_DstName = ?KHEPRI_WILDCARD_STAR,
13281328
_RoutingKey = ?KHEPRI_WILDCARD_STAR),
1329-
khepri:register_projection(?RA_CLUSTER_NAME, PathPattern, Projection).
1329+
khepri:register_projection(?STORE_ID, PathPattern, Projection).
13301330

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

0 commit comments

Comments
 (0)