Skip to content

DRAFT: dmx using khepri and RA #253

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Closed
wants to merge 18 commits into from
Closed

DRAFT: dmx using khepri and RA #253

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
18 commits
Select commit Hold shift + click to select a range
f33eade
wip
SimonUnge Sep 25, 2023
7607fee
wip
SimonUnge Sep 28, 2023
18daf44
wip
SimonUnge Sep 29, 2023
dbf3e63
wip
SimonUnge Oct 4, 2023
a0a214b
wip
SimonUnge Oct 13, 2023
391b7a5
wip: some more
SimonUnge Oct 24, 2023
a6bc453
Supervise the bookie server
SimonUnge Oct 24, 2023
8192976
Add stupid state
SimonUnge Oct 25, 2023
cd82a29
Create a stream on startup
SimonUnge Nov 16, 2023
0405514
wip
SimonUnge Dec 20, 2023
6eedfc4
wip
SimonUnge Dec 20, 2023
e9869f9
streamer reader
SimonUnge Jan 18, 2024
6812927
Fixes mc get_annotation call
SimonUnge Jan 22, 2024
539e31f
race condition temp fix
SimonUnge Jan 23, 2024
b63a31d
only use stream
SimonUnge Jan 23, 2024
5bfdf11
Code cleanup, remove ra machine logic
SimonUnge Jan 23, 2024
4934ffe
Fixes
SimonUnge Jan 25, 2024
10ad1d0
max age
SimonUnge Jan 26, 2024
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
4 changes: 4 additions & 0 deletions BUILD.bazel
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -107,6 +107,8 @@ erlang_app(
license_files = [":license_files"],
priv = [":priv"],
deps = [
"@khepri//:erlang_app",
"@ra//:erlang_app",
"@rabbitmq-server//deps/rabbit:erlang_app",
"@rabbitmq-server//deps/rabbit_common:erlang_app",
],
Expand All @@ -127,6 +129,8 @@ test_erlang_app(
license_files = [":license_files"],
priv = [":priv"],
deps = [
"@khepri//:erlang_app",
"@ra//:erlang_app",
"@rabbitmq-server//deps/rabbit:erlang_app",
"@rabbitmq-server//deps/rabbit_common:erlang_app",
],
Expand Down
10 changes: 7 additions & 3 deletions Makefile
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -2,10 +2,10 @@ PROJECT = rabbitmq_delayed_message_exchange
PROJECT_DESCRIPTION = RabbitMQ Delayed Message Exchange
PROJECT_MOD = rabbit_delayed_message_app

RABBITMQ_VERSION ?= v3.10.x
RABBITMQ_VERSION ?= main

define PROJECT_APP_EXTRA_KEYS
{broker_version_requirements, ["3.10.0"]}
{broker_version_requirements, ["3.13.0"]}
endef

dep_amqp_client = git_rmq-subfolder rabbitmq-erlang-client $(RABBITMQ_VERSION)
Expand All @@ -14,7 +14,11 @@ dep_rabbit = git_rmq-subfolder rabbitmq-server $(RABBITMQ_VE
dep_rabbitmq_ct_client_helpers = git_rmq-subfolder rabbitmq-ct-client-helpers $(RABBITMQ_VERSION)
dep_rabbitmq_ct_helpers = git_rmq-subfolder rabbitmq-ct-helpers $(RABBITMQ_VERSION)

DEPS = rabbit_common rabbit
dep_khepri = git https://github.com/rabbitmq/khepri.git main
dep_leveldb = git git@github.com:martinsumner/leveled.git
dep_lz4 = git git@github.com:martinsumner/erlang-lz4.git

DEPS = rabbit_common rabbit khepri leveldb lz4
TEST_DEPS = ct_helper rabbitmq_ct_helpers rabbitmq_ct_client_helpers amqp_client
dep_ct_helper = git https://github.com/extend/ct_helper.git master

Expand Down
13 changes: 11 additions & 2 deletions app.bzl
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -7,6 +7,9 @@ def all_srcs(name = "all_srcs"):
srcs = [
"src/rabbit_delayed_message.erl",
"src/rabbit_delayed_message_app.erl",
"src/rabbit_delayed_message_khepri.erl",
"src/rabbit_delayed_message_kv_store.erl",
"src/rabbit_delayed_message_machine.erl",
"src/rabbit_delayed_message_sup.erl",
"src/rabbit_delayed_message_utils.erl",
"src/rabbit_exchange_type_delayed_message.erl",
Expand Down Expand Up @@ -39,6 +42,9 @@ def all_beam_files(name = "all_beam_files"):
srcs = [
"src/rabbit_delayed_message.erl",
"src/rabbit_delayed_message_app.erl",
"src/rabbit_delayed_message_khepri.erl",
"src/rabbit_delayed_message_kv_store.erl",
"src/rabbit_delayed_message_machine.erl",
"src/rabbit_delayed_message_sup.erl",
"src/rabbit_delayed_message_utils.erl",
"src/rabbit_exchange_type_delayed_message.erl",
Expand All @@ -47,7 +53,7 @@ def all_beam_files(name = "all_beam_files"):
app_name = "rabbitmq_delayed_message_exchange",
dest = "ebin",
erlc_opts = "//:erlc_opts",
deps = ["@rabbitmq-server//deps/rabbit:erlang_app", "@rabbitmq-server//deps/rabbit_common:erlang_app"],
deps = ["@khepri//:erlang_app", "@ra//:erlang_app", "@rabbitmq-server//deps/rabbit:erlang_app", "@rabbitmq-server//deps/rabbit_common:erlang_app"],
)
filegroup(
name = "beam_files",
Expand All @@ -61,6 +67,9 @@ def all_test_beam_files(name = "all_test_beam_files"):
srcs = [
"src/rabbit_delayed_message.erl",
"src/rabbit_delayed_message_app.erl",
"src/rabbit_delayed_message_khepri.erl",
"src/rabbit_delayed_message_kv_store.erl",
"src/rabbit_delayed_message_machine.erl",
"src/rabbit_delayed_message_sup.erl",
"src/rabbit_delayed_message_utils.erl",
"src/rabbit_exchange_type_delayed_message.erl",
Expand All @@ -69,7 +78,7 @@ def all_test_beam_files(name = "all_test_beam_files"):
app_name = "rabbitmq_delayed_message_exchange",
dest = "test",
erlc_opts = "//:test_erlc_opts",
deps = ["@rabbitmq-server//deps/rabbit:erlang_app", "@rabbitmq-server//deps/rabbit_common:erlang_app"],
deps = ["@khepri//:erlang_app", "@ra//:erlang_app", "@rabbitmq-server//deps/rabbit:erlang_app", "@rabbitmq-server//deps/rabbit_common:erlang_app"],
)
filegroup(
name = "test_beam_files",
Expand Down
Loading