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.

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

EventStore streaming improvements #205

Merged
merged 1 commit into from
Dec 28, 2023

Conversation

marein
Copy link
Owner

@marein marein commented Dec 28, 2023

  • Dispatch events via PSR-14 event dispatcher so that clients can hook into the lifecycle.
  • Move debug logs to an event listener instead of using a decorator.
  • Add a listener that resets services to avoid possible memory leaks.
  • Encapsulate EventStore dispatcher code in a single class to improve readability.
  • Improve UI by adding boxes and colors.
  • Use a comma-separated list to specify which subscribers to use.
  • Rename argument -w to -p to specify how many events are processed in parallel. Default is now set to 1.

Related adjustments for ForkPool:

  • Use stream_select before reading from a channel to get immediate signal handling.
  • Make each fork a session leader so that only the main process receives SIGINT when the command is interrupted in the terminal.

@marein marein self-assigned this Dec 28, 2023
* Dispatch events via PSR-14 event dispatcher so that
clients can hook into the lifecycle.
* Move debug logs to an event listener instead of using
a decorator.
* Add a listener that resets services to avoid possible
memory leaks.
* Encapsulate EventStore dispatcher code in a single class
to improve readability.
* Improve UI by adding boxes and colors.
* Use a comma-separated list to specify which subscribers
to use.
* Rename argument -w to -p to specify how many events are
processed in parallel. Default is now set to 1.

Related adjustments for ForkPool:
* Use stream_select before reading from a channel to get
immediate signal handling.
* Make each fork a session leader so that only the main process
receives SIGINT when the command is interrupted in the terminal.
@marein marein force-pushed the 79-event-store-streaming-improvements branch from 6b7df7b to 79e8937 Compare December 28, 2023 19:17
@marein marein merged commit 3ad85ee into master Dec 28, 2023
1 check passed
@marein marein deleted the 79-event-store-streaming-improvements branch December 28, 2023 20:33
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
Development

Successfully merging this pull request may close these issues.

1 participant