Packages

rocksdb

0.24.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 utilities checkpoint checkpoint_impl.h
Raw

deps/rocksdb/utilities/checkpoint/checkpoint_impl.h 

//  Copyright (c) 2017-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

#ifndef ROCKSDB_LITE



#include "rocksdb/utilities/checkpoint.h"



#include <string>

#include "rocksdb/db.h"

#include "util/filename.h"



namespace rocksdb {



class CheckpointImpl : public Checkpoint {

 public:

  // Creates a Checkpoint object to be used for creating openable snapshots

  explicit CheckpointImpl(DB* db) : db_(db) {}



  // Builds an openable snapshot of RocksDB on the same disk, which

  // accepts an output directory on the same disk, and under the directory

  // (1) hard-linked SST files pointing to existing live SST files

  // SST files will be copied if output directory is on a different filesystem

  // (2) a copied manifest files and other files

  // The directory should not already exist and will be created by this API.

  // The directory will be an absolute path

  using Checkpoint::CreateCheckpoint;

  virtual Status CreateCheckpoint(const std::string& checkpoint_dir,

                                  uint64_t log_size_for_flush) override;



  // Checkpoint logic can be customized by providing callbacks for link, copy,

  // or create.

  Status CreateCustomCheckpoint(

      const DBOptions& db_options,

      std::function<Status(const std::string& src_dirname,

                           const std::string& fname, FileType type)>

          link_file_cb,

      std::function<Status(const std::string& src_dirname,

                           const std::string& fname, uint64_t size_limit_bytes,

                           FileType type)>

          copy_file_cb,

      std::function<Status(const std::string& fname,

                           const std::string& contents, FileType type)>

          create_file_cb,

      uint64_t* sequence_number, uint64_t log_size_for_flush);



 private:

  void CleanStagingDirectory(const std::string& path, Logger* info_log);

  DB* db_;

};



}  //  namespace rocksdb



#endif  // ROCKSDB_LITE