Class SqliteStorage

Defined in File sqlite_storage.hpp

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

virtual std::string get_relative_file_path() const override

virtual uint64_t get_bagfile_size() const override

virtual std::string get_storage_identifier() const override

uint64_t get_minimum_split_file_size() const override

virtual void set_filter(const rosbag2_storage::StorageFilter &storage_filter) override

virtual void reset_filter() override

virtual 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)