async_attempt_context.hxx

Go to the documentation of this file.

/*
 *     Copyright 2021-Present Couchbase, Inc.
 *
 *   Licensed under the Apache License, Version 2.0 (the "License");
 *   you may not use this file except in compliance with the License.
 *   You may obtain a copy of the License at
 *
 *       http://www.apache.org/licenses/LICENSE-2.0
 *
 *   Unless required by applicable law or agreed to in writing, software
 *   distributed under the License is distributed on an "AS IS" BASIS,
 *   WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 *   See the License for the specific language governing permissions and
 *   limitations under the License.
 */
#pragma once
 
#include <couchbase/transactions/transaction_get_result.hxx>
#include <couchbase/transactions/transaction_query_options.hxx>
#include <couchbase/transactions/transaction_query_result.hxx>
 
namespace couchbase
{
class collection;
class scope;
 
namespace transactions
{
using async_result_handler = std::function<void(error, transaction_get_result)>;
using async_query_handler = std::function<void(error, transaction_query_result)>;
using async_err_handler = std::function<void(error)>;
 
class async_attempt_context
{
 
public:
  virtual void get(const collection& coll, std::string id, async_result_handler&& handler) = 0;
 
  virtual void get_replica_from_preferred_server_group(const couchbase::collection& coll,
                                                       const std::string& id,
                                                       async_result_handler&& handler) = 0;
 
  virtual void remove(transaction_get_result doc, async_err_handler&& handler) = 0;
 
  template<typename Transcoder = codec::default_json_transcoder,
           typename Document,
           std::enable_if_t<!std::is_same_v<codec::encoded_value, Document>, bool> = true>
  void insert(const collection& coll,
              std::string id,
              Document&& content,
              async_result_handler&& handler)
  {
    return insert_raw(coll, id, Transcoder::encode(content), std::move(handler));
  }
  template<typename Transcoder = codec::default_json_transcoder,
           typename Document,
           std::enable_if_t<!std::is_same_v<codec::encoded_value, Document>, bool> = true>
  void replace(transaction_get_result doc, Document&& content, async_result_handler&& handler)
  {
    return replace_raw(std::move(doc), Transcoder::encode(content), std::move(handler));
  }
  void query(const scope& scope,
             std::string statement,
             transaction_query_options opts,
             async_query_handler&& handler);
 
  void query(std::string statement, transaction_query_options opts, async_query_handler&& handler)
  {
    return query(std::move(statement), std::move(opts), {}, std::move(handler));
  };
  void query(std::string statement, async_query_handler&& handler)
  {
    return query(std::move(statement), {}, std::move(handler));
  }
 
  virtual ~async_attempt_context() = default;
 
protected:
  virtual void insert_raw(const collection& coll,
                          std::string id,
                          codec::encoded_value content,
                          async_result_handler&& handler) = 0;
  virtual void replace_raw(transaction_get_result doc,
                           codec::encoded_value content,
                           async_result_handler&& handler) = 0;
  virtual void query(std::string statement,
                     transaction_query_options opts,
                     std::optional<std::string> query_context,
                     async_query_handler&&) = 0;
};
} // namespace transactions
} // namespace couchbase