Tkrzw
tkrzw::MessageQueue Member List

This is the complete list of members for tkrzw::MessageQueue, including all inherited members.

CancelReaders()tkrzw::MessageQueue
Close()tkrzw::MessageQueue
FindFiles(const std::string &prefix, std::vector< std::string > *paths)tkrzw::MessageQueuestatic
GetFileID(const std::string &path)tkrzw::MessageQueuestatic
GetTimestamp()tkrzw::MessageQueue
MakeReader(int64_t min_timestamp)tkrzw::MessageQueue
MessageQueue()tkrzw::MessageQueue
Open(const std::string &prefix, int64_t max_file_size, int32_t options=OPEN_DEFAULT)tkrzw::MessageQueue
OPEN_DEFAULT enum valuetkrzw::MessageQueue
OPEN_IGNORE_BROKEN enum valuetkrzw::MessageQueue
OPEN_READ_ONLY enum valuetkrzw::MessageQueue
OPEN_SYNC_HARD enum valuetkrzw::MessageQueue
OPEN_TRUNCATE enum valuetkrzw::MessageQueue
OpenOption enum nametkrzw::MessageQueue
ParseTimestamp(std::string_view expr, int64_t base_time)tkrzw::MessageQueuestatic
ReadFileMetadata(const std::string &path, int64_t *file_id, int64_t *timestamp, int64_t *file_size)tkrzw::MessageQueuestatic
ReadNextMessage(File *file, int64_t *file_offset, int64_t *timestamp, std::string *message, int64_t min_timestamp=0)tkrzw::MessageQueuestatic
RemoveOldFiles(const std::string &prefix, int64_t threshold, bool exclude_latest=false)tkrzw::MessageQueuestatic
Synchronize(bool hard)tkrzw::MessageQueue
UpdateTimestamp(int64_t timestamp)tkrzw::MessageQueue
Write(int64_t timestamp, std::string_view message)tkrzw::MessageQueue
~MessageQueue()tkrzw::MessageQueue