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

Distributed pub sub for typed #26338

Closed
johanandren opened this issue Feb 6, 2019 · 1 comment
Closed

Distributed pub sub for typed #26338

johanandren opened this issue Feb 6, 2019 · 1 comment
Assignees
Labels
3 - in progress Someone is working on this ticket t:cluster-tools t:typed
Milestone

Comments

@johanandren
Copy link
Member

The receptionist allows something like distributed pub sub by seing the receptionist registration as a subscription to a topic, it does however not do deduplication, when there are multiple "subscribers" on one node a message for that "topic" will go to all of them.

Could it be worth it to introduce an inbetween-topic-actor that does what distributed pub sub does for a single topic (registering to the receptionist when there are any subscribers, forwarding incoming messages to the subscribers).

@johanandren johanandren added t:cluster-tools 0 - new Ticket is unclear on it's purpose or if it is valid or not t:typed labels Feb 6, 2019
@patriknw patriknw added 1 - triaged Tickets that are safe to pick up for contributing in terms of likeliness of being accepted and removed 0 - new Ticket is unclear on it's purpose or if it is valid or not labels Jun 16, 2019
@chbatey
Copy link
Member

chbatey commented Nov 15, 2019

Descoping typed pubsub compared to untyped, what's left:

  • Service key describing the topic
  • An single topic-actor running on each node (that should take part in the pub-sub) that handles subscriptions to topics and sending to all the other topic-actors that have subscribed to the topic
  • actors taking part in pub-sub registers locally to the topic actor
  • Depends on de-register as agent should de-register when there are no local subscribers for the topic (in progress) Receptionist: support for actor de-registration  #28123
  • Can use the group router internally for sending to get that logic "for free"

@chbatey chbatey assigned chbatey, helena and johanandren and unassigned chbatey Nov 15, 2019
@helena helena added 3 - in progress Someone is working on this ticket and removed 3 - in progress Someone is working on this ticket labels Nov 20, 2019
@johanandren johanandren added 3 - in progress Someone is working on this ticket and removed 1 - triaged Tickets that are safe to pick up for contributing in terms of likeliness of being accepted labels Feb 19, 2020
@helena helena removed their assignment Feb 25, 2020
@chbatey chbatey added this to the 2.6.4 milestone Mar 10, 2020
@chbatey chbatey closed this as completed Mar 10, 2020
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
3 - in progress Someone is working on this ticket t:cluster-tools t:typed
Projects
None yet
Development

No branches or pull requests

4 participants