Packages

rocksdb

2.0.0
3.1.2 3.1.1 3.1.0 3.0.0 2.6.2 2.6.1 retired 2.6.0 retired 2.5.0 2.4.1 2.4.0 2.3.0 2.2.0 2.1.0 2.0.0 1.9.0 1.8.0 1.7.0 1.6.0 1.5.1 1.5.0 1.4.0 1.3.2 1.3.1 1.3.0 1.2.0 1.1.1 1.1.0 1.0.0 0.26.2 0.26.1 0.26.0 0.25.0 0.24.0 0.23.3 0.23.2 0.23.1 0.23.0 0.22.0 0.21.0 0.20.1 0.20.0 0.19.0 0.18.0 0.17.0 0.16.0 0.15.0 0.14.0 0.13.1 0.13.0 0.12.0 0.11.0 0.10.0 0.9.1 0.9.0 0.8.2 0.8.1 0.8.0 0.7.1 0.7.0 0.6.4 0.6.3 0.6.2 0.6.1 0.6.0

RocksDB for Erlang

HexDocs

Current section

Files

Jump to
Readme
64 Versions
0 Dependencies
Dependants
Files
Activity
rocksdb deps rocksdb db event_helpers.h
Raw

deps/rocksdb/db/event_helpers.h 

//  Copyright (c) 2011-present, Facebook, Inc.  All rights reserved.

//  This source code is licensed under both the GPLv2 (found in the

//  COPYING file in the root directory) and Apache 2.0 License

//  (found in the LICENSE.Apache file in the root directory).

#pragma once



#include <memory>

#include <string>

#include <vector>



#include "db/column_family.h"

#include "db/version_edit.h"

#include "logging/event_logger.h"

#include "rocksdb/listener.h"

#include "rocksdb/table_properties.h"



namespace ROCKSDB_NAMESPACE {



class EventHelpers {

 public:

  static void AppendCurrentTime(JSONWriter* json_writer);

  static void NotifyTableFileCreationStarted(

      const std::vector<std::shared_ptr<EventListener>>& listeners,

      const std::string& db_name, const std::string& cf_name,

      const std::string& file_path, int job_id, TableFileCreationReason reason);

  static void NotifyOnBackgroundError(

      const std::vector<std::shared_ptr<EventListener>>& listeners,

      BackgroundErrorReason reason, Status* bg_error,

      InstrumentedMutex* db_mutex, bool* auto_recovery);

  static void LogAndNotifyTableFileCreationFinished(

      EventLogger* event_logger,

      const std::vector<std::shared_ptr<EventListener>>& listeners,

      const std::string& db_name, const std::string& cf_name,

      const std::string& file_path, int job_id, const FileDescriptor& fd,

      uint64_t oldest_blob_file_number, const TableProperties& table_properties,

      TableFileCreationReason reason, const Status& s,

      const std::string& file_checksum,

      const std::string& file_checksum_func_name);

  static void LogAndNotifyTableFileDeletion(

      EventLogger* event_logger, int job_id, uint64_t file_number,

      const std::string& file_path, const Status& status,

      const std::string& db_name,

      const std::vector<std::shared_ptr<EventListener>>& listeners);

  static void NotifyOnErrorRecoveryEnd(

      const std::vector<std::shared_ptr<EventListener>>& listeners,

      const Status& old_bg_error, const Status& new_bg_error,

      InstrumentedMutex* db_mutex);



  static void NotifyBlobFileCreationStarted(

      const std::vector<std::shared_ptr<EventListener>>& listeners,

      const std::string& db_name, const std::string& cf_name,

      const std::string& file_path, int job_id,

      BlobFileCreationReason creation_reason);



  static void LogAndNotifyBlobFileCreationFinished(

      EventLogger* event_logger,

      const std::vector<std::shared_ptr<EventListener>>& listeners,

      const std::string& db_name, const std::string& cf_name,

      const std::string& file_path, int job_id, uint64_t file_number,

      BlobFileCreationReason creation_reason, const Status& s,

      const std::string& file_checksum,

      const std::string& file_checksum_func_name, uint64_t total_blob_count,

      uint64_t total_blob_bytes);



  static void LogAndNotifyBlobFileDeletion(

      EventLogger* event_logger,

      const std::vector<std::shared_ptr<EventListener>>& listeners, int job_id,

      uint64_t file_number, const std::string& file_path, const Status& status,

      const std::string& db_name);



 private:

  static void LogAndNotifyTableFileCreation(

      EventLogger* event_logger,

      const std::vector<std::shared_ptr<EventListener>>& listeners,

      const FileDescriptor& fd, const TableFileCreationInfo& info);

};



}  // namespace ROCKSDB_NAMESPACE