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

Jump to bottom

Subscription concurrency #134

Merged
merged 20 commits into from
Sep 18, 2018
Merged

Subscription concurrency #134

Show file tree
Hide file tree
Changes from 1 commit
Commits
Show all changes
20 commits
Select commit Hold shift + click to select a range
11473c6
Initial concurrent subscription test
slashdotdash Jun 26, 2018
0f99966
Send events to multiple subscribers connected to a single subscription
slashdotdash Jun 26, 2018
a6069af
WIP In-flight subscriber message acknowledgement
slashdotdash Jun 26, 2018
2bf3c6a
Subscription monitors subscribers, terminates when all subscribers down
slashdotdash Jun 27, 2018
dd9c57f
Exclude events filtered by selector function
slashdotdash Jun 27, 2018
3109505
Prevent too many subscribers connecting to a subscription
slashdotdash Jun 27, 2018
0c88470
Subscriber buffer size
slashdotdash Jun 28, 2018
2e5cdd6
Ensure subscription last sent is initialised from last seen
slashdotdash Jun 28, 2018
3b93f2e
Subscription event partitioning
slashdotdash Jun 29, 2018
f087937
Attempt to notify partitioned events ordered by lowest event number
slashdotdash Jun 29, 2018
0cd0ffa
Subscription records `last_sent` for filtered events
slashdotdash Sep 1, 2018
e0e80a7
Request next batch of events when catching up and queue is empty
slashdotdash Sep 2, 2018
a6db11d
Extract subscription tests to test case
slashdotdash Sep 3, 2018
a06bc3e
Delete subscription
slashdotdash Sep 17, 2018
ace4451
Unsubscribe from stream and delete subscription tests
slashdotdash Sep 17, 2018
d971424
Document concurrent subscriptions
slashdotdash Sep 17, 2018
a019183
Acknowledgement of redistributed in-flight events after subscription …
slashdotdash Sep 17, 2018
1225cbf
Include Elixir v1.7.2 in Travis CI configuration
slashdotdash Sep 18, 2018
672c126
Disable logger backends for test environments
slashdotdash Sep 18, 2018
47accab
Fix failing tests on Travis CI
slashdotdash Sep 18, 2018
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
Prev Previous commit
Next Next commit
Include Elixir v1.7.2 in Travis CI configuration 
Include #134 in CHANGELOG.
  • Loading branch information
@slashdotdash
slashdotdash committed Sep 18, 2018
commit 1225cbf518164fb3b8986f3160d861003e94e890
1 change: 1 addition & 0 deletions .travis.yml
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -6,6 +6,7 @@ cache:

elixir:
- 1.6.6
- 1.7.3

otp_release:
- 21.0
Expand Down
1 change: 1 addition & 0 deletions CHANGELOG.md
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -6,6 +6,7 @@

- Add `:socket` and `:socket_dir` config options ([#132](https://github.com/commanded/eventstore/pull/132)).
- Rename `uuid` dependency to `elixir_uuid` ([#135](https://github.com/commanded/eventstore/pull/135)).
- Subscription concurrency ([#134](https://github.com/commanded/eventstore/pull/134)).

## 0.15.1

Expand Down
2 changes: 1 addition & 1 deletion mix.exs
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -55,7 +55,7 @@ defmodule EventStore.Mixfile do
{:dialyxir, "~> 0.5", only: [:dev, :test]},
{:ex_doc, "~> 0.19", only: :dev},
{:markdown, github: "devinus/markdown", only: :dev},
{:mix_test_watch, "~> 0.8", only: :dev},
{:mix_test_watch, "~> 0.9", only: :dev},
{:poison, "~> 2.2 or ~> 3.0 or ~> 4.0", optional: true}
]
end
Expand Down
2 changes: 1 addition & 1 deletion mix.lock
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -17,7 +17,7 @@
"makeup": {:hex, :makeup, "0.5.5", "9e08dfc45280c5684d771ad58159f718a7b5788596099bdfb0284597d368a882", [:mix], [{:nimble_parsec, "~> 0.4", [hex: :nimble_parsec, repo: "hexpm", optional: false]}], "hexpm"},
"makeup_elixir": {:hex, :makeup_elixir, "0.10.0", "0f09c2ddf352887a956d84f8f7e702111122ca32fbbc84c2f0569b8b65cbf7fa", [:mix], [{:makeup, "~> 0.5.5", [hex: :makeup, repo: "hexpm", optional: false]}], "hexpm"},
"markdown": {:git, "https://github.com/devinus/markdown.git", "d065dbcc4e242a85ca2516fdadd0082712871fd8", []},
"mix_test_watch": {:hex, :mix_test_watch, "0.8.0", "acf97da2abc66532e7dc1aa66a5d6c9fc4442d7992d5d7eb4faeaeb964c2580e", [:mix], [{:file_system, "~> 0.2.1 or ~> 0.3", [hex: :file_system, repo: "hexpm", optional: false]}], "hexpm"},
"mix_test_watch": {:hex, :mix_test_watch, "0.9.0", "c72132a6071261893518fa08e121e911c9358713f62794a90c95db59042af375", [:mix], [{:file_system, "~> 0.2.1 or ~> 0.3", [hex: :file_system, repo: "hexpm", optional: false]}], "hexpm"},
"nimble_parsec": {:hex, :nimble_parsec, "0.4.0", "ee261bb53214943679422be70f1658fff573c5d0b0a1ecd0f18738944f818efe", [:mix], [], "hexpm"},
"poison": {:hex, :poison, "4.0.1", "bcb755a16fac91cad79bfe9fc3585bb07b9331e50cfe3420a24bcc2d735709ae", [:mix], [], "hexpm"},
"poolboy": {:hex, :poolboy, "1.5.1", "6b46163901cfd0a1b43d692657ed9d7e599853b3b21b95ae5ae0a777cf9b6ca8", [:rebar], [], "hexpm"},
Expand Down