1 files changed, 74 insertions, 0 deletions
diff --git a/src/include/taler_merchantdb_plugin.h b/src/include/taler_merchantdb_plugin.h
index f8ac0eaf..d5c4e9b1 100644
--- a/src/include/taler_merchantdb_plugin.h
+++ b/src/include/taler_merchantdb_plugin.h
@@ -717,6 +717,64 @@ struct TALER_MERCHANTDB_Plugin
   (*create_tables) (void *cls);
 
   /**
+   * Register callback to be invoked on events of type @a es.
+   *
+   * Unlike many other calls, this function is thread-safe
+   * and may be called from threads that are different
+   * from the one that setup @a db. However, the @a cb
+   * will always be called from the thread that runs
+   * #GNUNET_PQ_event_do_poll() or the GNUnet scheduler.
+   *
+   * @param db database context to use
+   * @param es specification of the event to listen for
+   * @param cb function to call when the event happens, possibly
+   *         multiple times (until #GNUNET_PQ_event_listen_cancel() is invoked)
+   * @param cb_cls closure for @a cb
+   * @return handle useful to cancel the listener
+   */
+  struct GNUNET_DB_EventHandler *
+  (*event_listen)(void *cls,
+                  const struct GNUNET_DB_EventHeaderP *es,
+                  GNUNET_DB_EventCallback cb,
+                  void *cb_cls);
+
+  /**
+   * Stop notifications.
+   *
+   * Unlike many other calls, this function is thread-safe
+   * and may be called from threads that are different
+   * from the one that setup @a db. However, the @a cb
+   * will always be called from the thread that runs
+   * #GNUNET_PQ_event_do_poll() or the GNUnet scheduler.
+   *
+   * @param eh handle to unregister.
+   */
+  void
+  (*event_listen_cancel)(struct GNUNET_DB_EventHandler *eh);
+
+
+  /**
+   * Notify all that listen on @a es of an event.
+   *
+   * Unlike many other calls, this function is thread-safe
+   * and may be called from threads that are different
+   * from the one that setup @a db. However, the @a cb
+   * will always be called from the thread that runs
+   * #GNUNET_PQ_event_do_poll() or the GNUnet scheduler.
+   *
+   * @param db database context to use
+   * @param es specification of the event to generate
+   * @param extra additional event data provided
+   * @param extra_size number of bytes in @a extra
+   */
+  void
+  (*event_notify)(void *cls,
+                  const struct GNUNET_DB_EventHeaderP *es,
+                  const void *extra,
+                  size_t extra_size);
+
+
+  /**
    * Do a pre-flight check that we are not in an uncommitted transaction.  If
    * we are, die.  Does not return anything, as we will continue regardless of
    * the outcome.
@@ -783,6 +841,22 @@ struct TALER_MERCHANTDB_Plugin
                       void *cb_cls);
 
   /**
+   * Lookup one of the instances this backend has configured.
+   *
+   * @param cls closure
+   * @param id ID of instance to look up
+   * @param active_only only find 'active' instances
+   * @param cb function to call on all instances found
+   * @param cb_cls closure for @a cb
+   */
+  enum GNUNET_DB_QueryStatus
+  (*lookup_instance)(void *cls,
+                     const char *id,
+                     bool active_only,
+                     TALER_MERCHANTDB_InstanceCallback cb,
+                     void *cb_cls);
+
+  /**
    * Lookup authentication data of an instance.
    *
    * @param cls closure