Uploaded image for project: 'Spring Data Geode'
  1. Spring Data Geode
  2. DATAGEODE-256

Explore Reactive extensions and support for applicable Apache Geode capabilities.

    XMLWordPrintable

    Details

      Description

      This is a R&D task to explore possible Reactive extensions and support for applicable Apache Geode capabilities.

      Initially, this JIRA ticket was opened to explore whether it was possible to...

      Implement the Reactive Streams API for Aapche Geode CQ Support.

      For example, Pivotal GemFire's [Continuous Query
      (CQ)|http://gemfire.docs.pivotal.io/latest/userguide/index.html#developing/continuous_querying/chapter_overview.html] would be a good fit to implement the Reactive Streams API, using Reactor or RxJava backed by CQs, and wrapping a CQ Listener with Reactive types (e.g. Flux).

      I also think it makes sense to explore additional Apache Geode features and capabilities that may be possible to wrap with a Reactive API (i.e. Reactive types and Reactive behavior (where possible)), including, but not necessarily limited to:

      1. AEQ (Listener)
      2. CQ
      3. Function Execution (by first adding support for Streaming Results)
      4. From Repositories
      5. Etc.

      Function Executions is perhaps less apparent in its path to Reactive, but if there were a fire-and-forget (i.e. async) method to invoke a Function, then it would be possible to execute a Function in a Reactive context. I think wrapping the ResultCollector would give you that async/Reactive-like behavior. Additionally, a StreamResultCollector implementation could be wrapped with a Flux.

      Additional thoughts and ideas will be added in comments.

        Attachments

          Activity

            People

            Assignee:
            jblum John Blum
            Reporter:
            jblum John Blum
            Last updater:
            John Blum
            Votes:
            0 Vote for this issue
            Watchers:
            1 Start watching this issue

              Dates

              Created:
              Updated: