transactions_cleanup_config.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_keyspace.hxx>
 
#include <chrono>
#include <list>
 
namespace couchbase::transactions
{
class transactions_cleanup_config
{
public:
  auto cleanup_lost_attempts(bool value) -> transactions_cleanup_config&
  {
    cleanup_lost_attempts_ = value;
    return *this;
  }

  [[nodiscard]] auto cleanup_lost_attempts() const -> bool
  {
    return cleanup_lost_attempts_;
  }

  auto cleanup_client_attempts(bool value) -> transactions_cleanup_config&
  {
    cleanup_client_attempts_ = value;
    return *this;
  }

  [[nodiscard]] auto cleanup_client_attempts() const -> bool
  {
    return cleanup_client_attempts_;
  }

  [[nodiscard]] auto cleanup_window() const -> std::chrono::milliseconds
  {
    return cleanup_window_;
  }

  template<typename T>
  auto cleanup_window(T duration) -> transactions_cleanup_config&
  {
    cleanup_window_ = std::chrono::duration_cast<std::chrono::milliseconds>(duration);
    return *this;
  }

  auto add_collection(const couchbase::transactions::transaction_keyspace& keyspace)
    -> transactions_cleanup_config&
  {
    collections_.emplace_back(keyspace);
    return *this;
  }

  struct built {
    bool cleanup_lost_attempts;
    bool cleanup_client_attempts;
    std::chrono::milliseconds cleanup_window;
    std::list<couchbase::transactions::transaction_keyspace> collections;
  };

  [[nodiscard]] auto build() const -> built
  {
    return { cleanup_lost_attempts_, cleanup_client_attempts_, cleanup_window_, collections_ };
  }
 
private:
  bool cleanup_lost_attempts_{ true };
  bool cleanup_client_attempts_{ true };
  std::chrono::milliseconds cleanup_window_{ std::chrono::seconds(60) };
  std::list<couchbase::transactions::transaction_keyspace> collections_{};
};
} // namespace couchbase::transactions