rocksdb_cursor.hpp

Go to the documentation of this file.

#ifndef KAGOME_ROCKSDB_CURSOR_HPP
#define KAGOME_ROCKSDB_CURSOR_HPP

#include <rocksdb/iterator.h>
#include "storage/rocksdb/rocksdb.hpp"

namespace kagome::storage {

  class RocksDBCursor : public BufferStorageCursor {
   public:
    ~RocksDBCursor() override = default;

    explicit RocksDBCursor(std::shared_ptr<rocksdb::Iterator> it);

    outcome::result<bool> seekFirst() override;

    outcome::result<bool> seek(const BufferView &key) override;

    outcome::result<bool> seekLast() override;

    bool isValid() const override;

    outcome::result<void> next() override;

    std::optional<Buffer> key() const override;

    std::optional<Buffer> value() const override;

   private:
    std::shared_ptr<rocksdb::Iterator> i_;
  };

}  // namespace kagome::storage

#endif  // KAGOME_ROCKSDB_CURSOR_HPP