#include <userver/ydb/topic.hpp>
YDB Topic Client.
Public Member Functions | |
void | AlterTopic (const std::string &path, const NYdb::NTopic::TAlterTopicSettings &settings) |
Alter topic. | |
NYdb::NTopic::TDescribeTopicResult | DescribeTopic (const std::string &path) |
Describe topic. | |
TopicReadSession | CreateReadSession (const NYdb::NTopic::TReadSessionSettings &settings) |
Create read session. | |
NYdb::NTopic::TTopicClient & | GetNativeTopicClient () |
NYdb::NTopic::TTopicClient & ydb::TopicClient::GetNativeTopicClient | ( | ) |
Get native topic client
<core/include/userver/drivers/subscribable_futures.hpp>
can help with non-blocking wait operations.