Tkrzw
|
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::MessageQueue | static |
GetFileID(const std::string &path) | tkrzw::MessageQueue | static |
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 value | tkrzw::MessageQueue | |
OPEN_IGNORE_BROKEN enum value | tkrzw::MessageQueue | |
OPEN_READ_ONLY enum value | tkrzw::MessageQueue | |
OPEN_SYNC_HARD enum value | tkrzw::MessageQueue | |
OPEN_TRUNCATE enum value | tkrzw::MessageQueue | |
OpenOption enum name | tkrzw::MessageQueue | |
ParseTimestamp(std::string_view expr, int64_t base_time) | tkrzw::MessageQueue | static |
ReadFileMetadata(const std::string &path, int64_t *file_id, int64_t *timestamp, int64_t *file_size) | tkrzw::MessageQueue | static |
ReadNextMessage(File *file, int64_t *file_offset, int64_t *timestamp, std::string *message, int64_t min_timestamp=0) | tkrzw::MessageQueue | static |
RemoveOldFiles(const std::string &prefix, int64_t threshold, bool exclude_latest=false) | tkrzw::MessageQueue | static |
Synchronize(bool hard) | tkrzw::MessageQueue | |
UpdateTimestamp(int64_t timestamp) | tkrzw::MessageQueue | |
Write(int64_t timestamp, std::string_view message) | tkrzw::MessageQueue | |
~MessageQueue() | tkrzw::MessageQueue |