-
Notifications
You must be signed in to change notification settings - Fork 1.2k
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
Add replicated storage for remote websocket subscriptions #9311
Conversation
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
In general Ok. @riuvshin wdyt?
ci-test |
ci-test build report: |
ci-test |
ci-test build report: |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
I see no unit tests, is that intentional?
JChannel channel = new JChannel(confFile); | ||
this.lockService = new LockService(channel); | ||
channel.connect(CHANNEL_NAME); | ||
subscriptions = new ReplicatedHashMap<>(channel); |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
looks like we are trying to achieve the consistent state of subscribers in each period of time, and so updates should be performed across the cluster synchronously, to achieve that you can use blocking_updates
property, if we won't need that we can manage local concurrent operations using read/write locks instead of LockService
.
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Makes sense, added.
What does this PR do?
Add JGroups-based replicated storage for remote websocket subscriptions.
What issues does this PR fix or reference?
#9014 (partially)
Release Notes
Added JGroups-based replicated storage for remote websocket subscriptions.
Docs PR
N/A