#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.