Class SqliteStorage

Inheritance Relationships

Base Type

  • public rosbag2_storage::storage_interfaces::ReadWriteInterface

Class Documentation

class SqliteStorage : public rosbag2_storage::storage_interfaces::ReadWriteInterface

Public Types

enum class PresetProfile

Values:

enumerator Resilient
enumerator WriteOptimized

Public Functions

SqliteStorage() = default
~SqliteStorage() override
void open(const rosbag2_storage::StorageOptions &storage_options, rosbag2_storage::storage_interfaces::IOFlag io_flag = rosbag2_storage::storage_interfaces::IOFlag::READ_WRITE) override
void remove_topic(const rosbag2_storage::TopicMetadata &topic) override
void create_topic(const rosbag2_storage::TopicMetadata &topic) override
void write(std::shared_ptr<const rosbag2_storage::SerializedBagMessage> message) override
void write(const std::vector<std::shared_ptr<const rosbag2_storage::SerializedBagMessage>> &messages) override
bool has_next() override
std::shared_ptr<rosbag2_storage::SerializedBagMessage> read_next() override
std::vector<rosbag2_storage::TopicMetadata> get_all_topics_and_types() override
rosbag2_storage::BagMetadata get_metadata() override
std::string get_relative_file_path() const override
uint64_t get_bagfile_size() const override
std::string get_storage_identifier() const override
uint64_t get_minimum_split_file_size() const override
void set_filter(const rosbag2_storage::StorageFilter &storage_filter) override
void reset_filter() override
void seek(const rcutils_time_point_value_t &timestamp) override
std::string get_storage_setting(const std::string &key)
SqliteWrapper &get_sqlite_database_wrapper()

Return the sqlite database wrapper.

Throws:

std::runtime_error – if open() has not been called

int get_db_schema_version() const
std::string get_recorded_ros_distro() const

Public Static Functions

static PresetProfile parse_preset_profile(const std::string &profile_string)