32class TopicReadSession
final {
36 explicit TopicReadSession(std::shared_ptr<NYdb::NTopic::IReadSession> read_session);
44 std::vector<NYdb::NTopic::TReadSessionEvent::TEvent>
GetEvents(std::optional<std::size_t> max_events_count = {});
50 bool Close(std::chrono::milliseconds timeout);
59 std::shared_ptr<NYdb::NTopic::IReadSession> read_session_;
67class TopicClient
final {
71 TopicClient(std::shared_ptr<impl::Driver> driver, impl::TopicSettings settings);
77 void AlterTopic(
const std::string& path,
const NYdb::NTopic::TAlterTopicSettings& settings);
80 NYdb::NTopic::TDescribeTopicResult
DescribeTopic(
const std::string& path);
92 std::shared_ptr<impl::Driver> driver_;
93 NYdb::NTopic::TTopicClient topic_client_;