Skip to content
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

feat: Allow indirect replication #1070

Merged
merged 11 commits into from
Nov 29, 2023
Merged

feat: Allow indirect replication #1070

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
11 commits
Select commit Hold shift + click to select a range
803686a
feat: Allow indirect replication
patriknw Nov 15, 2023
bf40695
javadsl
patriknw Nov 17, 2023
854ea2e
new take, replica ids included in InitReq
patriknw Nov 20, 2023
5b512d7
filter origin also from loadEvent
patriknw Nov 21, 2023
9d26050
feat: RES initial consumer filter
patriknw Nov 17, 2023
c6f523c
test of edge consumer filter
patriknw Nov 21, 2023
72c7578
mima filter
patriknw Nov 29, 2023
e1abef2
add to ConsumerEventStart
patriknw Nov 29, 2023
8d29177
headers
patriknw Nov 29, 2023
c8b0f0f
fix test race condition
patriknw Nov 29, 2023
ff96d7c
trace level needed for test
patriknw Nov 29, 2023
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
16 changes: 15 additions & 1 deletion akka-projection-grpc-tests/src/it/resources/db/default-init.sql
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -136,4 +136,18 @@ CREATE TABLE IF NOT EXISTS akka_projection_timestamp_offset_store_DCC (
-- the consumer lag is timestamp_consumed - timestamp_offset
timestamp_consumed timestamp with time zone NOT NULL,
PRIMARY KEY(slice, projection_name, timestamp_offset, persistence_id, seq_nr)
);
);

CREATE TABLE IF NOT EXISTS akka_projection_timestamp_offset_store_DCD (
projection_name VARCHAR(255) NOT NULL,
projection_key VARCHAR(255) NOT NULL,
slice INT NOT NULL,
persistence_id VARCHAR(255) NOT NULL,
seq_nr BIGINT NOT NULL,
-- timestamp_offset is the db_timestamp of the original event
timestamp_offset timestamp with time zone NOT NULL,
-- timestamp_consumed is when the offset was stored
-- the consumer lag is timestamp_consumed - timestamp_offset
timestamp_consumed timestamp with time zone NOT NULL,
PRIMARY KEY(slice, projection_name, timestamp_offset, persistence_id, seq_nr)
);
Loading