//////////////////////////////////////////////////////////////////////////////// /// DISCLAIMER /// /// Copyright 2019 ArangoDB GmbH, Cologne, Germany /// /// 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. /// /// Copyright holder is ArangoDB GmbH, Cologne, Germany /// /// @author Simon Grätzer //////////////////////////////////////////////////////////////////////////////// #ifndef ARANGOD_CLUSTER_CLUSTER_TRX_METHODS_H #define ARANGOD_CLUSTER_CLUSTER_TRX_METHODS_H 1 #include "Basics/Common.h" #include "Futures/Future.h" #include "VocBase/LogicalCollection.h" #include "VocBase/voc-types.h" #include namespace arangodb { struct OperationOptions; class TransactionState; namespace ClusterTrxMethods { using arangodb::futures::Future; /// @brief begin a transaction on all followers Future beginTransactionOnLeaders(TransactionState&, std::vector const& leaders); /// @brief commit a transaction on a subordinate Future commitTransaction(transaction::Methods& trx); /// @brief commit a transaction on a subordinate Future abortTransaction(transaction::Methods& trx); /// @brief add the transaction ID header for servers template void addTransactionHeader(transaction::Methods const& trx, ServerID const& server, MapT& headers); /// @brief add transaction ID header for setting up AQL snippets template void addAQLTransactionHeader(transaction::Methods const& trx, ServerID const& server, MapT& headers); /// @brief check whether this is a kind el cheapo transaction bool isElCheapo(transaction::Methods const& trx); bool isElCheapo(TransactionState const& state); } // namespace ClusterTrxMethods } // namespace arangodb #endif