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

QueryingSubscriber (to receive past publications) #102

Closed
JEnoch opened this issue Jun 17, 2021 · 1 comment
Closed

QueryingSubscriber (to receive past publications) #102

JEnoch opened this issue Jun 17, 2021 · 1 comment

Comments

@JEnoch
Copy link
Member

JEnoch commented Jun 17, 2021

Some use cases require a Subscriber to also receive the data that have been published before its creation.

Using the zenoh primitives, this can be done with a "QueryingSubscriber" that would:

  • do a query at start-up to retrieve the historical data
  • declare the subscription at the same time to receive live publications, but not delivering those to the user for now
  • merge the query results and the live data into a same queue, filtering duplicates and ordering by timestamps
  • deliver the content of this queue to the user
  • finally, go on delivering live publications to the user

The queryable storing the past publications and replying to the query could be implemented in different ways:

  • a zenoh storage deployed in a zenoh router
  • or a "publication cache" colocalized with the publisher (to support peer-to-peer use cases without any router)
@JEnoch JEnoch changed the title QueryingSubscriber (to also receive past publications) QueryingSubscriber (to receive past publications) Jun 17, 2021
@JEnoch
Copy link
Member Author

JEnoch commented Jun 28, 2021

Implemented in zenoh-net API.
An implementation in zenoh API will come later.

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

No branches or pull requests

1 participant