dist_lock_component_base.hpp

Go to the documentation of this file.

#pragma once
 
 
#include <userver/components/loggable_component_base.hpp>
#include <userver/dist_lock/dist_locked_worker.hpp>
#include <userver/storages/mongo/collection.hpp>
#include <userver/storages/mongo/dist_lock_strategy.hpp>
#include <userver/utils/statistics/entry.hpp>
 
USERVER_NAMESPACE_BEGIN
 
namespace storages::mongo {
 
// clang-format off
 
 
// clang-format on
 
class DistLockComponentBase : public components::LoggableComponentBase {
 public:
  DistLockComponentBase(const components::ComponentConfig&,
                        const components::ComponentContext&,
                        storages::mongo::Collection);
 
  ~DistLockComponentBase() override;
 
  dist_lock::DistLockedWorker& GetWorker();
 
  static yaml_config::Schema GetStaticConfigSchema();
 
 protected:
  virtual void DoWork() = 0;
 
  virtual void DoWorkTestsuite() { DoWork(); }
 
  void Start();
 
  void Stop();
 
 private:
  std::unique_ptr<dist_lock::DistLockedWorker> worker_;
  utils::statistics::Entry statistics_holder_;
  bool testsuite_enabled_{false};
};
 
}  // namespace storages::mongo
 
USERVER_NAMESPACE_END