bag

bag#

namespace heph#
namespace bag#
class ZenohPlayer#

Public Functions

~ZenohPlayer()#
std::future<void> start()#
std::future<void> stop()#
void wait() const#

Public Static Functions

static ZenohPlayer create(ZenohPlayerParams params)#
struct ZenohPlayerParams#

Public Members

ipc::zenoh::SessionPtr session#
std::unique_ptr<mcap::McapReader> bag_reader#
bool wait_for_readers_to_connect = {false}#
namespace heph
namespace bag
class ZenohRecorder#

Public Functions

~ZenohRecorder()#
std::future<void> start()#
std::future<void> stop()#

Public Static Functions

static ZenohRecorder create(ZenohRecorderParams params)#
struct ZenohRecorderParams#

Public Members

ipc::zenoh::SessionPtr session#
std::unique_ptr<IBagWriter> bag_writer#
ipc::TopicFilterParams topics_filter_params#
namespace heph
namespace bag

Functions

std::unique_ptr<IBagWriter> createMcapWriter(McapWriterParams params)#
class IBagWriter#

Public Functions

virtual ~IBagWriter() = default#
virtual void registerSchema(const serdes::TypeInfo &type_info) = 0#
virtual void registerChannel(const std::string &topic, const serdes::TypeInfo &type_info) = 0#
virtual void writeRecord(const ipc::zenoh::MessageMetadata &metadata, std::span<const std::byte> data) = 0#
struct McapWriterParams#

Public Members

std::filesystem::path output_file#
mcap::McapWriterOptions mcap_writer_options = mcap::McapWriterOptions("")#
Contents