QueryChainSync.h

#ifndef CBE__QueryChainSync_h__
#define CBE__QueryChainSync_h__
 
// #include "cbe/QueryResult.h"
#include "cbe/delegate/JoinDelegate.h"
#include "cbe/delegate/QueryJoinDelegate.h"
 
#include "cbe/util/Exception.h"
 
namespace cbe {
class QueryChainSync : public QueryResult {
public:
  ~QueryChainSync();
 
  using JoinException = delegate::JoinDelegate::Exception;
  QueryChainSync join(Container   containerToQuery,
                      std::string key1,
                      std::string key2);
  QueryChainSync join(Container   containerToQuery,
                      std::string key1,
                      std::string key2,
                      Filter      constraints);
  QueryChainSync join(Container   containerToQuery,
                      std::string key1,
                      std::string key2,
                      Container   containerForResults);
  QueryChainSync join(Container   containerToQuery,
                      std::string key1,
                      std::string key2,
                      Filter      constraints,
                      Container   containerForResults);
 
  QueryResult getQueryResult() const;
 
private:
  struct  Impl;
  std::shared_ptr<Impl> pImpl;
 
  friend CloudBackend;
  friend Container;
 
template <class ImplT, typename... QueryAsyncArgsTs>
friend
  QueryChainSync querySync(ImplT& impl,
                      delegate::QueryJoinDelegate::ErrorInfo*  queryJoinError,
                      const char*                               fnName,
                      QueryAsyncArgsTs&&...                     queryAsyncArgs);
  using QueryJoinError = delegate::QueryJoinDelegate::ErrorInfo;
  QueryChainSync(QueryResult&&    queryResult,
                 QueryChain&&     queryChain,
                 QueryJoinError*  errorInfo);
  QueryChainSync(QueryResult&&    queryResult,
                 QueryChain&&     queryChain,
                 const Impl&      impl);
  QueryChainSync(std::size_t  joinCallErrorIndex);
}; // class QueryChainSync
 
 
} // namespace cbe
 
 
#endif // #ifndef CBE__QueryChainSync_h__